backtype.storm.drpc
Interface LinearDRPCInputDeclarer
- All Superinterfaces:
- ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>
public interface LinearDRPCInputDeclarer
- extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>
fieldsGrouping
LinearDRPCInputDeclarer fieldsGrouping(Fields fields)
fieldsGrouping
LinearDRPCInputDeclarer fieldsGrouping(java.lang.String streamId,
Fields fields)
globalGrouping
LinearDRPCInputDeclarer globalGrouping()
globalGrouping
LinearDRPCInputDeclarer globalGrouping(java.lang.String streamId)
shuffleGrouping
LinearDRPCInputDeclarer shuffleGrouping()
shuffleGrouping
LinearDRPCInputDeclarer shuffleGrouping(java.lang.String streamId)
localOrShuffleGrouping
LinearDRPCInputDeclarer localOrShuffleGrouping()
localOrShuffleGrouping
LinearDRPCInputDeclarer localOrShuffleGrouping(java.lang.String streamId)
noneGrouping
LinearDRPCInputDeclarer noneGrouping()
noneGrouping
LinearDRPCInputDeclarer noneGrouping(java.lang.String streamId)
allGrouping
LinearDRPCInputDeclarer allGrouping()
allGrouping
LinearDRPCInputDeclarer allGrouping(java.lang.String streamId)
directGrouping
LinearDRPCInputDeclarer directGrouping()
directGrouping
LinearDRPCInputDeclarer directGrouping(java.lang.String streamId)
customGrouping
LinearDRPCInputDeclarer customGrouping(CustomStreamGrouping grouping)
customGrouping
LinearDRPCInputDeclarer customGrouping(java.lang.String streamId,
CustomStreamGrouping grouping)