Uses of Class
backtype.storm.task.TopologyContext

Packages that use TopologyContext

Package	Description
backtype.storm.clojure
backtype.storm.coordination
backtype.storm.drpc
backtype.storm.hooks
backtype.storm.metric
backtype.storm.metric.api
backtype.storm.multilang
backtype.storm.spout
backtype.storm.state
backtype.storm.task
backtype.storm.testing
backtype.storm.topology
backtype.storm.topology.base
backtype.storm.transactional
backtype.storm.transactional.partitioned
backtype.storm.utils
storm.trident.operation
storm.trident.planner
storm.trident.planner.processor
storm.trident.spout
storm.trident.testing
storm.trident.topology

Uses of TopologyContext in backtype.storm.clojure

Methods in backtype.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 backtype.storm.coordination

Methods in backtype.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	BatchBoltExecutor.prepare(Map conf, TopologyContext context, OutputCollector collector)
void	CoordinatedBolt.prepare(Map config, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in backtype.storm.drpc

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

Uses of TopologyContext in backtype.storm.hooks

Methods in backtype.storm.hooks with parameters of type TopologyContext

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

Uses of TopologyContext in backtype.storm.metric

Methods in backtype.storm.metric with parameters of type TopologyContext

Modifier and Type	Method and Description
void	LoggingMetricsConsumer.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)

Uses of TopologyContext in backtype.storm.metric.api

Methods in backtype.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 backtype.storm.multilang

Methods in backtype.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 backtype.storm.spout

Methods in backtype.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.

Uses of TopologyContext in backtype.storm.state

Methods in backtype.storm.state with parameters of type TopologyContext

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

Uses of TopologyContext in backtype.storm.task

Methods in backtype.storm.task with parameters of type TopologyContext

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

Uses of TopologyContext in backtype.storm.testing

Methods in backtype.storm.testing with parameters of type TopologyContext

Modifier and Type	Method and Description
IPartitionedTransactionalSpout.Coordinator	MemoryTransactionalSpout.getCoordinator(Map conf, TopologyContext context)
IOpaquePartitionedTransactionalSpout.Coordinator	OpaqueMemoryTransactionalSpout.getCoordinator(Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta>	MemoryTransactionalSpout.getEmitter(Map conf, TopologyContext context)
IOpaquePartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta>	OpaqueMemoryTransactionalSpout.getEmitter(Map conf, TopologyContext context)
void	TestPlannerSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	SpoutTracker.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TestEventLogSpout.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	PythonShellMetricsSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TestWordSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	ForwardingMetricsConsumer.prepare(Map stormConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void	TestConfBolt.prepare(Map conf, TopologyContext context)
void	TestWordCounter.prepare(Map stormConf, TopologyContext context)
void	KeyedCountingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	CountingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	KeyedSummingBatchBolt.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	NonRichBoltTracker.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestGlobalCount.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TupleCaptureBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	PythonShellMetricsBolt.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	TestPlannerBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in backtype.storm.topology

Methods in backtype.storm.topology with parameters of type TopologyContext

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

Uses of TopologyContext in backtype.storm.topology.base

Methods in backtype.storm.topology.base with parameters of type TopologyContext

Modifier and Type	Method and Description
void	BaseBasicBolt.prepare(Map stormConf, TopologyContext context)

Uses of TopologyContext in backtype.storm.transactional

Methods in backtype.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.
ICommitterTransactionalSpout.Emitter	ICommitterTransactionalSpout.getEmitter(Map conf, TopologyContext context)
ITransactionalSpout.Emitter<T>	ITransactionalSpout.getEmitter(Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
void	TransactionalSpoutCoordinator.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TransactionalSpoutBatchExecutor.prepare(Map conf, TopologyContext context, OutputCollector collector)

Uses of TopologyContext in backtype.storm.transactional.partitioned

Methods in backtype.storm.transactional.partitioned with parameters of type TopologyContext

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

Constructors in backtype.storm.transactional.partitioned with parameters of type TopologyContext

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

Uses of TopologyContext in backtype.storm.utils

Methods in backtype.storm.utils with parameters of type TopologyContext

Modifier and Type	Method and Description
Number	ShellProcess.launch(Map conf, TopologyContext context)

Uses of TopologyContext in storm.trident.operation

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

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

Uses of TopologyContext in storm.trident.planner

Methods in 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 storm.trident.planner.processor

Methods in 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	PartitionPersistProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	MultiReducerProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	ProjectedProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	AggregateProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)
void	EachProcessor.prepare(Map conf, TopologyContext context, TridentContext tridentContext)

Uses of TopologyContext in storm.trident.spout

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

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Coordinator	IOpaquePartitionedTridentSpout.getCoordinator(Map conf, TopologyContext context)
IPartitionedTridentSpout.Coordinator<Partitions>	IPartitionedTridentSpout.getCoordinator(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 and when transactions should commit.
ITridentSpout.BatchCoordinator	PartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator	BatchSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	OpaquePartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator	RichSpoutBatchExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,M>	IOpaquePartitionedTridentSpout.getEmitter(Map conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<Partitions,Partition,T>	IPartitionedTridentSpout.getEmitter(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.
ITridentSpout.Emitter	PartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter	BatchSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ICommitterTridentSpout.Emitter	OpaquePartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter	RichSpoutBatchExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ICommitterTridentSpout.Emitter	ICommitterTridentSpout.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 storm.trident.spout with parameters of type TopologyContext

Constructor and Description
OpaquePartitionedTridentSpoutExecutor.Coordinator(Map conf, TopologyContext context)
OpaquePartitionedTridentSpoutExecutor.Emitter(String txStateId, Map conf, TopologyContext context)

Uses of TopologyContext in storm.trident.testing

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

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

Uses of TopologyContext in storm.trident.topology

Methods in 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)