org.apache.flink.streaming.api.collector.selector

Interface OutputSelector<OUT>

Type Parameters:

OUT - Type parameter of the split values.

All Superinterfaces:

Serializable

All Known Implementing Classes:

IterateExample.MySelector

@PublicEvolving
public interface OutputSelector<OUT>
extends Serializable

Interface for defining an OutputSelector for a SplitStream using the SingleOutputStreamOperator.split(org.apache.flink.streaming.api.collector.selector.OutputSelector<T>) call. Every output object of a SplitStream will run through this operator to select outputs.

Method Summary

Modifier and Type	Method and Description
Iterable<String>	select(OUT value) Method for selecting output names for the emitted objects when using the SingleOutputStreamOperator.split(org.apache.flink.streaming.api.collector.selector.OutputSelector<T>) method.

Method Detail

select

Iterable<String> select(OUT value)

Method for selecting output names for the emitted objects when using the SingleOutputStreamOperator.split(org.apache.flink.streaming.api.collector.selector.OutputSelector<T>) method. The values will be emitted only to output names which are contained in the returned iterable.

Parameters:

value - Output object for which the output selection should be made.