Uses of Class
org.apache.storm.task.TopologyContext

Packages that use TopologyContext

Package	Description
org.apache.storm
org.apache.storm.bolt
org.apache.storm.cassandra.bolt
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.daemon
org.apache.storm.daemon.metrics
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt	ElasticSearch examples classes.
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.eventhubs.bolt
org.apache.storm.eventhubs.spout
org.apache.storm.eventhubs.trident
org.apache.storm.flux.examples
org.apache.storm.hbase.bolt
org.apache.storm.hbase.state
org.apache.storm.hbase.topology
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.bolt.format
org.apache.storm.hdfs.spout
org.apache.storm.hdfs.trident
org.apache.storm.hive.bolt
org.apache.storm.hive.trident
org.apache.storm.hooks
org.apache.storm.hooks.info
org.apache.storm.jdbc.bolt
org.apache.storm.jdbc.spout
org.apache.storm.jms.bolt
org.apache.storm.jms.example
org.apache.storm.jms.spout
org.apache.storm.jms.trident
org.apache.storm.kafka.bolt
org.apache.storm.kafka.spout
org.apache.storm.kafka.spout.internal
org.apache.storm.kafka.spout.subscription
org.apache.storm.kafka.spout.trident
org.apache.storm.kinesis.spout
org.apache.storm.lambda
org.apache.storm.loadgen
org.apache.storm.metric
org.apache.storm.metric.api
org.apache.storm.metrics2
org.apache.storm.mongodb.bolt
org.apache.storm.mongodb.topology
org.apache.storm.mqtt.bolt
org.apache.storm.mqtt.spout
org.apache.storm.multilang
org.apache.storm.opentsdb
org.apache.storm.opentsdb.bolt
org.apache.storm.perf.bolt
org.apache.storm.perf.spout
org.apache.storm.perf.utils
org.apache.storm.pmml
org.apache.storm.redis.bolt
org.apache.storm.redis.state
org.apache.storm.redis.topology
org.apache.storm.rocketmq.bolt
org.apache.storm.rocketmq.spout
org.apache.storm.rocketmq.topology
org.apache.storm.security.auth.kerberos
org.apache.storm.solr.bolt
org.apache.storm.solr.spout
org.apache.storm.spout
org.apache.storm.sql.runtime.datasource.socket.bolt
org.apache.storm.sql.runtime.datasource.socket.spout
org.apache.storm.st.topology.window
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.starter.spout
org.apache.storm.state
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.trident.operation
org.apache.storm.trident.planner
org.apache.storm.trident.planner.processor
org.apache.storm.trident.spout
org.apache.storm.trident.testing
org.apache.storm.trident.topology
org.apache.storm.trident.windowing
org.apache.storm.utils

Uses of TopologyContext in org.apache.storm

Methods in org.apache.storm with parameters of type TopologyContext

Modifier and Type	Method and Description
void	ExclamationTopology.FixedOrderWordSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	ExclamationTopology.ExclamationBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.bolt

Methods in org.apache.storm.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	JoinBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.cassandra.bolt

Methods in org.apache.storm.cassandra.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	BaseCassandraBolt.prepare(Map<String,Object> topoConfig, TopologyContext topologyContext, OutputCollector outputCollector) Called when a task for this component is initialized within a worker on the cluster.
void	BatchCassandraWriterBolt.prepare(Map<String,Object> topoConfig, TopologyContext topologyContext, OutputCollector outputCollector) Called when a task for this component is initialized within a worker on the cluster.

Uses of TopologyContext in org.apache.storm.clojure

Methods in org.apache.storm.clojure with parameters of type TopologyContext

Modifier and Type	Method and Description
void	ClojureSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	ClojureBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.coordination

Methods in org.apache.storm.coordination with parameters of type TopologyContext

Modifier and Type	Method and Description
void	IBatchBolt.prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, T id)
void	CoordinatedBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)
void	BatchBoltExecutor.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.daemon

Methods in org.apache.storm.daemon that return TopologyContext

Modifier and Type	Method and Description
TopologyContext	Task.getUserContext()

