T
- The type of the two input data sets and the result data set@Deprecated @Public public class UnionOperator<T> extends TwoInputOperator<T,T,T,UnionOperator<T>>
minResources, name, parallelism, preferredResources
Constructor and Description |
---|
UnionOperator(DataSet<T> input1,
DataSet<T> input2,
String unionLocationName)
Deprecated.
Create an operator that produces the union of the two given data sets.
|
Modifier and Type | Method and Description |
---|---|
UnionOperator<T> |
setParallelism(int parallelism)
Deprecated.
Sets the parallelism for this operator.
|
protected Union<T> |
translateToDataFlow(Operator<T> input1,
Operator<T> input2)
Deprecated.
Returns the BinaryNodeTranslation of the Union.
|
getInput1, getInput1Type, getInput2, getInput2Type
getMinResources, getName, getParallelism, getPreferredResources, getResultType, name
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
protected Union<T> translateToDataFlow(Operator<T> input1, Operator<T> input2)
translateToDataFlow
in class TwoInputOperator<T,T,T,UnionOperator<T>>
input1
- The first input of the union, as a common API operator.input2
- The second input of the union, as a common API operator.public UnionOperator<T> setParallelism(int parallelism)
Operator
setParallelism
in class Operator<T,UnionOperator<T>>
parallelism
- The parallelism for this operator. A value equal to ExecutionConfig.PARALLELISM_DEFAULT
will use the system default.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.