Uses of Interface
org.apache.flink.api.common.functions.MapPartitionFunction
-
Packages that use MapPartitionFunction Package Description org.apache.flink.api.common.functions org.apache.flink.api.common.operators.base org.apache.flink.api.java.typeutils -
-
Uses of MapPartitionFunction in org.apache.flink.api.common.functions
Classes in org.apache.flink.api.common.functions that implement MapPartitionFunction Modifier and Type Class Description classRichMapPartitionFunction<I,O>Rich variant of theMapPartitionFunction. -
Uses of MapPartitionFunction in org.apache.flink.api.common.operators.base
Classes in org.apache.flink.api.common.operators.base with type parameters of type MapPartitionFunction Modifier and Type Class Description classMapPartitionOperatorBase<IN,OUT,FT extends MapPartitionFunction<IN,OUT>> -
Uses of MapPartitionFunction in org.apache.flink.api.java.typeutils
Methods in org.apache.flink.api.java.typeutils with parameters of type MapPartitionFunction Modifier and Type Method Description static <IN,OUT>
TypeInformation<OUT>TypeExtractor. getMapPartitionReturnTypes(MapPartitionFunction<IN,OUT> mapPartitionInterface, TypeInformation<IN> inType)static <IN,OUT>
TypeInformation<OUT>TypeExtractor. getMapPartitionReturnTypes(MapPartitionFunction<IN,OUT> mapPartitionInterface, TypeInformation<IN> inType, String functionName, boolean allowMissing)
-