Methods in org.apache.storm.daemon with parameters of type TopologyContext

Modifier and Type	Method and Description
void	Acker.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.daemon.metrics

Methods in org.apache.storm.daemon.metrics with parameters of type TopologyContext

Modifier and Type	Method and Description
void	BuiltinMetrics.registerAll(Map<String,Object> topoConf, TopologyContext context)
static void	BuiltinMetricsUtil.registerIconnectionClientMetrics(Map<NodeInfo,IConnection> nodePortToSocket, Map<String,Object> topoConf, TopologyContext context)
static void	BuiltinMetricsUtil.registerIconnectionServerMetric(Object server, Map<String,Object> topoConf, TopologyContext context)
static void	BuiltinMetricsUtil.registerMetric(String name, IMetric metric, Map<String,Object> topoConf, TopologyContext context)
static void	BuiltinMetricsUtil.registerQueueMetrics(Map<String,JCQueue> queues, Map<String,Object> topoConf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.drpc

Methods in org.apache.storm.drpc with parameters of type TopologyContext

Modifier and Type	Method and Description
void	DRPCSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	PrepareRequest.prepare(Map<String,Object> map, TopologyContext context)
void	KeyedFairBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	ReturnResults.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	JoinResult.prepare(Map<String,Object> map, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.elasticsearch.bolt

Methods in org.apache.storm.elasticsearch.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	EsIndexTopology.UserDataSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collectorArg) Acquires collector and initializes pending.
void	EsIndexBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector)
void	AbstractEsBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector)
void	EsPercolateBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector)

Uses of TopologyContext in org.apache.storm.elasticsearch.trident

Methods in org.apache.storm.elasticsearch.trident with parameters of type TopologyContext

Modifier and Type	Method and Description
void	TridentEsTopology.FixedBatchSpout.open(Map<String,Object> conf, TopologyContext context) Opens the spout.

Uses of TopologyContext in org.apache.storm.eventhubs.bolt

Methods in org.apache.storm.eventhubs.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	EventHubBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.eventhubs.spout

Methods in org.apache.storm.eventhubs.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	EventHubSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.eventhubs.trident

Methods in org.apache.storm.eventhubs.trident with parameters of type TopologyContext

Modifier and Type	Method and Description
IPartitionedTridentSpout.Coordinator<Partitions>	TransactionalTridentEventHubSpout.getCoordinator(Map<String,Object> conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Coordinator<Partitions>	OpaqueTridentEventHubSpout.getCoordinator(Map<String,Object> conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<Partitions,Partition,Map<String,Object>>	TransactionalTridentEventHubSpout.getEmitter(Map<String,Object> conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>	OpaqueTridentEventHubSpout.getEmitter(Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.flux.examples

Methods in org.apache.storm.flux.examples with parameters of type TopologyContext

Modifier and Type	Method and Description
void	WordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)
void	TestWindowBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	StatefulWordCounter.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.hbase.bolt

Methods in org.apache.storm.hbase.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	HBaseBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector collector)
void	HBaseLookupBolt.prepare(Map<String,Object> config, TopologyContext topologyContext, OutputCollector collector)
void	AbstractHBaseBolt.prepare(Map<String,Object> topoConf, TopologyContext topologyContext, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.hbase.state

Methods in org.apache.storm.hbase.state with parameters of type TopologyContext

Modifier and Type	Method and Description
State	HBaseKeyValueStateProvider.newState(String namespace, Map<String,Object> stormConf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.hbase.topology

Methods in org.apache.storm.hbase.topology with parameters of type TopologyContext

Modifier and Type	Method and Description
void	WordSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	WordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)
void	TotalWordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.hdfs.bolt

Methods in org.apache.storm.hdfs.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	HdfsBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
void	SequenceFileBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
protected void	AvroGenericRecordBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
protected abstract void	AbstractHdfsBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
void	SequenceFileTopology.SentenceSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void	HdfsFileTopology.SentenceSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void	SequenceFileTopology.MyBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)
void	HdfsFileTopology.MyBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)
void	AbstractHdfsBolt.prepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector) Marked as final to prevent override.

