Modifier and Type | Method and Description |
---|---|
QueryOperation |
Table.getQueryOperation()
Returns underlying logical representation of this table.
|
Modifier and Type | Method and Description |
---|---|
QueryOperation |
TableImpl.getQueryOperation() |
Modifier and Type | Method and Description |
---|---|
protected TableImpl |
TableEnvironmentImpl.createTable(QueryOperation tableOperation) |
static TableImpl |
TableImpl.createTable(TableEnvironment tableEnvironment,
QueryOperation operationTree,
OperationTreeBuilder operationTreeBuilder,
FunctionLookup functionLookup) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
QueryOperationCatalogView.getQueryOperation() |
Constructor and Description |
---|
QueryOperationCatalogView(QueryOperation queryOperation) |
QueryOperationCatalogView(QueryOperation queryOperation,
String comment) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
TableReferenceExpression.getQueryOperation() |
Constructor and Description |
---|
TableReferenceExpression(String name,
QueryOperation queryOperation) |
Modifier and Type | Method and Description |
---|---|
static ExpressionResolver.ExpressionResolverBuilder |
ExpressionResolver.resolverFor(TableReferenceLookup tableCatalog,
FunctionLookup functionLookup,
QueryOperation... inputs)
Creates a builder for
ExpressionResolver . |
Constructor and Description |
---|
FieldReferenceLookup(List<QueryOperation> queryOperations) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
TemporalTableFunctionImpl.getUnderlyingHistoryTable() |
Modifier and Type | Method and Description |
---|---|
static TemporalTableFunction |
TemporalTableFunctionImpl.create(QueryOperation operationTree,
Expression timeAttribute,
Expression primaryKey) |
Modifier and Type | Class and Description |
---|---|
class |
AggregateQueryOperation
Relational operation that performs computations on top of subsets of input rows grouped by
key.
|
class |
CalculatedQueryOperation<T>
Describes a relational operation that was created from applying a
TableFunction . |
class |
CatalogQueryOperation
Describes a relational operation that was created from a lookup to a catalog.
|
class |
DataSetQueryOperation<E>
Describes a relational operation that reads from a
DataSet . |
class |
DistinctQueryOperation
Removes duplicated rows of underlying relational operation.
|
class |
FilterQueryOperation
Filters out rows of underlying relational operation that do not match given condition.
|
class |
JavaDataStreamQueryOperation<E>
Describes a relational operation that reads from a
DataStream . |
class |
JoinQueryOperation
Table operation that joins two relational operations based on given condition.
|
class |
ProjectQueryOperation
Table operation that computes new table using given
Expression s
from its input relational operation. |
class |
ScalaDataStreamQueryOperation<E>
Describes a relational operation that reads from a
DataStream . |
class |
SetQueryOperation
A set operation on two relations.
|
class |
SortQueryOperation
Expresses sort operation of rows of the underlying relational operation with given order.
|
class |
TableSourceQueryOperation<T>
Inline scan of a
TableSource . |
class |
WindowAggregateQueryOperation
Relational operation that performs computations on top of subsets of input rows grouped by
key and group window.
|
Modifier and Type | Method and Description |
---|---|
QueryOperation |
SortQueryOperation.getChild() |
QueryOperation |
ModifyOperation.getChild() |
QueryOperation |
OutputConversionModifyOperation.getChild() |
QueryOperation |
UnregisteredSinkModifyOperation.getChild() |
QueryOperation |
CatalogSinkModifyOperation.getChild() |
Modifier and Type | Method and Description |
---|---|
List<QueryOperation> |
ScalaDataStreamQueryOperation.getChildren() |
List<QueryOperation> |
JavaDataStreamQueryOperation.getChildren() |
List<QueryOperation> |
DataSetQueryOperation.getChildren() |
List<QueryOperation> |
DistinctQueryOperation.getChildren() |
List<QueryOperation> |
FilterQueryOperation.getChildren() |
List<QueryOperation> |
SortQueryOperation.getChildren() |
List<QueryOperation> |
TableSourceQueryOperation.getChildren() |
List<QueryOperation> |
JoinQueryOperation.getChildren() |
List<QueryOperation> |
CatalogQueryOperation.getChildren() |
List<QueryOperation> |
WindowAggregateQueryOperation.getChildren() |
List<QueryOperation> |
ProjectQueryOperation.getChildren() |
List<QueryOperation> |
AggregateQueryOperation.getChildren() |
List<QueryOperation> |
SetQueryOperation.getChildren() |
List<QueryOperation> |
QueryOperation.getChildren() |
List<QueryOperation> |
CalculatedQueryOperation.getChildren() |
Modifier and Type | Method and Description |
---|---|
T |
QueryOperationVisitor.visit(QueryOperation other) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
OperationTreeBuilder.addColumns(boolean replaceIfExist,
List<Expression> fieldLists,
QueryOperation child)
Adds additional columns.
|
QueryOperation |
OperationTreeBuilder.aggregate(List<Expression> groupingExpressions,
Expression aggregate,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.aggregate(List<Expression> groupingExpressions,
List<Expression> aggregates,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.alias(List<Expression> fields,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.distinct(QueryOperation child) |
QueryOperation |
OperationTreeBuilder.dropColumns(List<Expression> fieldLists,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.filter(Expression condition,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.flatMap(Expression tableFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.intersect(QueryOperation left,
QueryOperation right,
boolean all) |
QueryOperation |
OperationTreeBuilder.join(QueryOperation left,
QueryOperation right,
JoinQueryOperation.JoinType joinType,
Optional<Expression> condition,
boolean correlated) |
QueryOperation |
OperationTreeBuilder.joinLateral(QueryOperation left,
Expression tableFunction,
JoinQueryOperation.JoinType joinType,
Optional<Expression> condition) |
QueryOperation |
OperationTreeBuilder.limitWithFetch(int fetch,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.limitWithOffset(int offset,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.map(Expression mapFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.minus(QueryOperation left,
QueryOperation right,
boolean all) |
QueryOperation |
OperationTreeBuilder.project(List<Expression> projectList,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.project(List<Expression> projectList,
QueryOperation child,
boolean explicitAlias) |
QueryOperation |
OperationTreeBuilder.project(List<Expression> projectList,
QueryOperation child,
List<OverWindow> overWindows) |
QueryOperation |
OperationTreeBuilder.renameColumns(List<Expression> aliases,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.sort(List<Expression> fields,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.tableAggregate(List<Expression> groupingExpressions,
Expression tableAggFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.union(QueryOperation left,
QueryOperation right,
boolean all) |
QueryOperation |
OperationTreeBuilder.windowAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
Expression aggregateFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.windowAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
List<Expression> aggregates,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.windowTableAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
Expression tableAggFunction,
QueryOperation child) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
OperationTreeBuilder.addColumns(boolean replaceIfExist,
List<Expression> fieldLists,
QueryOperation child)
Adds additional columns.
|
QueryOperation |
OperationTreeBuilder.aggregate(List<Expression> groupingExpressions,
Expression aggregate,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.aggregate(List<Expression> groupingExpressions,
List<Expression> aggregates,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.alias(List<Expression> fields,
QueryOperation child) |
abstract T |
QueryOperationDefaultVisitor.defaultMethod(QueryOperation other) |
QueryOperation |
OperationTreeBuilder.distinct(QueryOperation child) |
QueryOperation |
OperationTreeBuilder.dropColumns(List<Expression> fieldLists,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.filter(Expression condition,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.flatMap(Expression tableFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.intersect(QueryOperation left,
QueryOperation right,
boolean all) |
QueryOperation |
OperationTreeBuilder.join(QueryOperation left,
QueryOperation right,
JoinQueryOperation.JoinType joinType,
Optional<Expression> condition,
boolean correlated) |
QueryOperation |
OperationTreeBuilder.joinLateral(QueryOperation left,
Expression tableFunction,
JoinQueryOperation.JoinType joinType,
Optional<Expression> condition) |
QueryOperation |
OperationTreeBuilder.limitWithFetch(int fetch,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.limitWithOffset(int offset,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.map(Expression mapFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.minus(QueryOperation left,
QueryOperation right,
boolean all) |
QueryOperation |
OperationTreeBuilder.project(List<Expression> projectList,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.project(List<Expression> projectList,
QueryOperation child,
boolean explicitAlias) |
QueryOperation |
OperationTreeBuilder.project(List<Expression> projectList,
QueryOperation child,
List<OverWindow> overWindows) |
QueryOperation |
OperationTreeBuilder.renameColumns(List<Expression> aliases,
QueryOperation child) |
Expression |
OperationTreeBuilder.resolveExpression(Expression expression,
QueryOperation... tableOperation) |
QueryOperation |
OperationTreeBuilder.sort(List<Expression> fields,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.tableAggregate(List<Expression> groupingExpressions,
Expression tableAggFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.union(QueryOperation left,
QueryOperation right,
boolean all) |
T |
QueryOperationDefaultVisitor.visit(QueryOperation other) |
QueryOperation |
OperationTreeBuilder.windowAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
Expression aggregateFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.windowAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
List<Expression> aggregates,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.windowTableAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
Expression tableAggFunction,
QueryOperation child) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
ProjectionOperationFactory.create(List<ResolvedExpression> projectList,
QueryOperation child,
boolean explicitAlias,
ExpressionResolver.PostResolverFactory postResolverFactory) |
QueryOperation |
JoinOperationFactory.create(QueryOperation left,
QueryOperation right,
JoinQueryOperation.JoinType joinType,
ResolvedExpression condition,
boolean correlated)
Creates a valid
JoinQueryOperation operation. |
QueryOperation |
SetOperationFactory.create(SetQueryOperation.SetQueryOperationType type,
QueryOperation left,
QueryOperation right,
boolean all)
Creates a valid algebraic operation.
|
QueryOperation |
AggregateOperationFactory.createAggregate(List<ResolvedExpression> groupings,
List<ResolvedExpression> aggregates,
QueryOperation child)
Creates a valid
AggregateQueryOperation operation. |
static List<Expression> |
AliasOperationUtils.createAliasList(List<Expression> aliases,
QueryOperation child)
Creates a list of valid alias expressions.
|
QueryOperation |
SortOperationFactory.createLimitWithFetch(int fetch,
QueryOperation child)
Adds fetch to the underlying
SortQueryOperation if it is a valid one. |
QueryOperation |
SortOperationFactory.createLimitWithOffset(int offset,
QueryOperation child)
Adds offset to the underlying
SortQueryOperation if it is a valid one. |
QueryOperation |
SortOperationFactory.createSort(List<ResolvedExpression> orders,
QueryOperation child,
ExpressionResolver.PostResolverFactory postResolverFactory)
Creates a valid
SortQueryOperation operation. |
QueryOperation |
AggregateOperationFactory.createWindowAggregate(List<ResolvedExpression> groupings,
List<ResolvedExpression> aggregates,
List<ResolvedExpression> windowProperties,
WindowAggregateQueryOperation.ResolvedGroupWindow window,
QueryOperation child)
Creates a valid
WindowAggregateQueryOperation operation. |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
QueryOperationConverter.defaultMethod(QueryOperation other) |
Modifier and Type | Class and Description |
---|---|
class |
DataStreamQueryOperation<E>
Describes a relational operation that reads from a
DataStream . |
class |
PlannerQueryOperation
Wrapper for valid logical plans generated by Planner.
|
class |
RichTableSourceQueryOperation<T>
A
TableSourceQueryOperation with FlinkStatistic and qualifiedName. |
Modifier and Type | Method and Description |
---|---|
List<QueryOperation> |
DataStreamQueryOperation.getChildren() |
List<QueryOperation> |
PlannerQueryOperation.getChildren() |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
QueryOperationConverter.defaultMethod(QueryOperation other) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.