org.apache.flink.api.java.operators

Class NoOpOperator<IN>

java.lang.Object

org.apache.flink.api.java.DataSet<IN>

org.apache.flink.api.java.operators.NoOpOperator<IN>

Type Parameters:

IN - The type of the data set passed through the operator.

@Internal
public class NoOpOperator<IN>
extends DataSet<IN>

This operator will be ignored during translation.

Field Summary

Fields inherited from class org.apache.flink.api.java.DataSet

context

Constructor Summary

Constructors

Constructor and Description
NoOpOperator(DataSet<IN> input, TypeInformation<IN> resultType)

Method Summary

Modifier and Type	Method and Description
DataSet<IN>	getInput()
void	setInput(DataSet<IN> input)

Methods inherited from class org.apache.flink.api.java.DataSet

aggregate, checkSameExecutionContext, clean, coGroup, collect, combineGroup, count, cross, crossWithHuge, crossWithTiny, distinct, distinct, distinct, distinct, fillInType, filter, first, flatMap, fullOuterJoin, fullOuterJoin, getExecutionEnvironment, getType, groupBy, groupBy, groupBy, iterate, iterateDelta, join, join, joinWithHuge, joinWithTiny, leftOuterJoin, leftOuterJoin, map, mapPartition, max, maxBy, min, minBy, output, partitionByHash, partitionByHash, partitionByHash, partitionByRange, partitionByRange, partitionByRange, partitionCustom, partitionCustom, partitionCustom, print, print, printOnTaskManager, printToErr, printToErr, project, rebalance, reduce, reduceGroup, rightOuterJoin, rightOuterJoin, runOperation, sortPartition, sortPartition, sortPartition, sum, union, write, write, writeAsCsv, writeAsCsv, writeAsCsv, writeAsCsv, writeAsFormattedText, writeAsFormattedText, writeAsText, writeAsText

Methods inherited from class java.lang.Object

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

Constructor Detail

NoOpOperator

public NoOpOperator(DataSet<IN> input,
                    TypeInformation<IN> resultType)

Method Detail

getInput

public DataSet<IN> getInput()

setInput

public void setInput(DataSet<IN> input)