backtype.storm.task
Class WorkerTopologyContext

java.lang.Object
  backtype.storm.task.GeneralTopologyContext
      backtype.storm.task.WorkerTopologyContext

Direct Known Subclasses:

TopologyContext

public class WorkerTopologyContext
extends GeneralTopologyContext

Field Summary

static java.lang.String

SHARED_EXECUTOR

Fields inherited from class backtype.storm.task.GeneralTopologyContext

_stormConf

Constructor Summary

WorkerTopologyContext(StormTopology topology, java.util.Map stormConf, java.util.Map<java.lang.Integer,java.lang.String> taskToComponent, java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> componentToSortedTasks, java.util.Map<java.lang.String,java.util.Map<java.lang.String,Fields>> componentToStreamToFields, java.lang.String stormId, java.lang.String codeDir, java.lang.String pidDir, java.lang.Integer workerPort, java.util.List<java.lang.Integer> workerTasks, java.util.Map<java.lang.String,java.lang.Object> defaultResources, java.util.Map<java.lang.String,java.lang.Object> userResources)

Method Summary

java.lang.String	getCodeDir() Gets the location of the external resources for this worker on the local filesystem.
java.lang.String	getPIDDir() If this task spawns any subprocesses, those subprocesses must immediately write their PID to this directory on the local filesystem to ensure that Storm properly destroys that process when the worker is shutdown.
java.lang.Object	getResource(java.lang.String name)
java.util.concurrent.ExecutorService	getSharedExecutor()
java.lang.Integer	getThisWorkerPort()
java.util.List<java.lang.Integer>	getThisWorkerTasks() Gets all the task ids that are running in this worker process (including the task for this task).

Methods inherited from class backtype.storm.task.GeneralTopologyContext

getComponentCommon, getComponentId, getComponentIds, getComponentOutputFields, getComponentOutputFields, getComponentStreams, getComponentTasks, getRawTopology, getSources, getStormId, getTargets, getTaskToComponent, maxTopologyMessageTimeout, toJSONString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SHARED_EXECUTOR

public static final java.lang.String SHARED_EXECUTOR

See Also:

Constant Field Values

Constructor Detail

WorkerTopologyContext

public WorkerTopologyContext(StormTopology topology,
                             java.util.Map stormConf,
                             java.util.Map<java.lang.Integer,java.lang.String> taskToComponent,
                             java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> componentToSortedTasks,
                             java.util.Map<java.lang.String,java.util.Map<java.lang.String,Fields>> componentToStreamToFields,
                             java.lang.String stormId,
                             java.lang.String codeDir,
                             java.lang.String pidDir,
                             java.lang.Integer workerPort,
                             java.util.List<java.lang.Integer> workerTasks,
                             java.util.Map<java.lang.String,java.lang.Object> defaultResources,
                             java.util.Map<java.lang.String,java.lang.Object> userResources)

Method Detail

getThisWorkerTasks

public java.util.List<java.lang.Integer> getThisWorkerTasks()

Gets all the task ids that are running in this worker process (including the task for this task).

getThisWorkerPort

public java.lang.Integer getThisWorkerPort()

getCodeDir

public java.lang.String getCodeDir()

Gets the location of the external resources for this worker on the local filesystem. These external resources typically include bolts implemented in other languages, such as Ruby or Python.

getPIDDir

public java.lang.String getPIDDir()

If this task spawns any subprocesses, those subprocesses must immediately write their PID to this directory on the local filesystem to ensure that Storm properly destroys that process when the worker is shutdown.

getResource

public java.lang.Object getResource(java.lang.String name)

getSharedExecutor

public java.util.concurrent.ExecutorService getSharedExecutor()