protected class TopologyBuilder.BoltGetter extends TopologyBuilder.ConfigGetter<BoltDeclarer> implements BoltDeclarer
Constructor and Description |
---|
BoltGetter(String boltId) |
addConfigurations
addConfiguration, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setNumTasks
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addConfiguration, addConfigurations, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setNumTasks
public BoltGetter(String boltId)
public BoltDeclarer fieldsGrouping(String componentId, Fields fields)
fieldsGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer fieldsGrouping(String componentId, String streamId, Fields fields)
fieldsGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer globalGrouping(String componentId)
globalGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer globalGrouping(String componentId, String streamId)
globalGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer shuffleGrouping(String componentId)
shuffleGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer shuffleGrouping(String componentId, String streamId)
shuffleGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer localOrShuffleGrouping(String componentId)
localOrShuffleGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer localOrShuffleGrouping(String componentId, String streamId)
localOrShuffleGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer noneGrouping(String componentId)
noneGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer noneGrouping(String componentId, String streamId)
noneGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer allGrouping(String componentId)
allGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer allGrouping(String componentId, String streamId)
allGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer directGrouping(String componentId)
directGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer directGrouping(String componentId, String streamId)
directGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer customGrouping(String componentId, CustomStreamGrouping grouping)
customGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer customGrouping(String componentId, String streamId, CustomStreamGrouping grouping)
customGrouping
in interface InputDeclarer<BoltDeclarer>
public BoltDeclarer grouping(GlobalStreamId id, Grouping grouping)
grouping
in interface InputDeclarer<BoltDeclarer>
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.