Constructor and Description |
---|
BatchExecCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecLookupJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecNestedLoopJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode condition,
boolean leftIsBuild,
boolean singleRowJoin,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
BatchExecPythonCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSortMergeJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
int[] leftKeys,
int[] rightKeys,
boolean[] filterNulls,
org.apache.calcite.rex.RexNode nonEquiCondition,
boolean leftIsSmaller,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
Constructor and Description |
---|
CommonExecCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
Class<?> operatorBaseClass,
boolean retainHeader,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecPythonCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
FlinkJoinType |
JoinSpec.getJoinType() |
Constructor and Description |
---|
JoinSpec(FlinkJoinType joinType,
int[] leftKeys,
int[] rightKeys,
boolean[] filterNulls,
org.apache.calcite.rex.RexNode nonEquiCondition) |
Constructor and Description |
---|
StreamExecCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
org.apache.calcite.rex.RexNode condition,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLookupJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
static FlinkJoinType |
JoinTypeUtil.getFlinkJoinType(org.apache.calcite.rel.core.JoinRelType joinRelType)
Converts
JoinRelType to FlinkJoinType . |
Modifier and Type | Method and Description |
---|---|
static FlinkJoinType |
FlinkJoinType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FlinkJoinType[] |
FlinkJoinType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
SortMergeJoinOperator(double externalBufferMemRatio,
FlinkJoinType type,
boolean leftIsSmaller,
GeneratedJoinCondition condFuncCode,
GeneratedProjection projectionCode1,
GeneratedProjection projectionCode2,
GeneratedNormalizedKeyComputer computer1,
GeneratedRecordComparator comparator1,
GeneratedNormalizedKeyComputer computer2,
GeneratedRecordComparator comparator2,
GeneratedRecordComparator genKeyComparator,
boolean[] filterNulls) |
Constructor and Description |
---|
ProcTimeIntervalJoin(FlinkJoinType joinType,
long leftLowerBound,
long leftUpperBound,
InternalTypeInfo<RowData> leftType,
InternalTypeInfo<RowData> rightType,
IntervalJoinFunction genJoinFunc) |
RowTimeIntervalJoin(FlinkJoinType joinType,
long leftLowerBound,
long leftUpperBound,
long allowedLateness,
InternalTypeInfo<RowData> leftType,
InternalTypeInfo<RowData> rightType,
IntervalJoinFunction joinFunc,
int leftTimeIdx,
int rightTimeIdx) |
Modifier and Type | Method and Description |
---|---|
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.joinType(FlinkJoinType joinType) |
Modifier and Type | Field and Description |
---|---|
protected FlinkJoinType |
PythonTableFunctionOperator.joinType
The correlate join type.
|
Constructor and Description |
---|
PythonTableFunctionOperator(Configuration config,
PythonFunctionInfo tableFunction,
RowType inputType,
RowType udfInputType,
RowType udfOutputType,
FlinkJoinType joinType,
GeneratedProjection udtfInputGeneratedProjection) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.