public class BoltDeclarer extends BaseComponentDeclarer<BoltDeclarer>
Constructor and Description |
---|
BoltDeclarer(java.lang.String name,
IRichBolt bolt,
java.lang.Number taskParallelism) |
Modifier and Type | Method and Description |
---|---|
BoltDeclarer |
allGrouping(java.lang.String componentName) |
BoltDeclarer |
allGrouping(java.lang.String componentName,
java.lang.String streamId) |
BoltDeclarer |
customGrouping(java.lang.String componentName,
CustomStreamGrouping grouping) |
BoltDeclarer |
customGrouping(java.lang.String componentName,
java.lang.String streamId,
CustomStreamGrouping grouping) |
BoltDeclarer |
directGrouping(java.lang.String componentName) |
BoltDeclarer |
directGrouping(java.lang.String componentName,
java.lang.String streamId) |
void |
dump(TopologyAPI.Topology.Builder bldr) |
BoltDeclarer |
fieldsGrouping(java.lang.String componentName,
Fields fields) |
BoltDeclarer |
fieldsGrouping(java.lang.String componentName,
java.lang.String streamId,
Fields fields) |
BoltDeclarer |
globalGrouping(java.lang.String componentName) |
BoltDeclarer |
globalGrouping(java.lang.String componentName,
java.lang.String streamId) |
BoltDeclarer |
localOrShuffleGrouping(java.lang.String componentName) |
BoltDeclarer |
localOrShuffleGrouping(java.lang.String componentName,
java.lang.String streamId) |
BoltDeclarer |
noneGrouping(java.lang.String componentName) |
BoltDeclarer |
noneGrouping(java.lang.String componentName,
java.lang.String streamId) |
BoltDeclarer |
returnThis() |
BoltDeclarer |
shuffleGrouping(java.lang.String componentName) |
BoltDeclarer |
shuffleGrouping(java.lang.String componentName,
java.lang.String streamId) |
addConfigurations, dump, getName
addConfiguration, setDebug, setMaxSpoutPending
public BoltDeclarer(java.lang.String name, IRichBolt bolt, java.lang.Number taskParallelism)
public BoltDeclarer returnThis()
returnThis
in class BaseComponentDeclarer<BoltDeclarer>
public void dump(TopologyAPI.Topology.Builder bldr)
public BoltDeclarer fieldsGrouping(java.lang.String componentName, Fields fields)
public BoltDeclarer fieldsGrouping(java.lang.String componentName, java.lang.String streamId, Fields fields)
public BoltDeclarer globalGrouping(java.lang.String componentName)
public BoltDeclarer globalGrouping(java.lang.String componentName, java.lang.String streamId)
public BoltDeclarer shuffleGrouping(java.lang.String componentName)
public BoltDeclarer shuffleGrouping(java.lang.String componentName, java.lang.String streamId)
public BoltDeclarer localOrShuffleGrouping(java.lang.String componentName)
public BoltDeclarer localOrShuffleGrouping(java.lang.String componentName, java.lang.String streamId)
public BoltDeclarer noneGrouping(java.lang.String componentName)
public BoltDeclarer noneGrouping(java.lang.String componentName, java.lang.String streamId)
public BoltDeclarer allGrouping(java.lang.String componentName)
public BoltDeclarer allGrouping(java.lang.String componentName, java.lang.String streamId)
public BoltDeclarer directGrouping(java.lang.String componentName)
public BoltDeclarer directGrouping(java.lang.String componentName, java.lang.String streamId)
public BoltDeclarer customGrouping(java.lang.String componentName, CustomStreamGrouping grouping)
public BoltDeclarer customGrouping(java.lang.String componentName, java.lang.String streamId, CustomStreamGrouping grouping)