backtype.storm.topology
Interface InputDeclarer<T extends InputDeclarer>
- All Known Subinterfaces:
- BoltDeclarer
- All Known Implementing Classes:
- TopologyBuilder.BoltGetter
public interface InputDeclarer<T extends InputDeclarer>
Method Summary |
T |
allGrouping(java.lang.String componentId)
|
T |
allGrouping(java.lang.String componentId,
java.lang.String streamId)
|
T |
customGrouping(java.lang.String componentId,
CustomStreamGrouping grouping)
|
T |
customGrouping(java.lang.String componentId,
java.lang.String streamId,
CustomStreamGrouping grouping)
|
T |
directGrouping(java.lang.String componentId)
|
T |
directGrouping(java.lang.String componentId,
java.lang.String streamId)
|
T |
fieldsGrouping(java.lang.String componentId,
Fields fields)
|
T |
fieldsGrouping(java.lang.String componentId,
java.lang.String streamId,
Fields fields)
|
T |
globalGrouping(java.lang.String componentId)
|
T |
globalGrouping(java.lang.String componentId,
java.lang.String streamId)
|
T |
grouping(GlobalStreamId id,
Grouping grouping)
|
T |
localOrShuffleGrouping(java.lang.String componentId)
|
T |
localOrShuffleGrouping(java.lang.String componentId,
java.lang.String streamId)
|
T |
noneGrouping(java.lang.String componentId)
|
T |
noneGrouping(java.lang.String componentId,
java.lang.String streamId)
|
T |
shuffleGrouping(java.lang.String componentId)
|
T |
shuffleGrouping(java.lang.String componentId,
java.lang.String streamId)
|
fieldsGrouping
T fieldsGrouping(java.lang.String componentId,
Fields fields)
fieldsGrouping
T fieldsGrouping(java.lang.String componentId,
java.lang.String streamId,
Fields fields)
globalGrouping
T globalGrouping(java.lang.String componentId)
globalGrouping
T globalGrouping(java.lang.String componentId,
java.lang.String streamId)
shuffleGrouping
T shuffleGrouping(java.lang.String componentId)
shuffleGrouping
T shuffleGrouping(java.lang.String componentId,
java.lang.String streamId)
localOrShuffleGrouping
T localOrShuffleGrouping(java.lang.String componentId)
localOrShuffleGrouping
T localOrShuffleGrouping(java.lang.String componentId,
java.lang.String streamId)
noneGrouping
T noneGrouping(java.lang.String componentId)
noneGrouping
T noneGrouping(java.lang.String componentId,
java.lang.String streamId)
allGrouping
T allGrouping(java.lang.String componentId)
allGrouping
T allGrouping(java.lang.String componentId,
java.lang.String streamId)
directGrouping
T directGrouping(java.lang.String componentId)
directGrouping
T directGrouping(java.lang.String componentId,
java.lang.String streamId)
customGrouping
T customGrouping(java.lang.String componentId,
CustomStreamGrouping grouping)
customGrouping
T customGrouping(java.lang.String componentId,
java.lang.String streamId,
CustomStreamGrouping grouping)
grouping
T grouping(GlobalStreamId id,
Grouping grouping)