Class and Description |
---|
StreamExecutionEnvironment |
Class and Description |
---|
DataStream |
StreamExecutionEnvironment |
Class and Description |
---|
StreamExecutionEnvironment |
Class and Description |
---|
DataStream |
Class and Description |
---|
AllWindowedStream
A
AllWindowedStream represents a data stream where the stream of
elements is split into windows based on a
WindowAssigner . |
CoGroupedStreams
CoGroupedStreams represents two DataStream s that have been co-grouped. |
CoGroupedStreams.Where
A co-group operation that has
KeySelector s defined for the first input. |
CoGroupedStreams.Where.EqualTo
A co-group operation that a
KeySelector defined for the first and the second input. |
CoGroupedStreams.Where.EqualTo.WithWindow
A co-group operation that has
KeySelector s defined for both inputs as
well as a WindowAssigner . |
ConnectedStreams
ConnectedStreams represents two connected streams of (possibly) different data types. |
DataStream |
JoinedStreams
JoinedStreams represents two DataStream s that have been joined. |
JoinedStreams.Where
A join operation that has a
KeySelector defined for the first input. |
JoinedStreams.Where.EqualTo
A join operation that has a
KeySelector defined for the first and the second input. |
JoinedStreams.Where.EqualTo.WithWindow
A join operation that has
KeySelector s defined for both inputs as
well as a WindowAssigner . |
KeyedStream |
SplitStream
The SplitStream represents an operator that has been split using an
OutputSelector . |
StreamExecutionEnvironment |
StreamExecutionEnvironment$ |
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 |
---|
ConnectedStreams
ConnectedStreams represents two connected streams of (possibly) different data types. |
DataStream |
JoinedStreams.Where.EqualTo.WithWindow
A join operation that has
KeySelector s defined for both inputs as
well as a WindowAssigner . |
KeyedStream |
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 |
StreamExecutionEnvironment |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.