public class FlinkRelBuilder
extends org.apache.calcite.tools.RelBuilder
RelBuilder
that changes the default type factory to a FlinkTypeFactory
.Modifier and Type | Class and Description |
---|---|
static class |
FlinkRelBuilder.NamedWindowProperty
Information necessary to create a window aggregate.
|
static class |
FlinkRelBuilder.NamedWindowProperty$ |
Constructor and Description |
---|
FlinkRelBuilder(org.apache.calcite.plan.Context context,
org.apache.calcite.plan.RelOptCluster relOptCluster,
org.apache.calcite.plan.RelOptSchema relOptSchema) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.tools.RelBuilder |
aggregate(LogicalWindow window,
org.apache.calcite.tools.RelBuilder.GroupKey groupKey,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties,
Iterable<org.apache.calcite.tools.RelBuilder.AggCall> aggCalls) |
static FlinkRelBuilder |
create(org.apache.calcite.tools.FrameworkConfig config) |
org.apache.calcite.plan.RelOptCluster |
getCluster() |
org.apache.calcite.plan.RelOptPlanner |
getPlanner() |
FlinkTypeFactory |
getTypeFactory() |
aggregate, aggregate, aggregate, aggregateCall, aggregateCall, alias, and, and, as, avg, build, call, call, cast, cast, cast, clear, convert, count, countStar, desc, distinct, dot, dot, empty, equals, field, field, field, field, field, fields, fields, fields, fields, fields, fields, filter, filter, getAlias, getRexBuilder, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, groupKey, intersect, intersect, isNotNull, isNull, join, join, join, join, join, limit, literal, max, min, minus, not, nullsFirst, nullsLast, or, or, peek, peek, peek, permute, project, project, project, project, proto, proto, push, pushAll, scan, scan, semiJoin, semiJoin, sort, sort, sort, sortLimit, sortLimit, sum, union, union, values, values, values, values
public FlinkRelBuilder(org.apache.calcite.plan.Context context, org.apache.calcite.plan.RelOptCluster relOptCluster, org.apache.calcite.plan.RelOptSchema relOptSchema)
public static FlinkRelBuilder create(org.apache.calcite.tools.FrameworkConfig config)
public org.apache.calcite.plan.RelOptPlanner getPlanner()
public org.apache.calcite.plan.RelOptCluster getCluster()
public FlinkTypeFactory getTypeFactory()
getTypeFactory
in class org.apache.calcite.tools.RelBuilder
public org.apache.calcite.tools.RelBuilder aggregate(LogicalWindow window, org.apache.calcite.tools.RelBuilder.GroupKey groupKey, scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties, Iterable<org.apache.calcite.tools.RelBuilder.AggCall> aggCalls)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.