Uses of TopologyContext in org.apache.storm.hdfs.bolt.format

Methods in org.apache.storm.hdfs.bolt.format with parameters of type TopologyContext

Modifier and Type	Method and Description
void	DefaultFileNameFormat.prepare(Map<String,Object> conf, TopologyContext topologyContext)
void	SimpleFileNameFormat.prepare(Map<String,Object> conf, TopologyContext topologyContext)
void	FileNameFormat.prepare(Map<String,Object> conf, TopologyContext topologyContext)

Uses of TopologyContext in org.apache.storm.hdfs.spout

Methods in org.apache.storm.hdfs.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	HdfsSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	HdfsSpoutTopology.ConstBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.hdfs.trident

Methods in org.apache.storm.hdfs.trident with parameters of type TopologyContext

Modifier and Type	Method and Description
void	FixedBatchSpout.open(Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.hive.bolt

Methods in org.apache.storm.hive.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	HiveTopologyPartitioned.UserDataSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void	BucketTestHiveTopology.UserDataSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void	HiveTopology.UserDataSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void	HiveBolt.prepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.hive.trident

Methods in org.apache.storm.hive.trident with parameters of type TopologyContext

Modifier and Type	Method and Description
void	TridentHiveTopology.FixedBatchSpout.open(Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.hooks

Methods in org.apache.storm.hooks with parameters of type TopologyContext

Modifier and Type	Method and Description
void	ITaskHook.prepare(Map<String,Object> conf, TopologyContext context)
void	BaseTaskHook.prepare(Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.hooks.info

Methods in org.apache.storm.hooks.info with parameters of type TopologyContext

Modifier and Type	Method and Description
void	BoltAckInfo.applyOn(TopologyContext topologyContext)
void	EmitInfo.applyOn(TopologyContext topologyContext)
void	SpoutAckInfo.applyOn(TopologyContext topologyContext)
void	BoltExecuteInfo.applyOn(TopologyContext topologyContext)
void	BoltFailInfo.applyOn(TopologyContext topologyContext)
void	SpoutFailInfo.applyOn(TopologyContext topologyContext)

Uses of TopologyContext in org.apache.storm.jdbc.bolt

Methods in org.apache.storm.jdbc.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	AbstractJdbcBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector) Subclasses should call this to ensure output collector and connection provider are set up, and finally jdbcClient is initialized properly.
void	JdbcInsertBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.jdbc.spout

Methods in org.apache.storm.jdbc.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	UserSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.jms.bolt

Methods in org.apache.storm.jms.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	JmsBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) Initializes JMS resources.

Uses of TopologyContext in org.apache.storm.jms.example

Methods in org.apache.storm.jms.example with parameters of type TopologyContext

Modifier and Type	Method and Description
void	GenericBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.jms.spout

Methods in org.apache.storm.jms.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	JmsSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector spoutOutputCollector) ISpout implementation.

Uses of TopologyContext in org.apache.storm.jms.trident

Methods in org.apache.storm.jms.trident with parameters of type TopologyContext

Modifier and Type	Method and Description
ITridentSpout.BatchCoordinator<JmsBatch>	TridentJmsSpout.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<JmsBatch>	TridentJmsSpout.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.kafka.bolt

Methods in org.apache.storm.kafka.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	PreparableCallback.prepare(Map<String,Object> topoConf, TopologyContext context)
void	KafkaBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.kafka.spout

Methods in org.apache.storm.kafka.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	KafkaTupleListener.open(Map<String,Object> conf, TopologyContext context) Called during the initialization of the kafka spout.
void	EmptyKafkaTupleListener.open(Map<String,Object> conf, TopologyContext context)
void	KafkaSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	KafkaSpoutTestBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.kafka.spout.internal

Constructors in org.apache.storm.kafka.spout.internal with parameters of type TopologyContext

