Uses of Class
org.apache.wayang.flink.execution.FlinkExecutionContext
-
Packages that use FlinkExecutionContext Package Description org.apache.wayang.flink.compiler -
-
Uses of FlinkExecutionContext in org.apache.wayang.flink.compiler
Methods in org.apache.wayang.flink.compiler with parameters of type FlinkExecutionContext Modifier and Type Method Description <I,O>
org.apache.flink.api.common.functions.RichFlatMapFunction<I,O>FunctionCompiler. compile(FunctionDescriptor.ExtendedSerializableFunction<I,java.lang.Iterable<O>> flatMapDescriptor, FlinkExecutionContext exe)<I,O>
org.apache.flink.api.common.functions.RichMapPartitionFunction<I,O>FunctionCompiler. compile(MapPartitionsDescriptor<I,O> descriptor, FlinkExecutionContext fex)<I,O>
org.apache.flink.api.common.functions.RichMapFunction<I,O>FunctionCompiler. compile(TransformationDescriptor<I,O> mapDescriptor, FlinkExecutionContext fex)
-