Package org.apache.storm.topology
Class TopologyBuilder.BoltGetter
java.lang.Object
org.apache.storm.topology.BaseConfigurationDeclarer<T>
org.apache.storm.topology.TopologyBuilder.ConfigGetter<BoltDeclarer>
org.apache.storm.topology.TopologyBuilder.BoltGetter
- All Implemented Interfaces:
BoltDeclarer
,ComponentConfigurationDeclarer<BoltDeclarer>
,InputDeclarer<BoltDeclarer>
,ResourceDeclarer<BoltDeclarer>
- Enclosing class:
- TopologyBuilder
protected class TopologyBuilder.BoltGetter
extends TopologyBuilder.ConfigGetter<BoltDeclarer>
implements BoltDeclarer
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionallGrouping
(String componentId) The stream is replicated across all the bolt's tasks.allGrouping
(String componentId, String streamId) The stream is replicated across all the bolt's tasks.customGrouping
(String componentId, String streamId, CustomStreamGrouping grouping) A custom stream grouping by implementing the CustomStreamGrouping interface.customGrouping
(String componentId, CustomStreamGrouping grouping) A custom stream grouping by implementing the CustomStreamGrouping interface.directGrouping
(String componentId) A stream grouped this way means that the producer of the tuple decides which task of the consumer will receive this tuple.directGrouping
(String componentId, String streamId) A stream grouped this way means that the producer of the tuple decides which task of the consumer will receive this tuple.fieldsGrouping
(String componentId, String streamId, Fields fields) The stream is partitioned by the fields specified in the grouping.fieldsGrouping
(String componentId, Fields fields) The stream is partitioned by the fields specified in the grouping.globalGrouping
(String componentId) The entire stream goes to a single one of the bolt's tasks.globalGrouping
(String componentId, String streamId) The entire stream goes to a single one of the bolt's tasks.grouping
(GlobalStreamId id, Grouping grouping) localOrShuffleGrouping
(String componentId) If the target bolt has one or more tasks in the same worker process, tuples will be shuffled to just those in-process tasks.localOrShuffleGrouping
(String componentId, String streamId) If the target bolt has one or more tasks in the same worker process, tuples will be shuffled to just those in-process tasks.noneGrouping
(String componentId) This grouping specifies that you don't care how the stream is grouped.noneGrouping
(String componentId, String streamId) This grouping specifies that you don't care how the stream is grouped.partialKeyGrouping
(String componentId, String streamId, Fields fields) Tuples are passed to two hashing functions and each target task is decided based on the comparison of the state of candidate nodes.partialKeyGrouping
(String componentId, Fields fields) Tuples are passed to two hashing functions and each target task is decided based on the comparison of the state of candidate nodes.shuffleGrouping
(String componentId) Tuples are randomly distributed across the bolt's tasks in a way such that each bolt is guaranteed to get an equal number of tuples.shuffleGrouping
(String componentId, String streamId) Tuples are randomly distributed across the bolt's tasks in a way such that each bolt is guaranteed to get an equal number of tuples.Methods inherited from class org.apache.storm.topology.TopologyBuilder.ConfigGetter
addConfigurations, addResource, addResources, addSharedMemory, getComponentConfiguration
Methods inherited from class org.apache.storm.topology.BaseConfigurationDeclarer
addConfiguration, setCPULoad, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setMemoryLoad, setMemoryLoad, setNumTasks
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.storm.topology.ComponentConfigurationDeclarer
addConfiguration, addConfigurations, addResource, addResources, getComponentConfiguration, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setNumTasks
Methods inherited from interface org.apache.storm.topology.ResourceDeclarer
addSharedMemory, setCPULoad, setMemoryLoad, setMemoryLoad
-
Constructor Details
-
BoltGetter
-
-
Method Details
-
fieldsGrouping
Description copied from interface:InputDeclarer
The stream is partitioned by the fields specified in the grouping.- Specified by:
fieldsGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
fieldsGrouping
Description copied from interface:InputDeclarer
The stream is partitioned by the fields specified in the grouping.- Specified by:
fieldsGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
globalGrouping
Description copied from interface:InputDeclarer
The entire stream goes to a single one of the bolt's tasks. Specifically, it goes to the task with the lowest id.- Specified by:
globalGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
globalGrouping
Description copied from interface:InputDeclarer
The entire stream goes to a single one of the bolt's tasks. Specifically, it goes to the task with the lowest id.- Specified by:
globalGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
shuffleGrouping
Description copied from interface:InputDeclarer
Tuples are randomly distributed across the bolt's tasks in a way such that each bolt is guaranteed to get an equal number of tuples.- Specified by:
shuffleGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
shuffleGrouping
Description copied from interface:InputDeclarer
Tuples are randomly distributed across the bolt's tasks in a way such that each bolt is guaranteed to get an equal number of tuples.- Specified by:
shuffleGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
localOrShuffleGrouping
Description copied from interface:InputDeclarer
If the target bolt has one or more tasks in the same worker process, tuples will be shuffled to just those in-process tasks. Otherwise, this acts like a normal shuffle grouping.- Specified by:
localOrShuffleGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
localOrShuffleGrouping
Description copied from interface:InputDeclarer
If the target bolt has one or more tasks in the same worker process, tuples will be shuffled to just those in-process tasks. Otherwise, this acts like a normal shuffle grouping.- Specified by:
localOrShuffleGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
noneGrouping
Description copied from interface:InputDeclarer
This grouping specifies that you don't care how the stream is grouped.- Specified by:
noneGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
noneGrouping
Description copied from interface:InputDeclarer
This grouping specifies that you don't care how the stream is grouped.- Specified by:
noneGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
allGrouping
Description copied from interface:InputDeclarer
The stream is replicated across all the bolt's tasks. Use this grouping with care.- Specified by:
allGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
allGrouping
Description copied from interface:InputDeclarer
The stream is replicated across all the bolt's tasks. Use this grouping with care.- Specified by:
allGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
directGrouping
Description copied from interface:InputDeclarer
A stream grouped this way means that the producer of the tuple decides which task of the consumer will receive this tuple.- Specified by:
directGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
directGrouping
Description copied from interface:InputDeclarer
A stream grouped this way means that the producer of the tuple decides which task of the consumer will receive this tuple.- Specified by:
directGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
grouping
- Specified by:
grouping
in interfaceInputDeclarer<BoltDeclarer>
-
partialKeyGrouping
Description copied from interface:InputDeclarer
Tuples are passed to two hashing functions and each target task is decided based on the comparison of the state of candidate nodes.See https://melmeric.files.wordpress.com/2014/11/the-power-of-both-choices-practical-load-balancing-for-distributed-stream -processing-engines.pdf
- Specified by:
partialKeyGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
partialKeyGrouping
Description copied from interface:InputDeclarer
Tuples are passed to two hashing functions and each target task is decided based on the comparison of the state of candidate nodes.See https://melmeric.files.wordpress.com/2014/11/the-power-of-both-choices-practical-load-balancing-for-distributed-stream -processing-engines.pdf
- Specified by:
partialKeyGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
customGrouping
Description copied from interface:InputDeclarer
A custom stream grouping by implementing the CustomStreamGrouping interface.- Specified by:
customGrouping
in interfaceInputDeclarer<BoltDeclarer>
-
customGrouping
public BoltDeclarer customGrouping(String componentId, String streamId, CustomStreamGrouping grouping) Description copied from interface:InputDeclarer
A custom stream grouping by implementing the CustomStreamGrouping interface.- Specified by:
customGrouping
in interfaceInputDeclarer<BoltDeclarer>
-