@Internal public final class FlinkRelBuilder extends org.apache.calcite.tools.RelBuilder
RelBuilder
.Modifier and Type | Method and Description |
---|---|
org.apache.calcite.tools.RelBuilder |
aggregate(org.apache.calcite.tools.RelBuilder.GroupKey groupKey,
Iterable<org.apache.calcite.tools.RelBuilder.AggCall> aggCalls)
Build non-window aggregate for either aggregate or table aggregate.
|
org.apache.calcite.tools.RelBuilder |
expand(List<List<org.apache.calcite.rex.RexNode>> projects,
int expandIdIndex) |
org.apache.flink.table.planner.calcite.FlinkTypeFactory |
getTypeFactory() |
static FlinkRelBuilder |
of(org.apache.calcite.plan.Context context,
org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelOptSchema relOptSchema) |
static FlinkRelBuilder |
of(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelOptSchema relOptSchema) |
static org.apache.calcite.tools.RelBuilderFactory |
proto(org.apache.calcite.plan.Context context) |
static org.apache.calcite.tools.RelBuilder |
pushFunctionScan(org.apache.calcite.tools.RelBuilder relBuilder,
org.apache.calcite.sql.SqlOperator operator,
int inputCount,
Iterable<org.apache.calcite.rex.RexNode> operands,
List<String> aliases)
RelBuilder.functionScan(SqlOperator, int, Iterable) cannot work smoothly with aliases
which is why we implement a custom one. |
org.apache.calcite.tools.RelBuilder |
queryOperation(QueryOperation queryOperation) |
org.apache.calcite.tools.RelBuilder |
rank(org.apache.calcite.util.ImmutableBitSet partitionKey,
org.apache.calcite.rel.RelCollation orderKey,
RankType rankType,
RankRange rankRange,
org.apache.calcite.rel.type.RelDataTypeField rankNumberType,
boolean outputRankNumber) |
org.apache.calcite.tools.RelBuilder |
scan(ObjectIdentifier identifier,
Map<String,String> dynamicOptions) |
org.apache.calcite.tools.RelBuilder |
transform(java.util.function.UnaryOperator<org.apache.calcite.tools.RelBuilder.Config> transform) |
org.apache.calcite.tools.RelBuilder |
watermark(int rowtimeFieldIndex,
org.apache.calcite.rex.RexNode watermarkExpr)
Build watermark assigner relational node.
|
org.apache.calcite.tools.RelBuilder |
windowAggregate(org.apache.flink.table.planner.plan.logical.LogicalWindow window,
org.apache.calcite.tools.RelBuilder.GroupKey groupKey,
List<NamedWindowProperty> namedProperties,
Iterable<org.apache.calcite.tools.RelBuilder.AggCall> aggCalls)
Build window aggregate for either aggregate or table aggregate.
|
adoptConvention, aggregate, aggregate, aggregateCall, aggregateCall, aggregateCall, aggregateCall, aggregateCall, aggregateCall, aggregateCall, aggregateCall, aggregateCall, alias, and, and, antiJoin, antiJoin, as, avg, avg, between, build, call, call, cast, cast, cast, clear, convert, correlate, correlate, count, count, count, count, countStar, create, cursor, desc, distinct, dot, dot, empty, equals, exchange, field, field, field, field, field, field, field, fields, fields, fields, fields, fields, fields, fields, filter, filter, filter, filter, functionScan, functionScan, getCluster, getRelOptSchema, getRexBuilder, getScanFactory, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, hints, hints, in, in, intersect, intersect, isNotNull, isNull, join, join, join, join, join, limit, literal, match, max, max, min, min, minus, minus, not, notEquals, nullsFirst, nullsLast, or, or, patternAlter, patternAlter, patternConcat, patternConcat, patternExclude, patternField, patternPermute, patternPermute, patternQuantify, patternQuantify, peek, peek, peek, permute, pivot, project, project, project, project, projectExcept, projectExcept, projectNamed, projectPlus, projectPlus, proto, push, pushAll, rename, repeatUnion, repeatUnion, scan, scan, semiJoin, semiJoin, snapshot, sort, sort, sort, sort, sortExchange, sortLimit, sortLimit, sum, sum, toString, transientScan, transientScan, uncollect, union, union, values, values, values, values, variable
public static FlinkRelBuilder of(org.apache.calcite.plan.Context context, org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelOptSchema relOptSchema)
public static FlinkRelBuilder of(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelOptSchema relOptSchema)
public static org.apache.calcite.tools.RelBuilderFactory proto(org.apache.calcite.plan.Context context)
public static org.apache.calcite.tools.RelBuilder pushFunctionScan(org.apache.calcite.tools.RelBuilder relBuilder, org.apache.calcite.sql.SqlOperator operator, int inputCount, Iterable<org.apache.calcite.rex.RexNode> operands, List<String> aliases)
RelBuilder.functionScan(SqlOperator, int, Iterable)
cannot work smoothly with aliases
which is why we implement a custom one. The method is static because some RelOptRule
s
don't use FlinkRelBuilder
.public org.apache.calcite.tools.RelBuilder expand(List<List<org.apache.calcite.rex.RexNode>> projects, int expandIdIndex)
public org.apache.calcite.tools.RelBuilder rank(org.apache.calcite.util.ImmutableBitSet partitionKey, org.apache.calcite.rel.RelCollation orderKey, RankType rankType, RankRange rankRange, org.apache.calcite.rel.type.RelDataTypeField rankNumberType, boolean outputRankNumber)
public org.apache.calcite.tools.RelBuilder aggregate(org.apache.calcite.tools.RelBuilder.GroupKey groupKey, Iterable<org.apache.calcite.tools.RelBuilder.AggCall> aggCalls)
aggregate
in class org.apache.calcite.tools.RelBuilder
public org.apache.calcite.tools.RelBuilder windowAggregate(org.apache.flink.table.planner.plan.logical.LogicalWindow window, org.apache.calcite.tools.RelBuilder.GroupKey groupKey, List<NamedWindowProperty> namedProperties, Iterable<org.apache.calcite.tools.RelBuilder.AggCall> aggCalls)
public org.apache.calcite.tools.RelBuilder watermark(int rowtimeFieldIndex, org.apache.calcite.rex.RexNode watermarkExpr)
public org.apache.calcite.tools.RelBuilder queryOperation(QueryOperation queryOperation)
public org.apache.calcite.tools.RelBuilder scan(ObjectIdentifier identifier, Map<String,String> dynamicOptions)
public org.apache.flink.table.planner.calcite.FlinkTypeFactory getTypeFactory()
getTypeFactory
in class org.apache.calcite.tools.RelBuilder
public org.apache.calcite.tools.RelBuilder transform(java.util.function.UnaryOperator<org.apache.calcite.tools.RelBuilder.Config> transform)
transform
in class org.apache.calcite.tools.RelBuilder
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.