Modifier and Type | Field and Description |
---|---|
protected JoinType |
JoinOperator.joinType |
Modifier and Type | Method and Description |
---|---|
JoinType |
JoinOperator.getJoinType()
Gets the JoinType that describes this join operation (e.g.
|
Constructor and Description |
---|
DefaultJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
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,
JoinType type) |
JoinOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
JoinType type) |
Modifier and Type | Field and Description |
---|---|
protected JoinType |
JoinOperatorSetsBase.joinType |
Modifier and Type | Method and Description |
---|---|
static JoinType |
JoinType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static JoinType[] |
JoinType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
JoinOperatorSetsBase(DataSet<I1> input1,
DataSet<I2> input2,
JoinOperatorBase.JoinHint hint,
JoinType type) |
Modifier and Type | Method and Description |
---|---|
JoinType |
UnfinishedJoinOperationBase.joinType() |
Constructor and Description |
---|
UnfinishedJoinOperationBase(DataSet<L> leftSet,
DataSet<R> rightSet,
JoinOperatorBase.JoinHint joinHint,
JoinType joinType) |
UnfinishedOuterJoinOperation(DataSet<L> leftSet,
DataSet<R> rightSet,
JoinOperatorBase.JoinHint joinHint,
JoinType joinType) |
Modifier and Type | Method and Description |
---|---|
JoinType |
Join.joinType() |
Constructor and Description |
---|
Join(LogicalNode left,
LogicalNode right,
JoinType joinType,
scala.Option<Expression> condition,
boolean correlated) |
Modifier and Type | Method and Description |
---|---|
static JoinType |
TypeConverter.sqlJoinTypeToFlinkJoinType(org.apache.calcite.rel.core.JoinRelType sqlJoinType) |
JoinType |
TypeConverter$.sqlJoinTypeToFlinkJoinType(org.apache.calcite.rel.core.JoinRelType sqlJoinType) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.core.JoinRelType |
TypeConverter.flinkJoinTypeToRelType(JoinType joinType) |
org.apache.calcite.rel.core.JoinRelType |
TypeConverter$.flinkJoinTypeToRelType(JoinType joinType) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.