public interface LinearDRPCInputDeclarer extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer>
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 |
shuffleGrouping() |
LinearDRPCInputDeclarer |
shuffleGrouping(String streamId) |
addConfiguration, addConfigurations, setDebug, setMaxSpoutPending, setMaxTaskParallelism, setNumTasks
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 customGrouping(CustomStreamGrouping grouping)
LinearDRPCInputDeclarer customGrouping(String streamId, CustomStreamGrouping grouping)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.