Package org.apache.flink.optimizer.util

Class NoOpUnaryUdfOp<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<OUT,OUT,org.apache.flink.api.common.functions.util.NoOpFunction>

org.apache.flink.optimizer.util.NoOpUnaryUdfOp<OUT>

All Implemented Interfaces:

org.apache.flink.util.Visitable<org.apache.flink.api.common.operators.Operator<?>>

public class NoOpUnaryUdfOp<OUT>
extends org.apache.flink.api.common.operators.SingleInputOperator<OUT,OUT,org.apache.flink.api.common.functions.util.NoOpFunction>

Field Summary

Fields

Modifier and Type	Field	Description
static NoOpUnaryUdfOp	INSTANCE

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
NoOpUnaryUdfOp()

Method Summary

Modifier and Type	Method	Description
protected List<OUT>	executeOnCollections(List<OUT> inputData, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.api.common.ExecutionConfig executionConfig)
org.apache.flink.api.common.operators.UnaryOperatorInformation<OUT,OUT>	getOperatorInfo()

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

accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getSemanticProperties, setInput, setInput, setInputs, 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, setParameter, setParameter, setResources, toString

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final NoOpUnaryUdfOp INSTANCE

Constructor Detail

NoOpUnaryUdfOp

public NoOpUnaryUdfOp()

Method Detail

getOperatorInfo

public org.apache.flink.api.common.operators.UnaryOperatorInformation<OUT,OUT> getOperatorInfo()

Overrides:

getOperatorInfo in class org.apache.flink.api.common.operators.SingleInputOperator<OUT,OUT,org.apache.flink.api.common.functions.util.NoOpFunction>

executeOnCollections

protected List<OUT> executeOnCollections(List<OUT> inputData,
                                         org.apache.flink.api.common.functions.RuntimeContext runtimeContext,
                                         org.apache.flink.api.common.ExecutionConfig executionConfig)

Specified by:

executeOnCollections in class org.apache.flink.api.common.operators.SingleInputOperator<OUT,OUT,org.apache.flink.api.common.functions.util.NoOpFunction>