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

Packages that use TopologyContext

Package	Description
org.apache.storm.bolt
org.apache.storm.cassandra.bolt
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.drpc
org.apache.storm.druid.bolt
org.apache.storm.elasticsearch.bolt
org.apache.storm.elasticsearch.trident
org.apache.storm.eventhubs.bolt
org.apache.storm.eventhubs.samples.bolt
org.apache.storm.eventhubs.spout
org.apache.storm.eventhubs.trident
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.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
org.apache.storm.kafka.bolt
org.apache.storm.kafka.spout
org.apache.storm.kafka.spout.internal
org.apache.storm.kafka.spout.trident
org.apache.storm.kafka.trident
org.apache.storm.kinesis.spout
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.solr.bolt
org.apache.storm.solr.spout
org.apache.storm.spout
org.apache.storm.sql.runtime.datasource.socket.trident
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.transactional
org.apache.storm.transactional.partitioned
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.bolt

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

Modifier and Type	Method and Description
void	JoinBolt.prepare(Map stormConf, 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	BatchCassandraWriterBolt.prepare(Map stormConfig, TopologyContext topologyContext, OutputCollector outputCollector) Called when a task for this component is initialized within a worker on the cluster.
void	BaseCassandraBolt.prepare(Map stormConfig, 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	ClojureBolt.prepare(Map stormConf, 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 conf, TopologyContext context, BatchOutputCollector collector, T id)
void	CoordinatedBolt.prepare(Map config, TopologyContext context, OutputCollector collector)
void	BatchBoltExecutor.prepare(Map conf, TopologyContext context, OutputCollector collector)

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 conf, TopologyContext context, SpoutOutputCollector collector)
void	PrepareRequest.prepare(Map map, TopologyContext context)
void	ReturnResults.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	KeyedFairBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	JoinResult.prepare(Map map, TopologyContext context, OutputCollector collector)

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

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

Modifier and Type	Method and Description
void	DruidBeamBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector) Deprecated.

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 config, TopologyContext context, SpoutOutputCollector collector)
void	EsPercolateBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector)
void	EsIndexBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector)
void	AbstractEsBolt.prepare(Map 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 conf, TopologyContext context)

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 config, TopologyContext context, OutputCollector collector)

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

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

Modifier and Type	Method and Description
void	PartialCountBolt.prepare(Map stormConf, TopologyContext context)
void	GlobalCountBolt.prepare(Map config, TopologyContext context)

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 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
IOpaquePartitionedTridentSpout.Coordinator<Partitions>	OpaqueTridentEventHubSpout.getCoordinator(Map conf, TopologyContext context)
IPartitionedTridentSpout.Coordinator<Partitions>	TransactionalTridentEventHubSpout.getCoordinator(Map conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>	OpaqueTridentEventHubSpout.getEmitter(Map conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<Partitions,Partition,Map>	TransactionalTridentEventHubSpout.getEmitter(Map conf, TopologyContext context)

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	HBaseLookupBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
void	HBaseBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
void	AbstractHBaseBolt.prepare(Map map, 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 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	WordCounter.prepare(Map stormConf, TopologyContext context)
void	TotalWordCounter.prepare(Map stormConf, 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	SequenceFileBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
void	HdfsBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
protected void	AvroGenericRecordBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
protected abstract void	AbstractHdfsBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
void	SequenceFileTopology.SentenceSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	HdfsFileTopology.SentenceSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	SequenceFileTopology.MyBolt.prepare(Map config, TopologyContext context, OutputCollector collector)
void	HdfsFileTopology.MyBolt.prepare(Map config, TopologyContext context, OutputCollector collector)
void	AbstractHdfsBolt.prepare(Map 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	SimpleFileNameFormat.prepare(Map conf, TopologyContext topologyContext)
void	FileNameFormat.prepare(Map conf, TopologyContext topologyContext)
void	DefaultFileNameFormat.prepare(Map 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	HdfsSpoutTopology.ConstBolt.prepare(Map 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 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	BucketTestHiveTopology.UserDataSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	HiveTopologyPartitioned.UserDataSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	HiveTopology.UserDataSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	HiveBolt.prepare(Map 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 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 conf, TopologyContext context)
void	BaseTaskHook.prepare(Map conf, TopologyContext context)

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	JdbcInsertBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
void	AbstractJdbcBolt.prepare(Map 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.

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 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 stormConf, 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 stormConf, 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 conf, TopologyContext context, SpoutOutputCollector collector) 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 conf, TopologyContext context)
ITridentSpout.Emitter<JmsBatch>	TridentJmsSpout.getEmitter(String txStateId, Map conf, TopologyContext context)

Uses of TopologyContext in org.apache.storm.kafka

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

Modifier and Type	Method and Description
void	KafkaSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector) Deprecated.

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	KafkaBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector) Deprecated.

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 conf, TopologyContext context, SpoutOutputCollector collector)
List<org.apache.kafka.common.TopicPartition>	RoundRobinManualPartitioner.partition(List<org.apache.kafka.common.TopicPartition> allPartitions, TopologyContext context)
List<org.apache.kafka.common.TopicPartition>	ManualPartitioner.partition(List<org.apache.kafka.common.TopicPartition> allPartitions, TopologyContext context) Get the partitions for this assignment
abstract <K,V> void	Subscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener, TopologyContext context) Subscribe the KafkaConsumer to the proper topics.
<K,V> void	PatternSubscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener, TopologyContext unused) Deprecated.
<K,V> void	NamedSubscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener, TopologyContext unused) Deprecated.
<K,V> void	ManualPartitionSubscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener, TopologyContext context)

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.trident

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

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

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

