T- Type of the input elements.
O- Type of the returned elements.
@Public @FunctionalInterface public interface MapPartitionFunction<T,O> extends Function, Serializable
The basic syntax for a MapPartitionFunction is as follows:
DataSet<X> input = ...; DataSet<Y> result = input.mapPartition(new MyMapPartitionFunction());
values- All records for the mapper
out- The collector to hand results to.
Exception- This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.