org.apache.storm.topology.twister2

Class Twister2SpoutDeclarer

java.lang.Object

org.apache.storm.topology.twister2.Twister2SpoutDeclarer

All Implemented Interfaces:

java.io.Serializable, ComponentConfigurationDeclarer<SpoutDeclarer>, SpoutDeclarer

public class Twister2SpoutDeclarer
extends java.lang.Object
implements SpoutDeclarer, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Twister2SpoutDeclarer()

Method Summary

Modifier and Type	Method and Description
SpoutDeclarer	addConfiguration(java.lang.String config, java.lang.Object value)
SpoutDeclarer	addConfigurations(java.util.Map conf)
java.util.HashMap<java.lang.String,java.lang.Object>	getConfiguration()
java.lang.Number	getMaxSpoutPending()
java.lang.Number	getMaxTaskParallelism()
java.lang.Number	getNumTasks()
boolean	isDebug()
SpoutDeclarer	setDebug(boolean debug)
SpoutDeclarer	setMaxSpoutPending(java.lang.Number maxSpoutPending)
SpoutDeclarer	setMaxTaskParallelism(java.lang.Number maxTaskParallelism)
SpoutDeclarer	setNumTasks(java.lang.Number numTasks)

Methods inherited from class java.lang.Object

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

Constructor Detail

Twister2SpoutDeclarer

public Twister2SpoutDeclarer()

Method Detail

addConfigurations

public SpoutDeclarer addConfigurations(java.util.Map conf)

Specified by:

addConfigurations in interface ComponentConfigurationDeclarer<SpoutDeclarer>

addConfiguration

public SpoutDeclarer addConfiguration(java.lang.String config,
                                      java.lang.Object value)

Specified by:

addConfiguration in interface ComponentConfigurationDeclarer<SpoutDeclarer>

setDebug

public SpoutDeclarer setDebug(boolean debug)

Specified by:

setDebug in interface ComponentConfigurationDeclarer<SpoutDeclarer>

setMaxTaskParallelism

public SpoutDeclarer setMaxTaskParallelism(java.lang.Number maxTaskParallelism)

Specified by:

setMaxTaskParallelism in interface ComponentConfigurationDeclarer<SpoutDeclarer>

setMaxSpoutPending

public SpoutDeclarer setMaxSpoutPending(java.lang.Number maxSpoutPending)

Specified by:

setMaxSpoutPending in interface ComponentConfigurationDeclarer<SpoutDeclarer>

setNumTasks

public SpoutDeclarer setNumTasks(java.lang.Number numTasks)

Specified by:

setNumTasks in interface ComponentConfigurationDeclarer<SpoutDeclarer>

getMaxTaskParallelism

public java.lang.Number getMaxTaskParallelism()

getMaxSpoutPending

public java.lang.Number getMaxSpoutPending()

getNumTasks

public java.lang.Number getNumTasks()

isDebug

public boolean isDebug()

getConfiguration

public java.util.HashMap<java.lang.String,java.lang.Object> getConfiguration()