Uses of Class
org.apache.storm.task.WorkerTopologyContext
Packages that use WorkerTopologyContext
Package
Description
-
Uses of WorkerTopologyContext in org.apache.storm.daemon
Methods in org.apache.storm.daemon that return WorkerTopologyContextModifier and TypeMethodDescriptionstatic WorkerTopologyContextStormCommon.makeWorkerContext(Map<String, Object> workerData) Methods in org.apache.storm.daemon with parameters of type WorkerTopologyContextModifier and TypeMethodDescriptionGrouperFactory.mkGrouper(WorkerTopologyContext context, String componentId, String streamId, Fields outFields, Grouping thriftGrouping, List<Integer> unsortedTargetTasks, Map<String, Object> topoConf) voidGrouperFactory.AllGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.BasicLoadAwareCustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.FieldsGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.GlobalGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.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 WorkerTopologyContextModifier and TypeMethodDescriptionfinal WorkerTopologyContextWorkerState.getWorkerTopologyContext() -
Uses of WorkerTopologyContext in org.apache.storm.executor
Fields in org.apache.storm.executor declared as WorkerTopologyContextModifier and TypeFieldDescriptionprotected final WorkerTopologyContextExecutor.workerTopologyContextMethods in org.apache.storm.executor that return WorkerTopologyContext -
Uses of WorkerTopologyContext in org.apache.storm.executor.error
Constructors in org.apache.storm.executor.error with parameters of type WorkerTopologyContextModifierConstructorDescriptionReportError(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 WorkerTopologyContextModifier and TypeMethodDescriptionvoidCustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) Tells the stream grouping at runtime the tasks in the target bolt.voidLoadAwareShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidPartialKeyGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidShuffleGrouping.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 WorkerTopologyContextModifier and TypeMethodDescriptiondefault voidIWorkerHook.start(Map<String, Object> topoConf, WorkerTopologyContext context) Deprecated. -
Uses of WorkerTopologyContext in org.apache.storm.metrics2
Methods in org.apache.storm.metrics2 with parameters of type WorkerTopologyContextModifier and TypeMethodDescriptioncom.codahale.metrics.CounterStormMetricRegistry.counter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId) com.codahale.metrics.MeterStormMetricRegistry.meter(String name, WorkerTopologyContext context, String componentId, Integer taskId) com.codahale.metrics.MeterStormMetricRegistry.meter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId) Constructors in org.apache.storm.metrics2 with parameters of type WorkerTopologyContextModifierConstructorDescriptionTaskMetrics(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.taskModifier and TypeClassDescriptionclassA `TopologyContext` is given to bolts and spouts in their `prepare()` and `open()` methods, respectively.class -
Uses of WorkerTopologyContext in org.apache.storm.testing
Methods in org.apache.storm.testing with parameters of type WorkerTopologyContextModifier and TypeMethodDescriptionvoidNGrouping.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 WorkerTopologyContextModifier and TypeMethodDescriptionvoidGlobalGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets) voidIdentityGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> tasks) voidIndexHashGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
IWorkerHook.start(Map, WorkerUserContext)