Constructor and Description
KafkaTridentSpoutEmitter(KafkaTridentSpoutManager<K,V> kafkaManager, TopologyContext topologyContext) Creates instance of this class with default 500 millisecond refresh subscription timer
KafkaTridentSpoutEmitter(KafkaTridentSpoutManager<K,V> kafkaManager, TopologyContext topologyContext, Timer refreshSubscriptionTimer) Create a new Kafka spout emitter.

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

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

Modifier and Type	Method and Description
IPartitionedTridentSpout.Coordinator	TransactionalTridentKafkaSpout.getCoordinator(Map conf, TopologyContext context) Deprecated.
IOpaquePartitionedTridentSpout.Coordinator	OpaqueTridentKafkaSpout.getCoordinator(Map conf, TopologyContext tc) Deprecated.
IPartitionedTridentSpout.Emitter	TransactionalTridentKafkaSpout.getEmitter(Map conf, TopologyContext context) Deprecated.
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map>	OpaqueTridentKafkaSpout.getEmitter(Map conf, TopologyContext context) Deprecated.

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

Constructor and Description
TridentKafkaEmitter(Map conf, TopologyContext context, TridentKafkaConfig config, String topologyInstanceId)

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 conf, TopologyContext context, SpoutOutputCollector 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> stormConf, Map<String,Object> arguments, TopologyContext context)
void	LoggingMetricsConsumer.prepare(Map stormConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	HttpForwardingMetricsConsumer.prepare(Map stormConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	SystemBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	MetricsConsumerBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	EventLoggerBolt.prepare(Map stormConf, 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 stormConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)

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
static String	StormMetricRegistry.metricName(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 stormConf, TopologyContext context, OutputCollector collector)
void	AbstractMongoBolt.prepare(Map stormConf, 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	WordCounter.prepare(Map stormConf, 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 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 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	JsonSerializer.connect(Map conf, TopologyContext context)
Number	ISerializer.connect(Map conf, TopologyContext context) This method transmits the Storm config to the non-JVM process and receives its pid.

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 conf, TopologyContext context)
void	MetricGenSpout.open(Map 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 stormConf, 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 stormConf, TopologyContext context)
void	SplitSentenceBolt.prepare(Map stormConf, TopologyContext context)
void	IdBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	DevNullBolt.prepare(Map stormConf, 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	StringGenSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	ConstSpout.open(Map 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 stormConf, 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	PMMLPredictorBolt.prepare(Map stormConf, 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 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 stormConf, 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	WordCounter.prepare(Map stormConf, TopologyContext context)
void	WhitelistWordCount.PrintWordTotalCountBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	LookupWordCount.PrintWordTotalCountBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)

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 stormConf, 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	SolrJsonSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	SolrFieldsSpout.open(Map 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	ShellSpout.open(Map stormConf, TopologyContext context, SpoutOutputCollector collector)
void	ISpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.
void	CheckpointSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

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

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

Modifier and Type	Method and Description
void	TridentSocketSpout.open(Map conf, TopologyContext context)

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	ThroughputVsLatency.FastRandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	InOrderDeliveryTest.InOrderSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	FastWordCountTopology.FastRandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	BlobStoreAPIWordCountTopology.RandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	AnchoredWordCount.RandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TransactionalGlobalCount.BatchCount.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	ReachTopology.PartialUniquer.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	ReachTopology.CountAggregator.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	TransactionalWords.KeyedCountUpdater.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt id)
void	TransactionalWords.BucketCountUpdater.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt attempt)
void	TransactionalGlobalCount.UpdateGlobalCount.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt attempt)
void	ResourceAwareExampleTopology.ExclamationBolt.prepare(Map conf, TopologyContext context, OutputCollector collector)
void	MultipleLoggerTopology.ExclamationLoggingBolt.prepare(Map conf, TopologyContext context, OutputCollector collector)
void	ExclamationTopology.ExclamationBolt.prepare(Map 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	SlidingWindowSumBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	SingleJoinBolt.prepare(Map conf, TopologyContext context, OutputCollector collector)
void	RollingCountBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	RollingCountAggBolt.prepare(Map stormConf, 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 conf, TopologyContext context)
void	RandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	RandomIntegerSpout.open(Map 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 stormConf, 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 stormConf, TopologyContext context) Returns a new state instance.
State	InMemoryKeyValueStateProvider.newState(String namespace, Map stormConf, TopologyContext context)
void	IStateSpout.open(Map conf, TopologyContext context)

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 stormConf, TopologyContext context, OutputCollector collector)
void	IBolt.prepare(Map stormConf, 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
IOpaquePartitionedTransactionalSpout.Coordinator	OpaqueMemoryTransactionalSpout.getCoordinator(Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Coordinator	MemoryTransactionalSpout.getCoordinator(Map conf, TopologyContext context)
IOpaquePartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta>	OpaqueMemoryTransactionalSpout.getEmitter(Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta>	MemoryTransactionalSpout.getEmitter(Map conf, TopologyContext context)
void	TestWordSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TestPlannerSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TestEventLogSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	SpoutTracker.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	PythonShellMetricsSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	FixedTupleSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	FeederSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	ForwardingMetricsConsumer.prepare(Map stormConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	TestWordCounter.prepare(Map stormConf, TopologyContext context)
void	TestConfBolt.prepare(Map conf, TopologyContext context)
void	KeyedSummingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	KeyedCountingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	CountingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	BatchNumberList.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	CountingCommitBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt id)
void	TupleCaptureBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestPlannerBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestGlobalCount.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestEventOrderCheckBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestAggregatesCounter.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	PythonShellMetricsBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	NonRichBoltTracker.prepare(Map stormConf, 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	BaseStatefulBoltExecutor.init(TopologyContext context, OutputCollector collector)
void	IBasicBolt.prepare(Map stormConf, TopologyContext context)
void	WindowedBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	StatefulWindowedBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	StatefulBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	IWindowedBolt.prepare(Map stormConf, 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.
void	IStatefulBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	CheckpointTupleForwarder.prepare(Map stormConf, TopologyContext context, OutputCollector outputCollector)
void	BasicBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)

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 stormConf, TopologyContext context)
void	BaseWindowedBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	BaseStatefulBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.transactional

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

Modifier and Type	Method and Description
ITransactionalSpout.Coordinator<T>	ITransactionalSpout.getCoordinator(Map conf, TopologyContext context) The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit.
ITransactionalSpout.Emitter<T>	ITransactionalSpout.getEmitter(Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
ICommitterTransactionalSpout.Emitter	ICommitterTransactionalSpout.getEmitter(Map conf, TopologyContext context)
void	TransactionalSpoutCoordinator.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TransactionalSpoutBatchExecutor.prepare(Map conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in org.apache.storm.transactional.partitioned

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

Modifier and Type	Method and Description
ITransactionalSpout.Coordinator	PartitionedTransactionalSpoutExecutor.getCoordinator(Map conf, TopologyContext context)
ITransactionalSpout.Coordinator<Object>	OpaquePartitionedTransactionalSpoutExecutor.getCoordinator(Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Coordinator	IPartitionedTransactionalSpout.getCoordinator(Map conf, TopologyContext context)
IOpaquePartitionedTransactionalSpout.Coordinator	IOpaquePartitionedTransactionalSpout.getCoordinator(Map conf, TopologyContext context)
ITransactionalSpout.Emitter	PartitionedTransactionalSpoutExecutor.getEmitter(Map conf, TopologyContext context)
ICommitterTransactionalSpout.Emitter	OpaquePartitionedTransactionalSpoutExecutor.getEmitter(Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Emitter<T>	IPartitionedTransactionalSpout.getEmitter(Map conf, TopologyContext context)
IOpaquePartitionedTransactionalSpout.Emitter<T>	IOpaquePartitionedTransactionalSpout.getEmitter(Map conf, TopologyContext context)

Constructors in org.apache.storm.transactional.partitioned with parameters of type TopologyContext

Constructor and Description
Coordinator(Map conf, TopologyContext context)
Emitter(Map conf, TopologyContext context)

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 conf, TopologyContext context, BatchOutputCollector batchCollector)
void	TridentProcessor.prepare(Map 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	StateQueryProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	ProjectedProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	PartitionPersistProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	MultiReducerProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	MapProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	EachProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	AggregateProcessor.prepare(Map 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<Partitions>	IPartitionedTridentSpout.getCoordinator(Map conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Coordinator<Partitions>	IOpaquePartitionedTridentSpout.getCoordinator(Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator	RichSpoutBatchExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	PartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	OpaquePartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator<T>	ITridentSpout.getCoordinator(String txStateId, Map conf, TopologyContext context) The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted.
ITridentSpout.BatchCoordinator	BatchSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<Partitions,Partition,T>	IPartitionedTridentSpout.getEmitter(Map conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,M>	IOpaquePartitionedTridentSpout.getEmitter(Map conf, TopologyContext context)
ITridentSpout.Emitter	RichSpoutBatchExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter<Object>	PartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ICommitterTridentSpout.Emitter	OpaquePartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter<T>	ITridentSpout.getEmitter(String txStateId, Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
ICommitterTridentSpout.Emitter	ICommitterTridentSpout.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter	BatchSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
void	IBatchSpout.open(Map conf, TopologyContext context)
void	RichSpoutBatchTriggerer.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TridentSpoutCoordinator.prepare(Map conf, TopologyContext context)
void	TridentSpoutExecutor.prepare(Map conf, TopologyContext context, BatchOutputCollector collector)

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

Constructor and Description
Coordinator(Map conf, TopologyContext context)
Emitter(String txStateId, Map 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	FeederCommitterBatchSpout.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator	FeederBatchSpout.getCoordinator(String txStateId, Map conf, TopologyContext context)
ICommitterTridentSpout.Emitter	FeederCommitterBatchSpout.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter	FeederBatchSpout.getEmitter(String txStateId, Map conf, TopologyContext context)
void	FixedBatchSpout.open(Map 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 conf, TopologyContext context, SpoutOutputCollector collector)
void	ITridentBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector)
void	TridentBoltExecutor.prepare(Map 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 stormConf, 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 conf, TopologyContext context)
Number	ShellProcess.launch(Map conf, TopologyContext context, boolean changeDirectory)
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.
void	DefaultShellLogHandler.setUpContext(Class<?> ownerCls, ShellProcess process, TopologyContext context) This default implementation saves the ShellProcess so it can output the process info string later.