Package org.apache.flink.streaming.api.operators.co

Class Summary

Class	Description
CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT>	A TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions.
CoBroadcastWithNonKeyedOperator<IN1,IN2,OUT>	A TwoInputStreamOperator for executing BroadcastProcessFunctions.
CoProcessOperator<IN1,IN2,OUT>	A StreamOperator for executing CoProcessFunctions.
CoStreamFlatMap<IN1,IN2,OUT>	StreamOperator for processing CoFlatMapFunctions.
CoStreamMap<IN1,IN2,OUT>	StreamOperator for processing CoMapFunctions.
IntervalJoinOperator<K,T1,T2,OUT>	An operator to execute time-bounded stream inner joins.
IntervalJoinOperator.BufferSerializerConfigSnapshot<T>	The configuration of our serializer.
KeyedCoProcessOperator<K,IN1,IN2,OUT>	A StreamOperator for executing keyed CoProcessFunctions.