Package org.apache.wayang.flink.compiler

Class Summary

Class	Description
FlinkCoGroupFunction<InputType0,InputType1,OutputType>	Wrapper of CoGroupFunction of Flink for use in Wayang
FunctionCompiler	A compiler translates Wayang functions into executable Flink functions.
KeySelectorDistinct<T>	Wrapper for KeySelector
KeySelectorFunction<T,K>	Wrapper for KeySelector
OutputFormatConsumer<T>	Wrapper for OutputFormat
WayangFileOutputFormat<IT>	Wrapper for FileOutputFormat