Uses of Interface
org.apache.storm.drpc.LinearDRPCInputDeclarer
Packages that use LinearDRPCInputDeclarer
-
Uses of LinearDRPCInputDeclarer in org.apache.storm.drpc
Methods in org.apache.storm.drpc that return LinearDRPCInputDeclarerModifier 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)