Package org.apache.wayang.flink.compiler
package org.apache.wayang.flink.compiler
-
ClassesClassDescriptionFlinkCoGroupFunction<InputType0,
InputType1, OutputType> Wrapper of of Flink for use in WayangA compiler translates Wayang functions into executable Flink functions.Wrapper forKeySelectorFunction<T,K> Wrapper forKeySelectorWrapper forWrapper forFileOutputFormat