org.apache.storm.kafka.trident

Class LocalSubmitter

java.lang.Object

org.apache.storm.kafka.trident.LocalSubmitter

public class LocalSubmitter
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LocalSubmitter(org.apache.storm.LocalDRPC drpc, org.apache.storm.LocalCluster cluster)
LocalSubmitter(StormTopology topology, org.apache.storm.LocalDRPC drpc, org.apache.storm.LocalCluster cluster, String name)

Method Summary

Modifier and Type	Method and Description
static Config	defaultConfig()
static Config	defaultConfig(boolean debug)
org.apache.storm.LocalCluster	getCluster()
org.apache.storm.LocalDRPC	getDrpc()
void	kill(String name)
static LocalSubmitter	newInstance()
void	printResults(int num, int time, TimeUnit unit) Prints the DRPC results for the amount of time specified
void	shutdown()
void	submit(String name, Config config, StormTopology topology)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

LocalSubmitter

public LocalSubmitter(org.apache.storm.LocalDRPC drpc,
                      org.apache.storm.LocalCluster cluster)

LocalSubmitter

public LocalSubmitter(StormTopology topology,
                      org.apache.storm.LocalDRPC drpc,
                      org.apache.storm.LocalCluster cluster,
                      String name)

Method Detail

newInstance

public static LocalSubmitter newInstance()

defaultConfig

public static Config defaultConfig()

defaultConfig

public static Config defaultConfig(boolean debug)

submit

public void submit(String name,
                   Config config,
                   StormTopology topology)

printResults

public void printResults(int num,
                         int time,
                         TimeUnit unit)

Prints the DRPC results for the amount of time specified

kill

public void kill(String name)

shutdown

public void shutdown()

getDrpc

public org.apache.storm.LocalDRPC getDrpc()

getCluster

public org.apache.storm.LocalCluster getCluster()