Modifier and Type | Method and Description |
---|---|
SupportsFilterPushDown.Result |
FileSystemTableSource.applyFilters(List<ResolvedExpression> filters) |
Modifier and Type | Method and Description |
---|---|
default void |
BulkDecodingFormat.applyFilters(List<ResolvedExpression> filters)
Provides a list of filters in conjunctive form for filtering on a best-effort basis.
|
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
Column.ComputedColumn.getExpression() |
ResolvedExpression |
WatermarkSpec.getWatermarkExpression()
Returns the
ResolvedExpression for watermark generation. |
Modifier and Type | Method and Description |
---|---|
static Column.ComputedColumn |
Column.computed(String name,
ResolvedExpression expression)
Creates a computed column that is computed from the given
ResolvedExpression . |
static WatermarkSpec |
WatermarkSpec.of(String rowtimeAttribute,
ResolvedExpression watermarkExpression) |
Modifier and Type | Method and Description |
---|---|
CallExpression |
ContextResolvedFunction.toCallExpression(List<ResolvedExpression> resolvedArgs,
DataType outputDataType) |
Modifier and Type | Method and Description |
---|---|
List<ResolvedExpression> |
SupportsFilterPushDown.Result.getAcceptedFilters() |
List<ResolvedExpression> |
SupportsFilterPushDown.Result.getRemainingFilters() |
Modifier and Type | Method and Description |
---|---|
SupportsFilterPushDown.Result |
SupportsFilterPushDown.applyFilters(List<ResolvedExpression> filters)
Provides a list of filters in conjunctive form.
|
static SupportsFilterPushDown.Result |
SupportsFilterPushDown.Result.of(List<ResolvedExpression> acceptedFilters,
List<ResolvedExpression> remainingFilters)
Constructs a filter push-down result.
|
static SupportsFilterPushDown.Result |
SupportsFilterPushDown.Result.of(List<ResolvedExpression> acceptedFilters,
List<ResolvedExpression> remainingFilters)
Constructs a filter push-down result.
|
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
Parser.parseSqlExpression(String sqlExpression,
RowType inputRowType,
LogicalType outputType)
Entry point for parsing SQL expressions expressed as a String.
|
Modifier and Type | Method and Description |
---|---|
TypeInferenceUtil.Result |
PlannerTypeInferenceUtil.runTypeInference(UnresolvedCallExpression unresolvedCall,
List<ResolvedExpression> resolvedArgs)
Same behavior as
TypeInferenceUtil#runTypeInference(TypeInference, CallContext) . |
Modifier and Type | Class and Description |
---|---|
class |
AggregateExpression
Resolved and validated expression for calling an aggregate function.
|
class |
CallExpression
Resolved and validated call expression for calling a function.
|
class |
FieldReferenceExpression
A reference to a field in an input.
|
class |
LocalReferenceExpression
Reference to entity local to a certain
QueryOperation . |
class |
TableReferenceExpression
Expression that references another table.
|
class |
TypeLiteralExpression
Expression that wraps
DataType as a literal. |
class |
ValueLiteralExpression
Expression for constant literal values.
|
Modifier and Type | Method and Description |
---|---|
List<ResolvedExpression> |
LocalReferenceExpression.getResolvedChildren() |
List<ResolvedExpression> |
TableReferenceExpression.getResolvedChildren() |
List<ResolvedExpression> |
CallExpression.getResolvedChildren() |
List<ResolvedExpression> |
ValueLiteralExpression.getResolvedChildren() |
List<ResolvedExpression> |
FieldReferenceExpression.getResolvedChildren() |
List<ResolvedExpression> |
ResolvedExpression.getResolvedChildren() |
List<ResolvedExpression> |
AggregateExpression.getResolvedChildren() |
List<ResolvedExpression> |
TypeLiteralExpression.getResolvedChildren() |
Modifier and Type | Method and Description |
---|---|
abstract R |
ResolvedExpressionVisitor.visit(ResolvedExpression other)
For resolved expressions created by the planner.
|
abstract R |
ApiExpressionVisitor.visit(ResolvedExpression other)
For resolved expressions created by the planner.
|
Modifier and Type | Method and Description |
---|---|
static CallExpression |
CallExpression.anonymous(FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
Creates a
CallExpression to an anonymous function that has been declared inline
without a FunctionIdentifier . |
static CallExpression |
CallExpression.permanent(BuiltInFunctionDefinition builtInFunctionDefinition,
List<ResolvedExpression> args,
DataType dataType)
Creates a
CallExpression to a resolved built-in function. |
static CallExpression |
CallExpression.permanent(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
|
CallExpression |
CallExpression.replaceArgs(List<ResolvedExpression> args,
DataType dataType) |
CallExpression |
UnresolvedCallExpression.resolve(List<ResolvedExpression> args,
DataType dataType) |
static CallExpression |
CallExpression.temporary(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
Creates a
CallExpression to a temporary function (potentially shadowing a Catalog function or providing a system function). |
Constructor and Description |
---|
CallExpression(boolean isTemporary,
FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType) |
CallExpression(FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
Deprecated.
|
CallExpression(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
|
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
SqlExpressionResolver.resolveExpression(String sqlExpression,
RowType inputRowType,
LogicalType outputType)
Translates the given SQL expression string or throws a
ValidationException . |
Modifier and Type | Method and Description |
---|---|
List<ResolvedExpression> |
ExpressionResolver.resolve(List<Expression> expressions)
Resolves given expressions with configured set of rules.
|
Modifier and Type | Method and Description |
---|---|
CallExpression |
ExpressionResolver.PostResolverFactory.array(DataType dataType,
ResolvedExpression... expression) |
CallExpression |
ExpressionResolver.PostResolverFactory.as(ResolvedExpression expression,
String alias) |
CallExpression |
ExpressionResolver.PostResolverFactory.cast(ResolvedExpression expression,
DataType dataType) |
CallExpression |
ExpressionResolver.PostResolverFactory.get(ResolvedExpression composite,
ValueLiteralExpression key,
DataType dataType) |
CallExpression |
ExpressionResolver.PostResolverFactory.map(DataType dataType,
ResolvedExpression... expression) |
CallExpression |
ExpressionResolver.PostResolverFactory.row(DataType dataType,
ResolvedExpression... expression) |
CallExpression |
ExpressionResolver.PostResolverFactory.wrappingCall(BuiltInFunctionDefinition definition,
ResolvedExpression expression) |
Modifier and Type | Method and Description |
---|---|
protected abstract T |
ResolvedExpressionDefaultVisitor.defaultMethod(ResolvedExpression expression) |
T |
ResolvedExpressionDefaultVisitor.visit(ResolvedExpression other) |
T |
ApiExpressionDefaultVisitor.visit(ResolvedExpression other) |
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
JoinQueryOperation.getCondition() |
ResolvedExpression |
FilterQueryOperation.getCondition() |
Modifier and Type | Method and Description |
---|---|
List<ResolvedExpression> |
WindowAggregateQueryOperation.getAggregateExpressions() |
List<ResolvedExpression> |
AggregateQueryOperation.getAggregateExpressions() |
List<ResolvedExpression> |
CalculatedQueryOperation.getArguments() |
List<ResolvedExpression> |
WindowAggregateQueryOperation.getGroupingExpressions() |
List<ResolvedExpression> |
AggregateQueryOperation.getGroupingExpressions() |
List<ResolvedExpression> |
SortQueryOperation.getOrder() |
List<ResolvedExpression> |
ProjectQueryOperation.getProjectList() |
List<List<ResolvedExpression>> |
ValuesQueryOperation.getValues() |
List<ResolvedExpression> |
WindowAggregateQueryOperation.getWindowPropertiesExpressions() |
Constructor and Description |
---|
FilterQueryOperation(ResolvedExpression condition,
QueryOperation child) |
JoinQueryOperation(QueryOperation left,
QueryOperation right,
JoinQueryOperation.JoinType joinType,
ResolvedExpression condition,
boolean correlated) |
Modifier and Type | Method and Description |
---|---|
static List<Optional<String>> |
OperationExpressionsUtils.extractNames(List<ResolvedExpression> expressions)
Extracts names from given expressions if they have one.
|
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
ParserImpl.parseSqlExpression(String sqlExpression,
RowType inputRowType,
LogicalType outputType) |
Modifier and Type | Class and Description |
---|---|
class |
RexNodeExpression
Wrapper for a
ResolvedExpression that originated from a RexNode . |
Modifier and Type | Method and Description |
---|---|
protected ResolvedExpression |
DeclarativeExpressionResolver.defaultMethod(Expression expression) |
ResolvedExpression |
CallExpressionResolver.resolve(Expression expression) |
abstract ResolvedExpression |
DeclarativeExpressionResolver.toAccInputExpr(String name,
int localIndex)
When accumulate phase, for inputs.
|
abstract ResolvedExpression |
DeclarativeExpressionResolver.toAggBufferExpr(String name,
int localIndex)
For aggregate buffer.
|
abstract ResolvedExpression |
DeclarativeExpressionResolver.toMergeInputExpr(String name,
int localIndex)
When merge phase, for inputs.
|
static ResolvedExpression |
DeclarativeExpressionResolver.toRexDistinctKey(org.apache.calcite.tools.RelBuilder builder,
String name,
LogicalType t) |
static ResolvedExpression |
DeclarativeExpressionResolver.toRexInputRef(org.apache.calcite.tools.RelBuilder builder,
int i,
LogicalType t) |
Modifier and Type | Method and Description |
---|---|
List<ResolvedExpression> |
RexNodeExpression.getResolvedChildren() |
Modifier and Type | Method and Description |
---|---|
TypeInferenceUtil.Result |
PlannerTypeInferenceUtilImpl.runTypeInference(UnresolvedCallExpression unresolvedCall,
List<ResolvedExpression> resolvedArgs) |
Modifier and Type | Method and Description |
---|---|
protected List<org.apache.calcite.rex.RexNode> |
PushFilterIntoSourceScanRuleBase.convertExpressionToRexNode(List<ResolvedExpression> expressions,
org.apache.calcite.tools.RelBuilder relBuilder) |
protected org.apache.calcite.rex.RexNode |
PushFilterIntoSourceScanRuleBase.createRemainingCondition(org.apache.calcite.tools.RelBuilder relBuilder,
List<ResolvedExpression> expressions,
org.apache.calcite.rex.RexNode[] unconvertedPredicates) |
Modifier and Type | Method and Description |
---|---|
static FunctionDefinition |
ShortcutUtils.unwrapFunctionDefinition(ResolvedExpression expression) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.