Constructor and Description
CommitMetadataManager(TopologyContext context, KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Create a manager with the given context.

Uses of TopologyContext in org.apache.storm.kafka.spout.subscription

Methods in org.apache.storm.kafka.spout.subscription with parameters of type TopologyContext

Modifier and Type	Method and Description
Set<org.apache.kafka.common.TopicPartition>	ManualPartitioner.getPartitionsForThisTask(List<org.apache.kafka.common.TopicPartition> allPartitionsSorted, TopologyContext context) Filter the list of all partitions handled by this set of spouts to get only the partitions assigned to this task.
Set<org.apache.kafka.common.TopicPartition>	RoundRobinManualPartitioner.getPartitionsForThisTask(List<org.apache.kafka.common.TopicPartition> allPartitionsSorted, TopologyContext context)

Uses of TopologyContext in org.apache.storm.kafka.spout.trident

Methods in org.apache.storm.kafka.spout.trident with parameters of type TopologyContext

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>>	KafkaTridentSpoutOpaque.getCoordinator(Map<String,Object> conf, TopologyContext context)
IPartitionedTridentSpout.Coordinator<List<Map<String,Object>>>	KafkaTridentSpoutTransactional.getCoordinator(Map<String,Object> conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>	KafkaTridentSpoutOpaque.getEmitter(Map<String,Object> conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>	KafkaTridentSpoutTransactional.getEmitter(Map<String,Object> conf, TopologyContext context)

Constructors in org.apache.storm.kafka.spout.trident with parameters of type TopologyContext

Constructor and Description
KafkaTridentSpoutEmitter(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig, TopologyContext topologyContext) Create a new Kafka spout emitter.

Uses of TopologyContext in org.apache.storm.kinesis.spout

Methods in org.apache.storm.kinesis.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	KinesisSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.lambda

Methods in org.apache.storm.lambda with parameters of type TopologyContext

Modifier and Type	Method and Description
void	LambdaSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.loadgen

Methods in org.apache.storm.loadgen with parameters of type TopologyContext

Modifier and Type	Method and Description
void	LoadSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	HttpForwardingMetricsConsumer.prepare(Map<String,Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	ThroughputVsLatency.SplitSentence.prepare(Map<String,Object> stormConf, TopologyContext context)
void	LoadBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.metric

Methods in org.apache.storm.metric with parameters of type TopologyContext

Modifier and Type	Method and Description
void	IEventLogger.prepare(Map<String,Object> conf, Map<String,Object> arguments, TopologyContext context)
void	FileBasedEventLogger.prepare(Map<String,Object> conf, Map<String,Object> arguments, TopologyContext context)
void	LoggingMetricsConsumer.prepare(Map<String,Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	MetricsConsumerBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	SystemBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	EventLoggerBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.metric.api

Methods in org.apache.storm.metric.api with parameters of type TopologyContext

Modifier and Type	Method and Description
void	IMetricsConsumer.prepare(Map<String,Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	IMetricsRegistrant.registerMetrics(TopologyContext topoContext, Map<String,Object> topoConf)

Uses of TopologyContext in org.apache.storm.metrics2

Methods in org.apache.storm.metrics2 with parameters of type TopologyContext

Modifier and Type	Method and Description
com.codahale.metrics.Counter	StormMetricRegistry.counter(String name, TopologyContext context)
<T> com.codahale.metrics.Gauge<T>	StormMetricRegistry.gauge(String name, com.codahale.metrics.Gauge<T> gauge, TopologyContext context)
com.codahale.metrics.Histogram	StormMetricRegistry.histogram(String name, TopologyContext context)
com.codahale.metrics.Meter	StormMetricRegistry.meter(String name, TopologyContext context)
void	StormMetricRegistry.metricSet(String prefix, com.codahale.metrics.MetricSet set, TopologyContext context)
com.codahale.metrics.Timer	StormMetricRegistry.timer(String name, TopologyContext context)

Uses of TopologyContext in org.apache.storm.mongodb.bolt

Methods in org.apache.storm.mongodb.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	MongoInsertBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	AbstractMongoBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.mongodb.topology

Methods in org.apache.storm.mongodb.topology with parameters of type TopologyContext

Modifier and Type	Method and Description
void	WordSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	WordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)
void	TotalWordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.mqtt.bolt

Methods in org.apache.storm.mqtt.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	MqttBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.mqtt.spout

Fields in org.apache.storm.mqtt.spout declared as TopologyContext

Modifier and Type	Field and Description
protected TopologyContext	MqttSpout.context

Methods in org.apache.storm.mqtt.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	MqttSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.multilang

Methods in org.apache.storm.multilang with parameters of type TopologyContext

Modifier and Type	Method and Description
Number	ISerializer.connect(Map<String,Object> conf, TopologyContext context) This method transmits the Storm config to the non-JVM process and receives its pid.
Number	JsonSerializer.connect(Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.opentsdb

Methods in org.apache.storm.opentsdb with parameters of type TopologyContext

Modifier and Type	Method and Description
void	MetricGenBatchSpout.open(Map<String,Object> conf, TopologyContext context)
void	MetricGenSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.opentsdb.bolt

Methods in org.apache.storm.opentsdb.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	OpenTsdbBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.perf.bolt

Methods in org.apache.storm.perf.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	CountBolt.prepare(Map<String,Object> topoConf, TopologyContext context)
void	SplitSentenceBolt.prepare(Map<String,Object> topoConf, TopologyContext context)
void	IdBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	DevNullBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.perf.spout

Methods in org.apache.storm.perf.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	FileReadSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	StringGenSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	ConstSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	WordGenSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.perf.utils

Methods in org.apache.storm.perf.utils with parameters of type TopologyContext

Modifier and Type	Method and Description
void	IdentityBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.pmml

Methods in org.apache.storm.pmml with parameters of type TopologyContext

Modifier and Type	Method and Description
void	RawInputFromCSVSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	PMMLPredictorBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.redis.bolt

Methods in org.apache.storm.redis.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	AbstractRedisBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.

Uses of TopologyContext in org.apache.storm.redis.state

Methods in org.apache.storm.redis.state with parameters of type TopologyContext

Modifier and Type	Method and Description
State	RedisKeyValueStateProvider.newState(String namespace, Map<String,Object> topoConf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.redis.topology

Methods in org.apache.storm.redis.topology with parameters of type TopologyContext

Modifier and Type	Method and Description
void	WordSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	WordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)
void	WhitelistWordCount.PrintWordTotalCountBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	LookupWordCount.PrintWordTotalCountBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.rocketmq.bolt

Methods in org.apache.storm.rocketmq.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	RocketMqBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.rocketmq.spout

Methods in org.apache.storm.rocketmq.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	RocketMqSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.rocketmq.topology

Methods in org.apache.storm.rocketmq.topology with parameters of type TopologyContext

Modifier and Type	Method and Description
void	WordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.security.auth.kerberos

Methods in org.apache.storm.security.auth.kerberos with parameters of type TopologyContext

Modifier and Type	Method and Description
void	AutoTGT.registerMetrics(TopologyContext topoContext, Map<String,Object> topoConf)

Uses of TopologyContext in org.apache.storm.solr.bolt

Methods in org.apache.storm.solr.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	SolrUpdateBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.solr.spout

Methods in org.apache.storm.solr.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	SolrFieldsSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	SolrJsonSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.spout

Methods in org.apache.storm.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	CheckpointSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	ShellSpout.open(Map<String,Object> topoConf, TopologyContext context, SpoutOutputCollector collector)
void	ISpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.

Uses of TopologyContext in org.apache.storm.sql.runtime.datasource.socket.bolt

Methods in org.apache.storm.sql.runtime.datasource.socket.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	SocketBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.sql.runtime.datasource.socket.spout

Methods in org.apache.storm.sql.runtime.datasource.socket.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	SocketSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.st.topology.window

Methods in org.apache.storm.st.topology.window with parameters of type TopologyContext

Modifier and Type	Method and Description
void	IncrementingSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	TimeDataIncrementingSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	TimeDataVerificationBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	VerificationBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.starter

Methods in org.apache.storm.starter with parameters of type TopologyContext

Modifier and Type	Method and Description
void	FastWordCountTopology.FastRandomSentenceSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	InOrderDeliveryTest.InOrderSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	BlobStoreAPIWordCountTopology.RandomSentenceSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	AnchoredWordCount.RandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	ReachTopology.PartialUniquer.prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	ReachTopology.CountAggregator.prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	ResourceAwareExampleTopology.ExclamationBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)
void	MultiThreadWordCountTopology.MultiThreadedSplitSentence.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	MultipleLoggerTopology.ExclamationLoggingBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)
void	ExclamationTopology.ExclamationBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.starter.bolt

Methods in org.apache.storm.starter.bolt with parameters of type TopologyContext

Modifier and Type	Method and Description
void	RollingCountAggBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	RollingCountBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	SingleJoinBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)
void	SlidingWindowSumBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.starter.spout

Methods in org.apache.storm.starter.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
void	RandomNumberGeneratorSpout.open(Map<String,Object> conf, TopologyContext context)
void	RandomIntegerSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	RandomSentenceSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)

Uses of TopologyContext in org.apache.storm.state

Methods in org.apache.storm.state with parameters of type TopologyContext

Modifier and Type	Method and Description
static State	StateFactory.getState(String namespace, Map<String,Object> topoConf, TopologyContext context) Returns a new state instance using the Config.TOPOLOGY_STATE_PROVIDER or a InMemoryKeyValueState if no provider is configured.
State	StateProvider.newState(String namespace, Map<String,Object> topoConf, TopologyContext context) Returns a new state instance.
State	InMemoryKeyValueStateProvider.newState(String namespace, Map<String,Object> topoConf, TopologyContext context)
void	IStateSpout.open(Map<String,Object> conf, TopologyContext context)

Constructors in org.apache.storm.state with parameters of type TopologyContext

Constructor and Description
DefaultStateSerializer(Map<String,Object> topoConf, TopologyContext context)
DefaultStateSerializer(Map<String,Object> topoConf, TopologyContext context, List<Class<?>> classesToRegister) Constructs a DefaultStateSerializer instance with the given list of classes registered in kryo.

Uses of TopologyContext in org.apache.storm.task

Methods in org.apache.storm.task with parameters of type TopologyContext

Modifier and Type	Method and Description
void	ShellBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	IBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.

Uses of TopologyContext in org.apache.storm.testing

Methods in org.apache.storm.testing with parameters of type TopologyContext

Modifier and Type	Method and Description
void	PythonShellMetricsSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	TestPlannerSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	FeederSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	TestEventLogSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	SpoutTracker.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	FixedTupleSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	TestWordSpout.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	ForwardingMetricsConsumer.prepare(Map<String,Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	TestConfBolt.prepare(Map<String,Object> conf, TopologyContext context)
void	TestWordCounter.prepare(Map<String,Object> topoConf, TopologyContext context)
void	TupleCaptureBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	NonRichBoltTracker.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestPlannerBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestAggregatesCounter.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	PythonShellMetricsBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestGlobalCount.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestEventOrderCheckBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.topology

Methods in org.apache.storm.topology with parameters of type TopologyContext

Modifier and Type	Method and Description
protected void	WindowedBoltExecutor.doPrepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector, Collection<Event<Tuple>> queue, boolean stateful)
protected void	BaseStatefulBoltExecutor.init(TopologyContext context, OutputCollector collector)
void	IBasicBolt.prepare(Map<String,Object> topoConf, TopologyContext context)
void	StatefulBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	StatefulWindowedBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	IStatefulBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) Analogue to bolt function.
void	PersistentWindowedBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	BasicBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	CheckpointTupleForwarder.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector outputCollector)
void	WindowedBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	IWindowedBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) This is similar to the IBolt.prepare(Map, TopologyContext, OutputCollector) except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow.

