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> Deprecated. This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.

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<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(int[] keyPositions1, int[] keyPositions2) Deprecated.
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(int[] keyPositions1, int[] keyPositions2) KeyBy operation for connected data stream.
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(int keyPosition1, int keyPosition2) KeyBy operation for connected data stream.
<KEY> ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(KeySelector<I,KEY> keySelector1, KeySelector<F,KEY> keySelector2) Deprecated.
<KEY> ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(KeySelector<I,KEY> keySelector1, KeySelector<F,KEY> keySelector2, TypeInformation<KEY> keyType) Deprecated.
<KEY> ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(KeySelector<IN1,KEY> keySelector1, KeySelector<IN2,KEY> keySelector2) KeyBy operation for connected data stream.
<KEY> ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(KeySelector<IN1,KEY> keySelector1, KeySelector<IN2,KEY> keySelector2, TypeInformation<KEY> keyType) KeyBy operation for connected data stream.
ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(String[] fields1, String[] fields2) Deprecated.
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(String[] fields1, String[] fields2) KeyBy operation for connected data stream using key expressions. the elements of input1 and input2 according to fields1 and fields2.
ConnectedStreams<I,F>	IterativeStream.ConnectedIterativeStreams.keyBy(String field1, String field2) Deprecated.
ConnectedStreams<IN1,IN2>	ConnectedStreams.keyBy(String field1, String field2) KeyBy operation for connected data stream using key expressions.