Package org.apache.wayang.flink.compiler

package org.apache.wayang.flink.compiler

Related Packages

Package	Description
org.apache.wayang.flink
org.apache.wayang.flink.compiler.criterion

Classes

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