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

Packages that use WorkerTopologyContext

Package	Description
org.apache.storm.cassandra
org.apache.storm.grouping
org.apache.storm.hooks
org.apache.storm.metrics2
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.trident.partition

Uses of WorkerTopologyContext in org.apache.storm.cassandra

Methods in org.apache.storm.cassandra with parameters of type WorkerTopologyContext

Modifier and Type	Method and Description
void	Murmur3StreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) Tells the stream grouping at runtime the tasks in the target bolt.

Uses of WorkerTopologyContext in org.apache.storm.grouping

Methods in org.apache.storm.grouping with parameters of type WorkerTopologyContext

Modifier and Type	Method and Description
void	ShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	PartialKeyGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	LoadAwareShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	CustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) Tells the stream grouping at runtime the tasks in the target bolt.

Uses of WorkerTopologyContext in org.apache.storm.hooks

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

Modifier and Type	Method and Description
void	IWorkerHook.start(Map stormConf, WorkerTopologyContext context) This method is called when a worker is started
void	BaseWorkerHook.start(Map stormConf, WorkerTopologyContext context) This method is called when a worker is started

Uses of WorkerTopologyContext in org.apache.storm.metrics2

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

Modifier and Type	Method and Description
static com.codahale.metrics.Counter	StormMetricRegistry.counter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)
static com.codahale.metrics.Meter	StormMetricRegistry.meter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)

Constructors in org.apache.storm.metrics2 with parameters of type WorkerTopologyContext

Constructor and Description
TaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid)

Uses of WorkerTopologyContext in org.apache.storm.task

Subclasses of WorkerTopologyContext in org.apache.storm.task

Modifier and Type	Class and Description
class	TopologyContext A TopologyContext is given to bolts and spouts in their prepare() and open() methods, respectively.

Uses of WorkerTopologyContext in org.apache.storm.testing

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

Modifier and Type	Method and Description
void	NGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)

Uses of WorkerTopologyContext in org.apache.storm.trident.partition

Methods in org.apache.storm.trident.partition with parameters of type WorkerTopologyContext

Modifier and Type	Method and Description
void	IndexHashGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	IdentityGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> tasks)
void	GlobalGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets)