backtype.storm.topology
Class TopologyBuilder.BoltGetter
java.lang.Object
backtype.storm.topology.BaseConfigurationDeclarer<T>
backtype.storm.topology.TopologyBuilder.ConfigGetter<BoltDeclarer>
backtype.storm.topology.TopologyBuilder.BoltGetter
- All Implemented Interfaces:
- BoltDeclarer, ComponentConfigurationDeclarer<BoltDeclarer>, InputDeclarer<BoltDeclarer>
- Enclosing class:
- TopologyBuilder
protected class TopologyBuilder.BoltGetter
- extends TopologyBuilder.ConfigGetter<BoltDeclarer>
- implements BoltDeclarer
Method Summary |
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)
|
BoltDeclarer |
globalGrouping(java.lang.String componentId)
|
BoltDeclarer |
globalGrouping(java.lang.String componentId,
java.lang.String streamId)
|
BoltDeclarer |
grouping(GlobalStreamId id,
Grouping grouping)
|
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 |
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 |
TopologyBuilder.BoltGetter
public TopologyBuilder.BoltGetter(java.lang.String boltId)
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>
grouping
public BoltDeclarer grouping(GlobalStreamId id,
Grouping grouping)
- Specified by:
grouping
in interface InputDeclarer<BoltDeclarer>