org.apache.flink.api.table.typeinfo

Class RenameOperator<T>

java.lang.Object

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

org.apache.flink.api.java.operators.Operator<OUT,O>

org.apache.flink.api.java.operators.SingleInputOperator<T,T,RenameOperator<T>>

org.apache.flink.api.table.typeinfo.RenameOperator<T>

public class RenameOperator<T>
extends SingleInputOperator<T,T,RenameOperator<T>>

This is a logical operator that can hold a RenamingProxyTypeInfo for renaming some fields of a CompositeType. At runtime this disappears since the translation methods simply returns the input.

Field Summary

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

name, parallelism

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

context

Constructor Summary

Constructors

Constructor and Description
RenameOperator(DataSet<T> input, RenamingProxyTypeInfo<T> renamingTypeInformation)

Method Summary

Modifier and Type	Method and Description
protected Operator<T>	translateToDataFlow(Operator<T> input) Translates this operation to a data flow operator of the common data flow API.

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

getInput, getInputType

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

getName, getParallelism, getResultType, name, setParallelism

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

RenameOperator

public RenameOperator(DataSet<T> input,
                      RenamingProxyTypeInfo<T> renamingTypeInformation)

Method Detail

translateToDataFlow

protected Operator<T> translateToDataFlow(Operator<T> input)

Description copied from class: SingleInputOperator

Translates this operation to a data flow operator of the common data flow API.

Specified by:

translateToDataFlow in class SingleInputOperator<T,T,RenameOperator<T>>

Parameters:

input - The data flow operator that produces this operation's input data.

Returns:

The translated data flow operator.