Uses of Class
org.apache.flink.streaming.api.datastream.ConnectedStreams

Packages that use ConnectedStreams

Package	Description
org.apache.flink.streaming.api.datastream

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

Subclasses of ConnectedStreams in org.apache.flink.streaming.api.datastream

Modifier and Type	Class and Description
static class	IterativeStream.ConnectedIterativeStreams<I,F> The IterativeStream.ConnectedIterativeStreams represent a start of an iterative part of a streaming program, where the original input of the iteration and the feedback of the iteration are connected as in a ConnectedStreams.

Methods in org.apache.flink.streaming.api.datastream that return ConnectedStreams

Modifier and Type	Method and Description
<R> ConnectedStreams<T,R>	DataStream.connect(DataStream<R> dataStream) Creates a new ConnectedStreams by connecting DataStream outputs of (possible) different types with each other.
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(int[] keyPositions1, int[] keyPositions2) KeyBy operation for connected data stream.
ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(int[] keyPositions1, int[] keyPositions2)
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(int keyPosition1, int keyPosition2) KeyBy operation for connected data stream.
ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(KeySelector<I,?> keySelector1, KeySelector<F,?> keySelector2)
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(KeySelector<IN1,?> keySelector1, KeySelector<IN2,?> keySelector2) KeyBy operation for connected data stream.
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(String[] fields1, String[] fields2) KeyBy operation for connected data stream using key expressions.
ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(String[] fields1, String[] fields2)
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(String field1, String field2) KeyBy operation for connected data stream using key expressions.
ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(String field1, String field2)