I1 - The type of the first input DataSet of the Join transformation.I2 - The type of the second input DataSet of the Join transformation.OUT - The type of the result of the Join transformation.@Public public static class JoinOperator.EquiJoin<I1,I2,OUT> extends JoinOperator<I1,I2,OUT>
JoinFunction on each pair of joining elements.
It also represents the DataSet that is the result of a Join transformation.
RichFlatJoinFunction,
DataSetJoinOperator.DefaultJoin<I1,I2>, JoinOperator.EquiJoin<I1,I2,OUT>, JoinOperator.JoinOperatorSets<I1,I2>, JoinOperator.ProjectJoin<I1,I2,OUT extends Tuple>joinType, keys1, keys2minResources, name, parallelism, preferredResources| Constructor and Description |
|---|
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
| Modifier and Type | Method and Description |
|---|---|
protected DualInputSemanticProperties |
extractSemanticAnnotationsFromUdf(Class<?> udfClass) |
protected FlatJoinFunction<I1,I2,OUT> |
getFunction() |
DualInputSemanticProperties |
getSemanticProperties()
Gets the semantic properties that have been set for the user-defined functions (UDF).
|
protected JoinOperatorBase<?,?,OUT,?> |
translateToDataFlow(Operator<I1> input1,
Operator<I2> input2)
Translates this java API operator into a common API operator with two inputs.
|
protected boolean |
udfWithForwardedFieldsFirstAnnotation(Class<?> udfClass) |
protected boolean |
udfWithForwardedFieldsSecondAnnotation(Class<?> udfClass) |
getJoinHint, getJoinType, getKeys1, getKeys2, getPartitioner, withPartitionergetAnalyzedUdfSemanticsFlag, getBroadcastSets, getParameters, returns, returns, returns, setAnalyzedUdfSemanticsFlag, setSemanticProperties, withBroadcastSet, withForwardedFieldsFirst, withForwardedFieldsSecond, withParametersgetInput1, getInput1Type, getInput2, getInput2TypegetMinResources, getName, getParallelism, getPreferredResources, getResultType, name, setParallelismaggregate, 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, writeAsTextpublic EquiJoin(DataSet<I1> input1, DataSet<I2> input2, Keys<I1> keys1, Keys<I2> keys2, FlatJoinFunction<I1,I2,OUT> function, TypeInformation<OUT> returnType, JoinOperatorBase.JoinHint hint, String joinLocationName)
public EquiJoin(DataSet<I1> input1, DataSet<I2> input2, Keys<I1> keys1, Keys<I2> keys2, FlatJoinFunction<I1,I2,OUT> generatedFunction, JoinFunction<I1,I2,OUT> function, TypeInformation<OUT> returnType, JoinOperatorBase.JoinHint hint, String joinLocationName)
public EquiJoin(DataSet<I1> input1, DataSet<I2> input2, Keys<I1> keys1, Keys<I2> keys2, FlatJoinFunction<I1,I2,OUT> function, TypeInformation<OUT> returnType, JoinOperatorBase.JoinHint hint, String joinLocationName, JoinType type)
protected FlatJoinFunction<I1,I2,OUT> getFunction()
getFunction in class TwoInputUdfOperator<I1,I2,OUT,JoinOperator<I1,I2,OUT>>@Internal public DualInputSemanticProperties getSemanticProperties()
UdfOperatorgetSemanticProperties in interface UdfOperator<JoinOperator<I1,I2,OUT>>getSemanticProperties in class TwoInputUdfOperator<I1,I2,OUT,JoinOperator<I1,I2,OUT>>protected DualInputSemanticProperties extractSemanticAnnotationsFromUdf(Class<?> udfClass)
extractSemanticAnnotationsFromUdf in class TwoInputUdfOperator<I1,I2,OUT,JoinOperator<I1,I2,OUT>>protected boolean udfWithForwardedFieldsFirstAnnotation(Class<?> udfClass)
udfWithForwardedFieldsFirstAnnotation in class TwoInputUdfOperator<I1,I2,OUT,JoinOperator<I1,I2,OUT>>protected boolean udfWithForwardedFieldsSecondAnnotation(Class<?> udfClass)
udfWithForwardedFieldsSecondAnnotation in class TwoInputUdfOperator<I1,I2,OUT,JoinOperator<I1,I2,OUT>>protected JoinOperatorBase<?,?,OUT,?> translateToDataFlow(Operator<I1> input1, Operator<I2> input2)
TwoInputOperatortranslateToDataFlow in class TwoInputOperator<I1,I2,OUT,JoinOperator<I1,I2,OUT>>input1 - The first input of the operation, as a common API operator.input2 - The second input of the operation, as a common API operator.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.