Package org.apache.flink.streaming.api.scala

Class Summary

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.
ConnectedStreams<IN1,IN2>	ConnectedStreams represents two connected streams of (possibly) different data types.
DataStream<T>
JoinedStreams<T1,T2>	JoinedStreams represents two DataStreams that have been joined.
KeyedStream<T,K>
KeySelectorWithType<IN,K>
SplitStream<T>	The SplitStream represents an operator that has been split using an OutputSelector.
StreamExecutionEnvironment
StreamExecutionEnvironment$
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.