org.apache.storm.topology.twister2

Class Twister2BoltDeclarer

java.lang.Object

org.apache.storm.topology.twister2.Twister2BoltDeclarer

All Implemented Interfaces:

java.io.Serializable, BoltDeclarer, ComponentConfigurationDeclarer<BoltDeclarer>, InputDeclarer<BoltDeclarer>

public class Twister2BoltDeclarer
extends java.lang.Object
implements BoltDeclarer, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Twister2BoltDeclarer(MadeASourceListener madeASourceListener)

Method Summary

Modifier and Type	Method and Description
BoltDeclarer	addConfiguration(java.lang.String config, java.lang.Object value)
BoltDeclarer	addConfigurations(java.util.Map conf)
BoltDeclarer	allGrouping(java.lang.String componentId)
BoltDeclarer	allGrouping(java.lang.String componentId, java.lang.String streamId)
BoltDeclarer	customGrouping(java.lang.String componentId, CustomStreamGrouping grouping)
BoltDeclarer	customGrouping(java.lang.String componentId, java.lang.String streamId, CustomStreamGrouping grouping)
BoltDeclarer	directGrouping(java.lang.String componentId)
BoltDeclarer	directGrouping(java.lang.String componentId, java.lang.String streamId)
BoltDeclarer	fieldsGrouping(java.lang.String componentId, Fields fields)
BoltDeclarer	fieldsGrouping(java.lang.String componentId, java.lang.String streamId, Fields fields)
java.util.HashMap<java.lang.String,java.lang.Object>	getConfiguration()
java.util.List<Twister2BoltGrouping>	getGroupings()
java.lang.Number	getMaxSpoutPending()
java.lang.Number	getMaxTaskParallelism()
java.lang.Number	getNumTasks()
BoltDeclarer	globalGrouping(java.lang.String componentId)
BoltDeclarer	globalGrouping(java.lang.String componentId, java.lang.String streamId)
boolean	isDebug()
BoltDeclarer	localOrShuffleGrouping(java.lang.String componentId)
BoltDeclarer	localOrShuffleGrouping(java.lang.String componentId, java.lang.String streamId)
BoltDeclarer	noneGrouping(java.lang.String componentId)
BoltDeclarer	noneGrouping(java.lang.String componentId, java.lang.String streamId)
BoltDeclarer	setDebug(boolean debug)
BoltDeclarer	setMaxSpoutPending(java.lang.Number val)
BoltDeclarer	setMaxTaskParallelism(java.lang.Number val)
BoltDeclarer	setNumTasks(java.lang.Number val)
BoltDeclarer	shuffleGrouping(java.lang.String componentId)
BoltDeclarer	shuffleGrouping(java.lang.String componentId, java.lang.String streamId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Twister2BoltDeclarer

public Twister2BoltDeclarer(MadeASourceListener madeASourceListener)

Method Detail

addConfigurations

public BoltDeclarer addConfigurations(java.util.Map conf)

Specified by:

addConfigurations in interface ComponentConfigurationDeclarer<BoltDeclarer>

addConfiguration

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

Specified by:

addConfiguration in interface ComponentConfigurationDeclarer<BoltDeclarer>

setDebug

public BoltDeclarer setDebug(boolean debug)

Specified by:

setDebug in interface ComponentConfigurationDeclarer<BoltDeclarer>

setMaxTaskParallelism

public BoltDeclarer setMaxTaskParallelism(java.lang.Number val)

Specified by:

setMaxTaskParallelism in interface ComponentConfigurationDeclarer<BoltDeclarer>

setMaxSpoutPending

public BoltDeclarer setMaxSpoutPending(java.lang.Number val)

Specified by:

setMaxSpoutPending in interface ComponentConfigurationDeclarer<BoltDeclarer>

setNumTasks

public BoltDeclarer setNumTasks(java.lang.Number val)

Specified by:

setNumTasks in interface ComponentConfigurationDeclarer<BoltDeclarer>

fieldsGrouping

public BoltDeclarer fieldsGrouping(java.lang.String componentId,
                                   Fields fields)

Specified by:

fieldsGrouping in interface InputDeclarer<BoltDeclarer>

fieldsGrouping

public BoltDeclarer fieldsGrouping(java.lang.String componentId,
                                   java.lang.String streamId,
                                   Fields fields)

Specified by:

fieldsGrouping in interface InputDeclarer<BoltDeclarer>

globalGrouping

public BoltDeclarer globalGrouping(java.lang.String componentId)

Specified by:

globalGrouping in interface InputDeclarer<BoltDeclarer>

globalGrouping

public BoltDeclarer globalGrouping(java.lang.String componentId,
                                   java.lang.String streamId)

Specified by:

globalGrouping in interface InputDeclarer<BoltDeclarer>

shuffleGrouping

public BoltDeclarer shuffleGrouping(java.lang.String componentId)

Specified by:

shuffleGrouping in interface InputDeclarer<BoltDeclarer>

shuffleGrouping

public BoltDeclarer shuffleGrouping(java.lang.String componentId,
                                    java.lang.String streamId)

Specified by:

shuffleGrouping in interface InputDeclarer<BoltDeclarer>

localOrShuffleGrouping

public BoltDeclarer localOrShuffleGrouping(java.lang.String componentId)

Specified by:

localOrShuffleGrouping in interface InputDeclarer<BoltDeclarer>

localOrShuffleGrouping

public BoltDeclarer localOrShuffleGrouping(java.lang.String componentId,
                                           java.lang.String streamId)

Specified by:

localOrShuffleGrouping in interface InputDeclarer<BoltDeclarer>

noneGrouping

public BoltDeclarer noneGrouping(java.lang.String componentId)

Specified by:

noneGrouping in interface InputDeclarer<BoltDeclarer>

noneGrouping

public BoltDeclarer noneGrouping(java.lang.String componentId,
                                 java.lang.String streamId)

Specified by:

noneGrouping in interface InputDeclarer<BoltDeclarer>

allGrouping

public BoltDeclarer allGrouping(java.lang.String componentId)

Specified by:

allGrouping in interface InputDeclarer<BoltDeclarer>

allGrouping

public BoltDeclarer allGrouping(java.lang.String componentId,
                                java.lang.String streamId)

Specified by:

allGrouping in interface InputDeclarer<BoltDeclarer>

directGrouping

public BoltDeclarer directGrouping(java.lang.String componentId)

Specified by:

directGrouping in interface InputDeclarer<BoltDeclarer>

directGrouping

public BoltDeclarer directGrouping(java.lang.String componentId,
                                   java.lang.String streamId)

Specified by:

directGrouping in interface InputDeclarer<BoltDeclarer>

customGrouping

public BoltDeclarer customGrouping(java.lang.String componentId,
                                   CustomStreamGrouping grouping)

Specified by:

customGrouping in interface InputDeclarer<BoltDeclarer>

customGrouping

public BoltDeclarer customGrouping(java.lang.String componentId,
                                   java.lang.String streamId,
                                   CustomStreamGrouping grouping)

Specified by:

customGrouping in interface InputDeclarer<BoltDeclarer>

getConfiguration

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

isDebug

public boolean isDebug()

getMaxTaskParallelism

public java.lang.Number getMaxTaskParallelism()

getMaxSpoutPending

public java.lang.Number getMaxSpoutPending()

getNumTasks

public java.lang.Number getNumTasks()

getGroupings

public java.util.List<Twister2BoltGrouping> getGroupings()