org.apache.storm.topology

Class SpoutDeclarerImpl

java.lang.Object

org.apache.storm.topology.SpoutDeclarerImpl

All Implemented Interfaces:

ComponentConfigurationDeclarer<SpoutDeclarer>, SpoutDeclarer

public class SpoutDeclarerImpl
extends java.lang.Object
implements SpoutDeclarer

Constructor Summary

Constructors

Constructor and Description
SpoutDeclarerImpl(SpoutDeclarer delegate)

Method Summary

Modifier and Type	Method and Description
SpoutDeclarer	addConfiguration(java.lang.String config, java.lang.Object value)
SpoutDeclarer	addConfigurations(java.util.Map<java.lang.String,java.lang.Object> conf)
SpoutDeclarer	setDebug(boolean debug)
SpoutDeclarer	setMaxSpoutPending(java.lang.Number val)
SpoutDeclarer	setMaxTaskParallelism(java.lang.Number val)
SpoutDeclarer	setNumTasks(java.lang.Number val)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpoutDeclarerImpl

public SpoutDeclarerImpl(SpoutDeclarer delegate)

Method Detail

addConfigurations

public SpoutDeclarer addConfigurations(java.util.Map<java.lang.String,java.lang.Object> 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 val)

Specified by:

setMaxTaskParallelism in interface ComponentConfigurationDeclarer<SpoutDeclarer>

setMaxSpoutPending

public SpoutDeclarer setMaxSpoutPending(java.lang.Number val)

Specified by:

setMaxSpoutPending in interface ComponentConfigurationDeclarer<SpoutDeclarer>

setNumTasks

public SpoutDeclarer setNumTasks(java.lang.Number val)

Specified by:

setNumTasks in interface ComponentConfigurationDeclarer<SpoutDeclarer>