Modifier and Type | Field and Description |
---|---|
protected OutputSelector<OUT>[] |
DirectedOutput.outputSelectors |
Constructor and Description |
---|
CopyingDirectedOutput(List<OutputSelector<OUT>> outputSelectors,
List<? extends Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge>> outputs) |
DirectedOutput(List<OutputSelector<OUT>> outputSelectors,
List<? extends Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge>> outputs) |
Modifier and Type | Method and Description |
---|---|
SplitStream<T> |
DataStream.split(OutputSelector<T> outputSelector)
Deprecated.
Please use side output instead.
|
SplitStream<T> |
SingleOutputStreamOperator.split(OutputSelector<T> outputSelector) |
Constructor and Description |
---|
SplitStream(DataStream<OUT> dataStream,
OutputSelector<OUT> outputSelector)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
List<OutputSelector<?>> |
StreamNode.getOutputSelectors() |
<T> List<OutputSelector<T>> |
StreamConfig.getOutputSelectors(ClassLoader userCodeClassloader) |
Modifier and Type | Method and Description |
---|---|
<T> void |
StreamGraph.addOutputSelector(Integer vertexID,
OutputSelector<T> outputSelector) |
void |
StreamNode.addOutputSelector(OutputSelector<?> outputSelector) |
Modifier and Type | Method and Description |
---|---|
void |
StreamConfig.setOutputSelectors(List<OutputSelector<?>> outputSelectors) |
Constructor and Description |
---|
StreamNode(Integer id,
String slotSharingGroup,
String coLocationGroup,
StreamOperator<?> operator,
String operatorName,
List<OutputSelector<?>> outputSelector,
Class<? extends AbstractInvokable> jobVertexClass) |
StreamNode(Integer id,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<?> operatorFactory,
String operatorName,
List<OutputSelector<?>> outputSelector,
Class<? extends AbstractInvokable> jobVertexClass) |
Modifier and Type | Method and Description |
---|---|
OutputSelector<T> |
SplitTransformation.getOutputSelector()
Returns the
OutputSelector . |
Constructor and Description |
---|
SplitTransformation(Transformation<T> input,
OutputSelector<T> outputSelector)
Creates a new
SplitTransformation from the given input and OutputSelector . |
Modifier and Type | Class and Description |
---|---|
static class |
IterateExample.MySelector
OutputSelector testing which tuple needs to be iterated again.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.