org.apache.flink.table.util

Class DummyNoOpOperator<IN>

java.lang.Object

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

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

org.apache.flink.table.util.DummyNoOpOperator<IN>

public class DummyNoOpOperator<IN>
extends org.apache.flink.api.java.operators.NoOpOperator<IN>

This is dummy NoOpOperator, which context is DummyExecutionEnvironment.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DummyNoOpOperator.DummyInputFormat<IN> Provides a FileInputFormat for DummyNoOpOperator.

Field Summary

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

context

Constructor Summary

Constructors

Constructor and Description
DummyNoOpOperator(org.apache.flink.api.java.ExecutionEnvironment dummyExecEnv, org.apache.flink.api.java.DataSet<IN> input, org.apache.flink.api.common.typeinfo.TypeInformation<IN> resultType)

Method Summary

Methods inherited from class org.apache.flink.api.java.operators.NoOpOperator

getInput, setInput

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

DummyNoOpOperator

public DummyNoOpOperator(org.apache.flink.api.java.ExecutionEnvironment dummyExecEnv,
                         org.apache.flink.api.java.DataSet<IN> input,
                         org.apache.flink.api.common.typeinfo.TypeInformation<IN> resultType)