org.apache.storm.task

Class SpoutTopologyContext

java.lang.Object

org.apache.storm.task.GeneralTopologyContext

org.apache.storm.task.WorkerTopologyContext

org.apache.storm.task.TopologyContext

org.apache.storm.task.SpoutTopologyContext

All Implemented Interfaces:

IMetricsContext, org.json.simple.JSONAware

public class SpoutTopologyContext
extends TopologyContext

A TopologyContext that is given to a spout is actually an instance of SpoutTopologyContext. Currently spouts can store spout specific information in this structure.

Constructor Summary

Constructors

Constructor and Description
SpoutTopologyContext(TopologyContext delegate)

Method Summary

Modifier and Type	Method and Description
java.lang.Long	getMaxSpoutPending() Gets the Maximum Spout Pending value for this instance of spout.
void	setMaxSpoutPending(java.lang.Long maxSpoutPending) Sets the Maximum Spout Pending value for this instance of spout

Methods inherited from class org.apache.storm.task.TopologyContext

addTaskHook, getHooks, getTaskData, getThisComponentId, getThisOutputFields, getThisStreams, getThisTaskId, getThisTaskIndex, registerMetric, registerMetric, registerMetric, setTaskData

Methods inherited from class org.apache.storm.task.WorkerTopologyContext

getCodeDir, getPIDDir, getResource, getSharedExecutor, getThisWorkerPort, getThisWorkerTasks

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

SpoutTopologyContext

public SpoutTopologyContext(TopologyContext delegate)

Method Detail

getMaxSpoutPending

public java.lang.Long getMaxSpoutPending()

Gets the Maximum Spout Pending value for this instance of spout.

setMaxSpoutPending

public void setMaxSpoutPending(java.lang.Long maxSpoutPending)

Sets the Maximum Spout Pending value for this instance of spout