public interface InputDeclarer<T extends InputDeclarer>
Modifier and Type | Method and Description |
---|---|
T |
allGrouping(String componentId) |
T |
allGrouping(String componentId,
String streamId) |
T |
customGrouping(String componentId,
CustomStreamGrouping grouping) |
T |
customGrouping(String componentId,
String streamId,
CustomStreamGrouping grouping) |
T |
directGrouping(String componentId) |
T |
directGrouping(String componentId,
String streamId) |
T |
fieldsGrouping(String componentId,
Fields fields) |
T |
fieldsGrouping(String componentId,
String streamId,
Fields fields) |
T |
globalGrouping(String componentId) |
T |
globalGrouping(String componentId,
String streamId) |
T |
grouping(GlobalStreamId id,
Grouping grouping) |
T |
localOrShuffleGrouping(String componentId) |
T |
localOrShuffleGrouping(String componentId,
String streamId) |
T |
noneGrouping(String componentId) |
T |
noneGrouping(String componentId,
String streamId) |
T |
shuffleGrouping(String componentId) |
T |
shuffleGrouping(String componentId,
String streamId) |
T customGrouping(String componentId, CustomStreamGrouping grouping)
T customGrouping(String componentId, String streamId, CustomStreamGrouping grouping)
T grouping(GlobalStreamId id, Grouping grouping)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.