backtype.storm.drpc
Interface LinearDRPCInputDeclarer

All Superinterfaces:

ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>

public interface LinearDRPCInputDeclarer
extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>

Method Summary

LinearDRPCInputDeclarer	allGrouping()
LinearDRPCInputDeclarer	allGrouping(java.lang.String streamId)
LinearDRPCInputDeclarer	directGrouping()
LinearDRPCInputDeclarer	directGrouping(java.lang.String streamId)
LinearDRPCInputDeclarer	fieldsGrouping(Fields fields)
LinearDRPCInputDeclarer	fieldsGrouping(java.lang.String streamId, Fields fields)
LinearDRPCInputDeclarer	globalGrouping()
LinearDRPCInputDeclarer	globalGrouping(java.lang.String streamId)
LinearDRPCInputDeclarer	noneGrouping()
LinearDRPCInputDeclarer	noneGrouping(java.lang.String streamId)
LinearDRPCInputDeclarer	shuffleGrouping()
LinearDRPCInputDeclarer	shuffleGrouping(java.lang.String streamId)

Methods inherited from interface backtype.storm.topology.ComponentConfigurationDeclarer

addConfiguration, addConfigurations, setDebug, setMaxSpoutPending, setMaxTaskParallelism

Method Detail

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)

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)