Package org.apache.storm.drpc
Interface LinearDRPCInputDeclarer
- All Superinterfaces:
- ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>,- ResourceDeclarer<LinearDRPCInputDeclarer>
public interface LinearDRPCInputDeclarer
extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>
- 
Method SummaryModifier 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.ComponentConfigurationDeclareraddConfiguration, addConfigurations, addResource, addResources, getComponentConfiguration, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setNumTasksMethods inherited from interface org.apache.storm.topology.ResourceDeclareraddSharedMemory, setCPULoad, setMemoryLoad, setMemoryLoad
- 
Method Details- 
fieldsGrouping
- 
fieldsGrouping
- 
globalGroupingLinearDRPCInputDeclarer globalGrouping()
- 
globalGrouping
- 
shuffleGroupingLinearDRPCInputDeclarer shuffleGrouping()
- 
shuffleGrouping
- 
localOrShuffleGroupingLinearDRPCInputDeclarer localOrShuffleGrouping()
- 
localOrShuffleGrouping
- 
noneGroupingLinearDRPCInputDeclarer noneGrouping()
- 
noneGrouping
- 
allGroupingLinearDRPCInputDeclarer allGrouping()
- 
allGrouping
- 
directGroupingLinearDRPCInputDeclarer directGrouping()
- 
directGrouping
- 
partialKeyGrouping
- 
partialKeyGrouping
- 
customGrouping
- 
customGrouping
 
-