Uses of Interface
org.apache.storm.drpc.LinearDRPCInputDeclarer
-
Uses of LinearDRPCInputDeclarer in org.apache.storm.drpc
Modifier and TypeMethodDescriptionLinearDRPCTopologyBuilder.addBolt
(IBatchBolt bolt) LinearDRPCTopologyBuilder.addBolt
(IBatchBolt bolt, Number parallelism) LinearDRPCTopologyBuilder.addBolt
(IBasicBolt bolt) LinearDRPCTopologyBuilder.addBolt
(IBasicBolt bolt, Number parallelism) Deprecated.Deprecated.LinearDRPCInputDeclarer.allGrouping()
LinearDRPCInputDeclarer.allGrouping
(String streamId) LinearDRPCInputDeclarer.customGrouping
(String streamId, CustomStreamGrouping grouping) LinearDRPCInputDeclarer.customGrouping
(CustomStreamGrouping grouping) LinearDRPCInputDeclarer.directGrouping()
LinearDRPCInputDeclarer.directGrouping
(String streamId) LinearDRPCInputDeclarer.fieldsGrouping
(String streamId, Fields fields) LinearDRPCInputDeclarer.fieldsGrouping
(Fields fields) LinearDRPCInputDeclarer.globalGrouping()
LinearDRPCInputDeclarer.globalGrouping
(String streamId) LinearDRPCInputDeclarer.localOrShuffleGrouping()
LinearDRPCInputDeclarer.localOrShuffleGrouping
(String streamId) LinearDRPCInputDeclarer.noneGrouping()
LinearDRPCInputDeclarer.noneGrouping
(String streamId) LinearDRPCInputDeclarer.partialKeyGrouping
(String streamId, Fields fields) LinearDRPCInputDeclarer.partialKeyGrouping
(Fields fields) LinearDRPCInputDeclarer.shuffleGrouping()
LinearDRPCInputDeclarer.shuffleGrouping
(String streamId)