Package org.apache.flink.runtime.operators.chaining

Class Summary

Class	Description
ChainedAllReduceDriver<IT>
ChainedDriver<IT,OT>	The interface to be implemented by drivers that do not run in an own task context, but are chained to other tasks.
ChainedFlatMapDriver<IT,OT>
ChainedMapDriver<IT,OT>
ChainedReduceCombineDriver<T>	Chained version of ReduceCombineDriver.
ChainedTerminationCriterionDriver<IT,OT>
GroupCombineChainedDriver<IN,OUT>	Chained variant of the GroupReduceCombineDriver Acts like a combiner with a custom output type OUT.
SynchronousChainedCombineDriver<IN,OUT>	The chained variant of the combine driver which is also implemented in GroupReduceCombineDriver.

Exception Summary

Exception	Description
ExceptionInChainedStubException	A special exception to indicate that an exception occurred in the nested call of a chained stub.