Class | Description |
---|---|
AllWindowedStream<T,W extends Window> |
A
AllWindowedStream represents a data stream where the stream of
elements is split into windows based on a
WindowAssigner . |
CoGroupedStreams<T1,T2> |
CoGroupedStreams represents two DataStreams that have been co-grouped. |
CoGroupedStreams.TaggedUnion<T1,T2> |
Internal class for implementing tagged union co-group.
|
CoGroupedStreams.WithWindow<T1,T2,KEY,W extends Window> |
A co-group operation that has
KeySelectors defined for both inputs as
well as a WindowAssigner . |
ConnectedStreams<IN1,IN2> |
ConnectedStreams represent two connected streams of (possibly) different data types.
|
DataStream<T> |
A DataStream represents a stream of elements of the same type.
|
DataStreamSink<T> |
A Stream Sink.
|
DataStreamSource<T> |
The DataStreamSource represents the starting point of a DataStream.
|
IterativeStream<T> |
The iterative data stream represents the start of an iteration in a
DataStream . |
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 . |
JoinedStreams<T1,T2> |
JoinedStreams represents two DataStreams that have been joined. |
JoinedStreams.WithWindow<T1,T2,KEY,W extends Window> |
A join operation that has
KeySelectors defined for both inputs as
well as a WindowAssigner . |
KeyedStream<T,KEY> |
A
KeyedStream represents a DataStream on which operator state is
partitioned by key using a provided KeySelector . |
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator represents a user defined transformation
applied on a DataStream with one predefined output type. |
SplitStream<OUT> |
The SplitStream represents an operator that has been split using an
OutputSelector . |
StreamProjection<IN> | |
WindowedStream<T,K,W extends Window> |
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 . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.