Uses of Class
org.apache.wayang.flink.execution.FlinkExecutionContext
Packages that use FlinkExecutionContext
-
Uses of FlinkExecutionContext in org.apache.wayang.flink.compiler
Methods in org.apache.wayang.flink.compiler with parameters of type FlinkExecutionContextModifier and TypeMethodDescription<I,
O> org.apache.flink.api.common.functions.RichFlatMapFunction<I, O> FunctionCompiler.compile
(FunctionDescriptor.ExtendedSerializableFunction<I, 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)