public interface LinearDRPCInputDeclarer extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>
addConfiguration, addConfigurations, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setNumTasks
setCPULoad, setMemoryLoad, setMemoryLoad
LinearDRPCInputDeclarer fieldsGrouping(Fields fields)
LinearDRPCInputDeclarer fieldsGrouping(String streamId, Fields fields)
LinearDRPCInputDeclarer globalGrouping()
LinearDRPCInputDeclarer globalGrouping(String streamId)
LinearDRPCInputDeclarer shuffleGrouping()
LinearDRPCInputDeclarer shuffleGrouping(String streamId)
LinearDRPCInputDeclarer localOrShuffleGrouping()
LinearDRPCInputDeclarer localOrShuffleGrouping(String streamId)
LinearDRPCInputDeclarer noneGrouping()
LinearDRPCInputDeclarer noneGrouping(String streamId)
LinearDRPCInputDeclarer allGrouping()
LinearDRPCInputDeclarer allGrouping(String streamId)
LinearDRPCInputDeclarer directGrouping()
LinearDRPCInputDeclarer directGrouping(String streamId)
LinearDRPCInputDeclarer partialKeyGrouping(Fields fields)
LinearDRPCInputDeclarer partialKeyGrouping(String streamId, Fields fields)
LinearDRPCInputDeclarer customGrouping(CustomStreamGrouping grouping)
LinearDRPCInputDeclarer customGrouping(String streamId, CustomStreamGrouping grouping)
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.