Package 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	Description
NoOpOperator(DataSet<IN> input, org.apache.flink.api.common.typeinfo.TypeInformation<IN> resultType)

Method Summary

Modifier and Type	Method	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,
                    org.apache.flink.api.common.typeinfo.TypeInformation<IN> resultType)

Method Detail

getInput

public DataSet<IN> getInput()

setInput

public void setInput(DataSet<IN> input)