Uses of Class
org.apache.flink.api.java.operators.MapPartitionOperator
-
Packages that use MapPartitionOperator Package Description org.apache.flink.api.java org.apache.flink.api.java.utils -
-
Uses of MapPartitionOperator in org.apache.flink.api.java
Methods in org.apache.flink.api.java that return MapPartitionOperator Modifier and Type Method Description <R> MapPartitionOperator<T,R>DataSet. mapPartition(org.apache.flink.api.common.functions.MapPartitionFunction<T,R> mapPartition)Deprecated.Applies a Map-style operation to the entire partition of the data. -
Uses of MapPartitionOperator in org.apache.flink.api.java.utils
Methods in org.apache.flink.api.java.utils that return MapPartitionOperator Modifier and Type Method Description static <T> MapPartitionOperator<T,T>DataSetUtils. sample(DataSet<T> input, boolean withReplacement, double fraction)Deprecated.Generate a sample of DataSet by the probability fraction of each element.static <T> MapPartitionOperator<T,T>DataSetUtils. sample(DataSet<T> input, boolean withReplacement, double fraction, long seed)Deprecated.Generate a sample of DataSet by the probability fraction of each element.
-