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.DataSet
that is the result of a Join transformation.RichFlatJoinFunction
,
DataSet
JoinOperator.DefaultFlatJoinFunction<T1,T2>, JoinOperator.DefaultJoin<I1,I2>, JoinOperator.EquiJoin<I1,I2,OUT>, JoinOperator.JoinOperatorSets<I1,I2>, JoinOperator.JoinProjection<I1,I2>, JoinOperator.ProjectFlatJoinFunction<T1,T2,R extends Tuple>, JoinOperator.ProjectJoin<I1,I2,OUT extends Tuple>
joinType, keys1, keys2
name, parallelism
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, withPartitioner
getAnalyzedUdfSemanticsFlag, getBroadcastSets, getParameters, returns, returns, returns, returns, setAnalyzedUdfSemanticsFlag, setSemanticProperties, withBroadcastSet, withForwardedFieldsFirst, withForwardedFieldsSecond, withParameters
getInput1, getInput1Type, getInput2, getInput2Type
getName, getParallelism, getResultType, name, setParallelism
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
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)
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()
UdfOperator
getSemanticProperties
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)
TwoInputOperator
translateToDataFlow
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–2017 The Apache Software Foundation. All rights reserved.