Uses of Interface
org.apache.flink.streaming.api.collector.selector.OutputSelector

Packages that use OutputSelector

Package	Description
org.apache.flink.storm.util
org.apache.flink.streaming.api.collector.selector
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.examples.iteration
org.apache.flink.streaming.python.api.datastream
org.apache.flink.streaming.python.api.functions

Uses of OutputSelector in org.apache.flink.storm.util

Classes in org.apache.flink.storm.util that implement OutputSelector

Modifier and Type	Class and Description
class	StormStreamSelector<T> Used by FlinkTopology to split multiple declared output streams within Flink.

Uses of OutputSelector in org.apache.flink.streaming.api.collector.selector

Fields in org.apache.flink.streaming.api.collector.selector declared as OutputSelector

Modifier and Type	Field and Description
protected OutputSelector<OUT>[]	DirectedOutput.outputSelectors

Constructor parameters in org.apache.flink.streaming.api.collector.selector with type arguments of type OutputSelector

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)

Uses of OutputSelector in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type OutputSelector

Modifier and Type	Method and Description
SplitStream<T>	DataStream.split(OutputSelector<T> outputSelector) Operator used for directing tuples to specific named outputs using an OutputSelector.
SplitStream<T>	SingleOutputStreamOperator.split(OutputSelector<T> outputSelector)

Constructors in org.apache.flink.streaming.api.datastream with parameters of type OutputSelector

Constructor and Description
SplitStream(DataStream<OUT> dataStream, OutputSelector<OUT> outputSelector)

Uses of OutputSelector in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph that return types with arguments of type OutputSelector

Modifier and Type	Method and Description
List<OutputSelector<?>>	StreamNode.getOutputSelectors()
<T> List<OutputSelector<T>>	StreamConfig.getOutputSelectors(ClassLoader userCodeClassloader)

Methods in org.apache.flink.streaming.api.graph with parameters of type OutputSelector

Modifier and Type	Method and Description
<T> void	StreamGraph.addOutputSelector(Integer vertexID, OutputSelector<T> outputSelector)
void	StreamNode.addOutputSelector(OutputSelector<?> outputSelector)

Method parameters in org.apache.flink.streaming.api.graph with type arguments of type OutputSelector

Modifier and Type	Method and Description
void	StreamConfig.setOutputSelectors(List<OutputSelector<?>> outputSelectors)

Constructor parameters in org.apache.flink.streaming.api.graph with type arguments of type OutputSelector

Constructor and Description
StreamNode(StreamExecutionEnvironment env, Integer id, String slotSharingGroup, StreamOperator<?> operator, String operatorName, List<OutputSelector<?>> outputSelector, Class<? extends AbstractInvokable> jobVertexClass)

Uses of OutputSelector in org.apache.flink.streaming.api.transformations

Methods in org.apache.flink.streaming.api.transformations that return OutputSelector

Modifier and Type	Method and Description
OutputSelector<T>	SplitTransformation.getOutputSelector() Returns the OutputSelector.

Constructors in org.apache.flink.streaming.api.transformations with parameters of type OutputSelector

Constructor and Description
SplitTransformation(StreamTransformation<T> input, OutputSelector<T> outputSelector) Creates a new SplitTransformation from the given input and OutputSelector.

Uses of OutputSelector in org.apache.flink.streaming.examples.iteration

Classes in org.apache.flink.streaming.examples.iteration that implement OutputSelector

Modifier and Type	Class and Description
static class	IterateExample.MySelector OutputSelector testing which tuple needs to be iterated again.

Uses of OutputSelector in org.apache.flink.streaming.python.api.datastream

Methods in org.apache.flink.streaming.python.api.datastream with parameters of type OutputSelector

Modifier and Type	Method and Description
PythonSplitStream	PythonDataStream.split(OutputSelector<org.python.core.PyObject> output_selector) A thin wrapper layer over DataStream.split(OutputSelector).

Uses of OutputSelector in org.apache.flink.streaming.python.api.functions

Classes in org.apache.flink.streaming.python.api.functions that implement OutputSelector

Modifier and Type	Class and Description
class	PythonOutputSelector The PythonOutputSelector is a thin wrapper layer over a Python UDF OutputSelector.

Constructors in org.apache.flink.streaming.python.api.functions with parameters of type OutputSelector

Constructor and Description
PythonOutputSelector(OutputSelector<org.python.core.PyObject> fun)