backtype.storm.drpc

Interface LinearDRPCInputDeclarer

All Superinterfaces:

ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>

public interface LinearDRPCInputDeclarer
extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>

Method Summary

Methods

Modifier and Type	Method and Description
LinearDRPCInputDeclarer	allGrouping()
LinearDRPCInputDeclarer	allGrouping(String streamId)
LinearDRPCInputDeclarer	customGrouping(CustomStreamGrouping grouping)
LinearDRPCInputDeclarer	customGrouping(String streamId, CustomStreamGrouping grouping)
LinearDRPCInputDeclarer	directGrouping()
LinearDRPCInputDeclarer	directGrouping(String streamId)
LinearDRPCInputDeclarer	fieldsGrouping(Fields fields)
LinearDRPCInputDeclarer	fieldsGrouping(String streamId, Fields fields)
LinearDRPCInputDeclarer	globalGrouping()
LinearDRPCInputDeclarer	globalGrouping(String streamId)
LinearDRPCInputDeclarer	localOrShuffleGrouping()
LinearDRPCInputDeclarer	localOrShuffleGrouping(String streamId)
LinearDRPCInputDeclarer	noneGrouping()
LinearDRPCInputDeclarer	noneGrouping(String streamId)
LinearDRPCInputDeclarer	partialKeyGrouping(Fields fields)
LinearDRPCInputDeclarer	partialKeyGrouping(String streamId, Fields fields)
LinearDRPCInputDeclarer	shuffleGrouping()
LinearDRPCInputDeclarer	shuffleGrouping(String streamId)

Methods inherited from interface backtype.storm.topology.ComponentConfigurationDeclarer

addConfiguration, addConfigurations, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setNumTasks

Method Detail

fieldsGrouping

LinearDRPCInputDeclarer fieldsGrouping(Fields fields)

fieldsGrouping

LinearDRPCInputDeclarer fieldsGrouping(String streamId,
                                     Fields fields)

globalGrouping

LinearDRPCInputDeclarer globalGrouping()

globalGrouping

LinearDRPCInputDeclarer globalGrouping(String streamId)

shuffleGrouping

LinearDRPCInputDeclarer shuffleGrouping()

shuffleGrouping

LinearDRPCInputDeclarer shuffleGrouping(String streamId)

localOrShuffleGrouping

LinearDRPCInputDeclarer localOrShuffleGrouping()

localOrShuffleGrouping

LinearDRPCInputDeclarer localOrShuffleGrouping(String streamId)

noneGrouping

LinearDRPCInputDeclarer noneGrouping()

noneGrouping

LinearDRPCInputDeclarer noneGrouping(String streamId)

allGrouping

LinearDRPCInputDeclarer allGrouping()

allGrouping

LinearDRPCInputDeclarer allGrouping(String streamId)

directGrouping

LinearDRPCInputDeclarer directGrouping()

directGrouping

LinearDRPCInputDeclarer directGrouping(String streamId)

partialKeyGrouping

LinearDRPCInputDeclarer partialKeyGrouping(Fields fields)

partialKeyGrouping

LinearDRPCInputDeclarer partialKeyGrouping(String streamId,
                                         Fields fields)

customGrouping

LinearDRPCInputDeclarer customGrouping(CustomStreamGrouping grouping)

customGrouping

LinearDRPCInputDeclarer customGrouping(String streamId,
                                     CustomStreamGrouping grouping)