org.apache.storm.task

Class WorkerTopologyContext

java.lang.Object

org.apache.storm.task.GeneralTopologyContext

org.apache.storm.task.WorkerTopologyContext

All Implemented Interfaces:

org.json.simple.JSONAware

Direct Known Subclasses:

TopologyContext

public class WorkerTopologyContext
extends GeneralTopologyContext

Constructor Summary

Constructors

Constructor and Description
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)
WorkerTopologyContext(TopologyContext newDelegate)

Method Summary

Modifier and Type	Method and Description
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() Return the port that the worker is running on.
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 org.apache.storm.task.GeneralTopologyContext

getComponentId, getComponentIds, getComponentOutputFields, getComponentStreams, getComponentTasks, getStormId, getTaskToComponent, toJSONString

Methods inherited from class java.lang.Object

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

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)

WorkerTopologyContext

public WorkerTopologyContext(TopologyContext newDelegate)

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). In Heron parlance, since every instance is running as a seperate process this will just return the current instance's taskId

getThisWorkerPort

public java.lang.Integer getThisWorkerPort()

Return the port that the worker is running on. This was typically done to differentiate workers running on the same machine. In Heron parlance, we just return the taskId since that should be unique

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()