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

Packages that use WorkerTopologyContext

Package	Description
org.apache.storm.cassandra
org.apache.storm.daemon
org.apache.storm.daemon.worker
org.apache.storm.executor
org.apache.storm.executor.error
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.daemon

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

Modifier and Type	Method and Description
static WorkerTopologyContext	StormCommon.makeWorkerContext(Map<String,Object> workerData)

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

Modifier and Type	Method and Description
static LoadAwareCustomStreamGrouping	GrouperFactory.mkGrouper(WorkerTopologyContext context, String componentId, String streamId, Fields outFields, Grouping thriftGrouping, List<Integer> unsortedTargetTasks, Map<String,Object> topoConf)
void	GrouperFactory.BasicLoadAwareCustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	GrouperFactory.FieldsGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	GrouperFactory.GlobalGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	GrouperFactory.NoneGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	GrouperFactory.AllGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)

Uses of WorkerTopologyContext in org.apache.storm.daemon.worker

Methods in org.apache.storm.daemon.worker that return WorkerTopologyContext

Modifier and Type	Method and Description
WorkerTopologyContext	WorkerState.getWorkerTopologyContext()

Uses of WorkerTopologyContext in org.apache.storm.executor

Fields in org.apache.storm.executor declared as WorkerTopologyContext

Modifier and Type	Field and Description
protected WorkerTopologyContext	Executor.workerTopologyContext

Methods in org.apache.storm.executor that return WorkerTopologyContext

Modifier and Type	Method and Description
WorkerTopologyContext	Executor.getWorkerTopologyContext()

Uses of WorkerTopologyContext in org.apache.storm.executor.error

Constructors in org.apache.storm.executor.error with parameters of type WorkerTopologyContext

Constructor and Description
ReportError(Map<String,Object> topoConf, IStormClusterState stormClusterState, String stormId, String componentId, WorkerTopologyContext workerTopologyContext)

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	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.
void	PartialKeyGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)

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	BaseWorkerHook.start(Map<String,Object> topoConf, WorkerTopologyContext context) This method is called when a worker is started.
void	IWorkerHook.start(Map<String,Object> topoConf, 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
com.codahale.metrics.Counter	StormMetricRegistry.counter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)
com.codahale.metrics.Meter	StormMetricRegistry.meter(String name, WorkerTopologyContext context, String componentId, Integer taskId)
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, StormMetricRegistry metricRegistry, Map<String,Object> topoConf)

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	GlobalGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets)
void	IndexHashGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	IdentityGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> tasks)