Package org.apache.flink.api.common.operators.base

Class MapPartitionOperatorBase<IN,OUT,FT extends MapPartitionFunction<IN,OUT>>

java.lang.Object

org.apache.flink.api.common.operators.Operator<OUT>

org.apache.flink.api.common.operators.AbstractUdfOperator<OUT,FT>

org.apache.flink.api.common.operators.SingleInputOperator<IN,OUT,FT>

org.apache.flink.api.common.operators.base.MapPartitionOperatorBase<IN,OUT,FT>

Type Parameters:

IN - The input type.

OUT - The result type.

FT - The type of the user-defined function.

All Implemented Interfaces:

Visitable<Operator<?>>

@Internal
public class MapPartitionOperatorBase<IN,OUT,FT extends MapPartitionFunction<IN,OUT>>
extends SingleInputOperator<IN,OUT,FT>

Field Summary

Fields inherited from class org.apache.flink.api.common.operators.SingleInputOperator

input

Fields inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

broadcastInputs, userFunction

Fields inherited from class org.apache.flink.api.common.operators.Operator

compilerHints, name, operatorInfo, parameters

Constructor Summary

Constructors

Constructor	Description
MapPartitionOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapPartitionOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapPartitionOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)

Method Summary

Modifier and Type	Method	Description
protected List<OUT>	executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)

Methods inherited from class org.apache.flink.api.common.operators.SingleInputOperator

accept, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSemanticProperties, setInput, setSemanticProperties

Methods inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables

Methods inherited from class org.apache.flink.api.common.operators.Operator

createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setResources, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MapPartitionOperatorBase

public MapPartitionOperatorBase(UserCodeWrapper<FT> udf,
                                UnaryOperatorInformation<IN,OUT> operatorInfo,
                                String name)

MapPartitionOperatorBase

public MapPartitionOperatorBase(FT udf,
                                UnaryOperatorInformation<IN,OUT> operatorInfo,
                                String name)

MapPartitionOperatorBase

public MapPartitionOperatorBase(Class<? extends FT> udf,
                                UnaryOperatorInformation<IN,OUT> operatorInfo,
                                String name)

Method Detail

executeOnCollections

protected List<OUT> executeOnCollections(List<IN> inputData,
                                         RuntimeContext ctx,
                                         ExecutionConfig executionConfig)
                                  throws Exception

Specified by:

executeOnCollections in class SingleInputOperator<IN,OUT,FT extends MapPartitionFunction<IN,OUT>>

Throws:

Exception