backtype.storm.task

Class SpoutTopologyContext

java.lang.Object

backtype.storm.task.GeneralTopologyContext

backtype.storm.task.WorkerTopologyContext

backtype.storm.task.TopologyContext

backtype.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 backtype.storm.task.TopologyContext

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

Methods inherited from class backtype.storm.task.WorkerTopologyContext

getCodeDir, getPIDDir, getResource, getSharedExecutor, getThisWorkerPort, getThisWorkerTasks

Methods inherited from class backtype.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