Uses of TopologyContext in org.apache.storm.topology.base

Methods in org.apache.storm.topology.base with parameters of type TopologyContext

Modifier and Type	Method and Description
void	BaseBasicBolt.prepare(Map<String,Object> topoConf, TopologyContext context)
void	BaseWindowedBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	BaseStatefulBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.trident.operation

Constructors in org.apache.storm.trident.operation with parameters of type TopologyContext

Constructor and Description
TridentOperationContext(TopologyContext topoContext, TridentTuple.Factory factory)

Uses of TopologyContext in org.apache.storm.trident.planner

Methods in org.apache.storm.trident.planner with parameters of type TopologyContext

Modifier and Type	Method and Description
void	SubtopologyBolt.prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector batchCollector)
void	TridentProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)

Uses of TopologyContext in org.apache.storm.trident.planner.processor

Methods in org.apache.storm.trident.planner.processor with parameters of type TopologyContext

Modifier and Type	Method and Description
void	MapProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
void	AggregateProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
void	PartitionPersistProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
void	EachProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
void	StateQueryProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
void	ProjectedProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
void	MultiReducerProcessor.prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)

Uses of TopologyContext in org.apache.storm.trident.spout

Methods in org.apache.storm.trident.spout with parameters of type TopologyContext

