Package org.apache.storm.drpc
Interface LinearDRPCInputDeclarer
- All Superinterfaces:
ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>
,ResourceDeclarer<LinearDRPCInputDeclarer>
public interface LinearDRPCInputDeclarer
extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>
-
Method Summary
Modifier and TypeMethodDescriptionallGrouping
(String streamId) customGrouping
(String streamId, CustomStreamGrouping grouping) customGrouping
(CustomStreamGrouping grouping) directGrouping
(String streamId) fieldsGrouping
(String streamId, Fields fields) fieldsGrouping
(Fields fields) globalGrouping
(String streamId) localOrShuffleGrouping
(String streamId) noneGrouping
(String streamId) partialKeyGrouping
(String streamId, Fields fields) partialKeyGrouping
(Fields fields) shuffleGrouping
(String streamId) 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
-
Method Details
-
fieldsGrouping
-
fieldsGrouping
-
globalGrouping
LinearDRPCInputDeclarer globalGrouping() -
globalGrouping
-
shuffleGrouping
LinearDRPCInputDeclarer shuffleGrouping() -
shuffleGrouping
-
localOrShuffleGrouping
LinearDRPCInputDeclarer localOrShuffleGrouping() -
localOrShuffleGrouping
-
noneGrouping
LinearDRPCInputDeclarer noneGrouping() -
noneGrouping
-
allGrouping
LinearDRPCInputDeclarer allGrouping() -
allGrouping
-
directGrouping
LinearDRPCInputDeclarer directGrouping() -
directGrouping
-
partialKeyGrouping
-
partialKeyGrouping
-
customGrouping
-
customGrouping
-