Uses of Class
org.apache.storm.task.WorkerTopologyContext
Package
Description
-
Uses of WorkerTopologyContext in org.apache.storm.daemon
Modifier and TypeMethodDescriptionstatic WorkerTopologyContext
StormCommon.makeWorkerContext
(Map<String, Object> workerData) Modifier and TypeMethodDescriptionGrouperFactory.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
Modifier and TypeMethodDescriptionfinal WorkerTopologyContext
WorkerState.getWorkerTopologyContext()
-
Uses of WorkerTopologyContext in org.apache.storm.executor
Modifier and TypeFieldDescriptionprotected final WorkerTopologyContext
Executor.workerTopologyContext
-
Uses of WorkerTopologyContext in org.apache.storm.executor.error
ModifierConstructorDescriptionReportError
(Map<String, Object> topoConf, IStormClusterState stormClusterState, String stormId, String componentId, WorkerTopologyContext workerTopologyContext) -
Uses of WorkerTopologyContext in org.apache.storm.grouping
Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptiondefault void
IWorkerHook.start
(Map<String, Object> topoConf, WorkerTopologyContext context) Deprecated. -
Uses of WorkerTopologyContext in org.apache.storm.metrics2
Modifier and TypeMethodDescriptioncom.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) ModifierConstructorDescriptionTaskMetrics
(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String, Object> topoConf) -
Uses of WorkerTopologyContext in org.apache.storm.task
Modifier and TypeClassDescriptionclass
A `TopologyContext` is given to bolts and spouts in their `prepare()` and `open()` methods, respectively.class
-
Uses of WorkerTopologyContext in org.apache.storm.testing
Modifier and TypeMethodDescriptionvoid
NGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) -
Uses of WorkerTopologyContext in org.apache.storm.trident.partition
Modifier and TypeMethodDescriptionvoid
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)
IWorkerHook.start(Map, WorkerUserContext)