Modifier and Type	Method and Description
IPartitionedTridentSpout.Coordinator<PartitionsT>	IPartitionedTridentSpout.getCoordinator(Map<String,Object> conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Coordinator<PartitionsT>	IOpaquePartitionedTridentSpout.getCoordinator(Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	PartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<T>	ITridentSpout.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context) The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted.
ITridentSpout.BatchCoordinator<Object>	OpaquePartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	BatchSpoutExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	RichSpoutBatchExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT,T>	IPartitionedTridentSpout.getEmitter(Map<String,Object> conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Emitter<PartitionsT,PartitionT,M>	IOpaquePartitionedTridentSpout.getEmitter(Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<Object>	PartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ICommitterTridentSpout.Emitter	ICommitterTridentSpout.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<T>	ITridentSpout.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
ICommitterTridentSpout.Emitter	OpaquePartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<Object>	BatchSpoutExecutor.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<Object>	RichSpoutBatchExecutor.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
void	IBatchSpout.open(Map<String,Object> conf, TopologyContext context)
void	RichSpoutBatchTriggerer.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	TridentSpoutCoordinator.prepare(Map<String,Object> conf, TopologyContext context)
void	TridentSpoutExecutor.prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector)

Constructors in org.apache.storm.trident.spout with parameters of type TopologyContext

Constructor and Description
Coordinator(Map<String,Object> conf, TopologyContext context)
Emitter(String txStateId, Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.trident.testing

Methods in org.apache.storm.trident.testing with parameters of type TopologyContext

Modifier and Type	Method and Description
ITridentSpout.BatchCoordinator<Map<Integer,List<List<Object>>>>	FeederCommitterBatchSpout.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Map<Integer,List<List<Object>>>>	FeederBatchSpout.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ICommitterTridentSpout.Emitter	FeederCommitterBatchSpout.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<Map<Integer,List<List<Object>>>>	FeederBatchSpout.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
void	FixedBatchSpout.open(Map<String,Object> conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.trident.topology

Methods in org.apache.storm.trident.topology with parameters of type TopologyContext

Modifier and Type	Method and Description
void	MasterBatchCoordinator.open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void	ITridentBatchBolt.prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector)
void	TridentBoltExecutor.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.trident.windowing

Methods in org.apache.storm.trident.windowing with parameters of type TopologyContext

Modifier and Type	Method and Description
void	WindowTridentProcessor.prepare(Map<String,Object> topoConf, TopologyContext context, TridentContext tridentContext)

Uses of TopologyContext in org.apache.storm.utils

Methods in org.apache.storm.utils with parameters of type TopologyContext

Modifier and Type	Method and Description
Number	ShellProcess.launch(Map<String,Object> conf, TopologyContext context)
Number	ShellProcess.launch(Map<String,Object> conf, TopologyContext context, boolean changeDirectory)
void	DefaultShellLogHandler.setUpContext(Class<?> ownerCls, ShellProcess process, TopologyContext context) This default implementation saves the ShellProcess so it can output the process info string later.
void	ShellLogHandler.setUpContext(Class<?> ownerCls, ShellProcess process, TopologyContext context) Called at least once before ShellLogHandler.log(org.apache.storm.multilang.ShellMsg) for each spout and bolt.