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.
|
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 |
---|
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.
|
CoGroupedStreams
CoGroupedStreams represents two DataStreams that have been co-grouped. |
CoGroupedStreams.TaggedUnion
Internal class for implementing tagged union co-group.
|
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.
|
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 . |
LegacyWindowOperatorType
For specifying what type of window operator was used to create the state
that a
WindowOperator
is restoring from. |
QueryableStateStream
Queryable state stream instance.
|
SingleOutputStreamOperator
SingleOutputStreamOperator represents a user defined transformation
applied on a DataStream with one predefined output type. |
SplitStream
The SplitStream represents an operator that has been split using an
OutputSelector . |
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 |
---|
CoGroupedStreams.TaggedUnion
Internal class for implementing tagged union co-group.
|
KeyedStream
A
KeyedStream represents a DataStream on which operator state is
partitioned by key using a provided KeySelector . |
SplitStream
The SplitStream represents an operator that has been split using an
OutputSelector . |
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 |
---|
LegacyWindowOperatorType
For specifying what type of window operator was used to create the state
that a
WindowOperator
is restoring from. |
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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.