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

Packages that use WorkerTopologyContext

Package	Description
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.daemon

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

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

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

Modifier and Type	Method	Description
static LoadAwareCustomStreamGrouping	GrouperFactory.mkGrouper(WorkerTopologyContext context, String componentId, String streamId, Fields outFields, Grouping thriftGrouping, List<Integer> unsortedTargetTasks, Map<String,Object> topoConf)
void	GrouperFactory.AllGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
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)

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

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

Modifier and Type	Method	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	Description
protected WorkerTopologyContext	Executor.workerTopologyContext

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

Modifier and Type	Method	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	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	Description
void	CustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)	Tells the stream grouping at runtime the tasks in the target bolt.
void	LoadAwareShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	PartialKeyGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	ShuffleGrouping.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	Description
default void	IWorkerHook.start(Map<String,Object> topoConf, WorkerTopologyContext context)	Deprecated. see IWorkerHook.start(Map, WorkerUserContext)

Uses of WorkerTopologyContext in org.apache.storm.metrics2

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

Modifier and Type	Method	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	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	Description
class	TopologyContext	A `TopologyContext` is given to bolts and spouts in their `prepare()` and `open()` methods, respectively.
class	WorkerUserContext

Uses of WorkerTopologyContext in org.apache.storm.testing

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

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