Modifier and Type | Method and Description |
---|---|
QueryOperation |
Table.getQueryOperation()
Returns underlying logical representation of this table.
|
Modifier and Type | Method and Description |
---|---|
protected QueryOperation |
AbstractStreamTableEnvironmentImpl.qualifyQueryOperation(ObjectIdentifier identifier,
QueryOperation queryOperation) |
Modifier and Type | Method and Description |
---|---|
protected QueryOperation |
AbstractStreamTableEnvironmentImpl.qualifyQueryOperation(ObjectIdentifier identifier,
QueryOperation queryOperation) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
TableImpl.getQueryOperation() |
protected QueryOperation |
TableEnvironmentImpl.qualifyQueryOperation(ObjectIdentifier identifier,
QueryOperation queryOperation)
Subclasses can override this method to transform the given QueryOperation to a new one with
the qualified object identifier.
|
Modifier and Type | Method and Description |
---|---|
TableImpl |
TableEnvironmentImpl.createTable(QueryOperation tableOperation) |
static TableImpl |
TableImpl.createTable(TableEnvironmentInternal tableEnvironment,
QueryOperation operationTree,
OperationTreeBuilder operationTreeBuilder,
FunctionLookup functionLookup) |
protected QueryOperation |
TableEnvironmentImpl.qualifyQueryOperation(ObjectIdentifier identifier,
QueryOperation queryOperation)
Subclasses can override this method to transform the given QueryOperation to a new one with
the qualified object identifier.
|
Modifier and Type | Method and Description |
---|---|
QueryOperation |
QueryOperationCatalogView.getQueryOperation() |
Constructor and Description |
---|
QueryOperationCatalogView(QueryOperation queryOperation) |
Modifier and Type | Method and Description |
---|---|
ResultDescriptor |
Executor.executeQuery(String sessionId,
QueryOperation query)
Submits a Flink SQL query job (detached) and returns the result descriptor.
|
Modifier and Type | Method and Description |
---|---|
ResultDescriptor |
LocalExecutor.executeQuery(String sessionId,
QueryOperation query) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
TableReferenceExpression.getQueryOperation() |
Modifier and Type | Method and Description |
---|---|
static TableReferenceExpression |
ApiExpressionUtils.tableRef(String name,
QueryOperation queryOperation) |
Modifier and Type | Method and Description |
---|---|
static ExpressionResolver.ExpressionResolverBuilder |
ExpressionResolver.resolverFor(TableConfig tableConfig,
TableReferenceLookup tableCatalog,
FunctionLookup functionLookup,
DataTypeFactory typeFactory,
SqlExpressionResolver sqlExpressionResolver,
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
Describes a relational operation that was created from applying a
TableFunction . |
class |
DataStreamQueryOperation<E>
Deprecated.
|
class |
DistinctQueryOperation
Removes duplicated rows of underlying relational operation.
|
class |
ExternalQueryOperation<E>
Describes a relational operation that reads from a
DataStream . |
class |
FilterQueryOperation
Filters out rows of underlying relational operation that do not match given condition.
|
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 |
SetQueryOperation
A set operation on two relations.
|
class |
SortQueryOperation
Expresses sort operation of rows of the underlying relational operation with given order.
|
class |
SourceQueryOperation
Describes a query operation from a
ContextResolvedTable . |
class |
TableSourceQueryOperation<T>
Inline scan of a
TableSource . |
class |
ValuesQueryOperation
Table operation that computes new table using given
Expression s from its input relational
operation. |
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 |
OutputConversionModifyOperation.getChild() |
QueryOperation |
ExternalModifyOperation.getChild() |
QueryOperation |
ModifyOperation.getChild() |
QueryOperation |
SortQueryOperation.getChild() |
QueryOperation |
UnregisteredSinkModifyOperation.getChild() |
QueryOperation |
CollectModifyOperation.getChild() |
QueryOperation |
SinkModifyOperation.getChild() |
Modifier and Type | Method and Description |
---|---|
List<QueryOperation> |
ExternalQueryOperation.getChildren() |
List<QueryOperation> |
DataStreamQueryOperation.getChildren()
Deprecated.
|
List<QueryOperation> |
QueryOperation.getChildren() |
List<QueryOperation> |
SetQueryOperation.getChildren() |
List<QueryOperation> |
ProjectQueryOperation.getChildren() |
List<QueryOperation> |
SortQueryOperation.getChildren() |
List<QueryOperation> |
CalculatedQueryOperation.getChildren() |
List<QueryOperation> |
SourceQueryOperation.getChildren() |
List<QueryOperation> |
WindowAggregateQueryOperation.getChildren() |
List<QueryOperation> |
AggregateQueryOperation.getChildren() |
List<QueryOperation> |
ValuesQueryOperation.getChildren() |
List<QueryOperation> |
DistinctQueryOperation.getChildren() |
List<QueryOperation> |
JoinQueryOperation.getChildren() |
List<QueryOperation> |
FilterQueryOperation.getChildren() |
List<QueryOperation> |
TableSourceQueryOperation.getChildren() |
Modifier and Type | Method and Description |
---|---|
T |
QueryOperationVisitor.visit(QueryOperation other) |
Constructor and Description |
---|
CreateTableASOperation(CreateTableOperation createTableOperation,
Map<String,String> sinkModifyStaticPartitions,
QueryOperation sinkModifyQuery,
boolean sinkModifyOverwrite) |
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 tableFunctionCall,
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.values(DataType rowType,
Expression... expressions) |
QueryOperation |
OperationTreeBuilder.values(Expression... expressions) |
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 tableFunctionCall,
QueryOperation child) |
ExpressionResolver.ExpressionResolverBuilder |
OperationTreeBuilder.getResolverBuilder(QueryOperation... tableOperation) |
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 |
---|---|
org.apache.calcite.tools.RelBuilder |
FlinkRelBuilder.queryOperation(QueryOperation queryOperation) |
Modifier and Type | Method and Description |
---|---|
Tuple4<ObjectIdentifier,QueryOperation,Map<String,String>,Boolean> |
HiveParserDMLHelper.createInsertOperationInfo(org.apache.calcite.rel.RelNode queryRelNode,
org.apache.hadoop.hive.ql.metadata.Table destTable,
Map<String,String> staticPartSpec,
List<String> destSchema,
boolean overwrite) |
Modifier and Type | Class and Description |
---|---|
class |
InternalDataStreamQueryOperation<E>
Deprecated.
|
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> |
PlannerQueryOperation.getChildren() |
List<QueryOperation> |
InternalDataStreamQueryOperation.getChildren()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
QueryOperationConverter.defaultMethod(QueryOperation other) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.