Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
SingleOutputStreamOperator
SingleOutputStreamOperator represents a user defined transformation applied on a DataStream with one predefined output type. |
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
DataStreamSink
A Stream Sink.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStreamSource
The DataStreamSource represents the starting point of a DataStream.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
AllWindowedStream
A
AllWindowedStream represents a data stream where the stream of elements is split into
windows based on a WindowAssigner . |
AsyncDataStream.OutputMode
Output mode for asynchronous operations.
|
BroadcastConnectedStream
A BroadcastConnectedStream represents the result of connecting a keyed or non-keyed stream, with
a
BroadcastStream with broadcast
state(s) . |
BroadcastStream
A
BroadcastStream is a stream with broadcast state(s) . |
CoGroupedStreams
CoGroupedStreams represents two DataStreams that have been co-grouped. |
CoGroupedStreams.TaggedUnion
Internal class for implementing tagged union co-group.
|
CoGroupedStreams.UnionSerializer |
CoGroupedStreams.Where
CoGrouped streams that have the key for one side defined.
|
CoGroupedStreams.Where.EqualTo
A co-group operation that has
KeySelectors defined for both inputs. |
CoGroupedStreams.WithWindow
A co-group operation that has
KeySelectors defined for both inputs as
well as a WindowAssigner . |
ConnectedStreams
ConnectedStreams represent two connected streams of (possibly) different data types.
|
CustomSinkOperatorUidHashes
This class is responsible to hold operator Uid hashes from the common operators of the sink.
|
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder
Builder to construct
CustomSinkOperatorUidHashes . |
DataStream
A DataStream represents a stream of elements of the same type.
|
DataStreamSink
A Stream Sink.
|
DataStreamSource
The DataStreamSource represents the starting point of a DataStream.
|
IterativeStream
The iterative data stream represents the start of an iteration in a
DataStream . |
IterativeStream.ConnectedIterativeStreams
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 . |
JoinedStreams
JoinedStreams represents two DataStreams that have been joined. |
JoinedStreams.Where
Joined streams that have the key for one side defined.
|
JoinedStreams.Where.EqualTo
A join operation that has
KeySelectors defined for both inputs. |
JoinedStreams.WithWindow
A join operation that has
KeySelectors defined for both inputs as well as
a WindowAssigner . |
KeyedStream
A
KeyedStream represents a DataStream on which operator state is partitioned by
key using a provided KeySelector . |
KeyedStream.IntervalJoin
Perform a join over a time interval.
|
KeyedStream.IntervalJoined
IntervalJoined is a container for two streams that have keys for both sides as well as the
time boundaries over which elements should be joined.
|
QueryableStateStream
Queryable state stream instance.
|
SingleOutputStreamOperator
SingleOutputStreamOperator represents a user defined transformation applied on a DataStream with one predefined output type. |
WindowedStream
A
WindowedStream represents a data stream where elements are grouped by key, and for each
key, the stream of elements is split into windows based on a WindowAssigner . |
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
DataStreamSource
The DataStreamSource represents the starting point of a DataStream.
|
Class and Description |
---|
AsyncDataStream.OutputMode
Output mode for asynchronous operations.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
DataStreamSink
A Stream Sink.
|
Class and Description |
---|
CustomSinkOperatorUidHashes
This class is responsible to hold operator Uid hashes from the common operators of the sink.
|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
DataStreamSink
A Stream Sink.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
KeyedStream
A
KeyedStream represents a DataStream on which operator state is partitioned by
key using a provided KeySelector . |
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
DataStreamSink
A Stream Sink.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
DataStreamSink
A Stream Sink.
|
Class and Description |
---|
DataStream
A DataStream represents a stream of elements of the same type.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.