Package | Description |
---|---|
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 . |
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) |
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) |
<KEY> ConnectedStreams<I,F> |
IterativeStream.ConnectedIterativeStreams.keyBy(KeySelector<I,KEY> keySelector1,
KeySelector<F,KEY> keySelector2,
TypeInformation<KEY> keyType) |
<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) |
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 field1,
String field2) |
ConnectedStreams<IN1,IN2> |
ConnectedStreams.keyBy(String field1,
String field2)
KeyBy operation for connected data stream using key expressions.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.