Uses of Interface
org.apache.flink.table.expressions.ResolvedExpression

Packages that use ResolvedExpression

Package	Description
org.apache.flink.table.connector.format
org.apache.flink.table.connector.source.abilities
org.apache.flink.table.delegation
org.apache.flink.table.expressions
org.apache.flink.table.expressions.resolver
org.apache.flink.table.expressions.utils
org.apache.flink.table.factories
org.apache.flink.table.filesystem
org.apache.flink.table.operations
org.apache.flink.table.operations.utils
org.apache.flink.table.planner
org.apache.flink.table.planner.delegation
org.apache.flink.table.planner.expressions

Uses of ResolvedExpression in org.apache.flink.table.connector.format

Method parameters in org.apache.flink.table.connector.format with type arguments of type ResolvedExpression

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.

Uses of ResolvedExpression in org.apache.flink.table.connector.source.abilities

Methods in org.apache.flink.table.connector.source.abilities that return types with arguments of type ResolvedExpression

Modifier and Type	Method and Description
List<ResolvedExpression>	SupportsFilterPushDown.Result.getAcceptedFilters()
List<ResolvedExpression>	SupportsFilterPushDown.Result.getRemainingFilters()

Method parameters in org.apache.flink.table.connector.source.abilities with type arguments of type ResolvedExpression

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.

Uses of ResolvedExpression in org.apache.flink.table.delegation

Methods in org.apache.flink.table.delegation that return ResolvedExpression

Modifier and Type	Method and Description
ResolvedExpression	Parser.parseSqlExpression(String sqlExpression, TableSchema inputSchema) Entry point for parsing SQL expressions expressed as a String.

Method parameters in org.apache.flink.table.delegation with type arguments of type ResolvedExpression

Modifier and Type	Method and Description
TypeInferenceUtil.Result	PlannerTypeInferenceUtil.runTypeInference(UnresolvedCallExpression unresolvedCall, List<ResolvedExpression> resolvedArgs) Same behavior as TypeInferenceUtil#runTypeInference(TypeInference, CallContext).

Uses of ResolvedExpression in org.apache.flink.table.expressions

Classes in org.apache.flink.table.expressions that implement ResolvedExpression

Modifier and Type	Class and Description
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.

Methods in org.apache.flink.table.expressions that return types with arguments of type ResolvedExpression

Modifier and Type	Method and Description
List<ResolvedExpression>	TableReferenceExpression.getResolvedChildren()
List<ResolvedExpression>	LocalReferenceExpression.getResolvedChildren()
List<ResolvedExpression>	FieldReferenceExpression.getResolvedChildren()
List<ResolvedExpression>	ValueLiteralExpression.getResolvedChildren()
List<ResolvedExpression>	ResolvedExpression.getResolvedChildren()
List<ResolvedExpression>	CallExpression.getResolvedChildren()
List<ResolvedExpression>	TypeLiteralExpression.getResolvedChildren()

Method parameters in org.apache.flink.table.expressions with type arguments of type ResolvedExpression

Modifier and Type	Method and Description
CallExpression	UnresolvedCallExpression.resolve(List<ResolvedExpression> args, DataType dataType)
TypeInferenceUtil.Result	PlannerTypeInferenceUtilImpl.runTypeInference(UnresolvedCallExpression unresolvedCall, List<ResolvedExpression> resolvedArgs)

Constructor parameters in org.apache.flink.table.expressions with type arguments of type ResolvedExpression

Constructor and Description
CallExpression(FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType)
CallExpression(FunctionIdentifier functionIdentifier, FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType)

Uses of ResolvedExpression in org.apache.flink.table.expressions.resolver

Methods in org.apache.flink.table.expressions.resolver that return types with arguments of type ResolvedExpression

Modifier and Type	Method and Description
List<ResolvedExpression>	ExpressionResolver.resolve(List<Expression> expressions) Resolves given expressions with configured set of rules.

Methods in org.apache.flink.table.expressions.resolver with parameters of type ResolvedExpression

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)

Uses of ResolvedExpression in org.apache.flink.table.expressions.utils

Methods in org.apache.flink.table.expressions.utils with parameters of type ResolvedExpression

Modifier and Type	Method and Description
protected abstract T	ResolvedExpressionDefaultVisitor.defaultMethod(ResolvedExpression expression)

Uses of ResolvedExpression in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return types with arguments of type ResolvedExpression

Modifier and Type	Method and Description
List<ResolvedExpression>	FileSystemFormatFactory.ReaderContext.getPushedDownFilters() Pushed down filters, reader can try its best to filter records.

Uses of ResolvedExpression in org.apache.flink.table.filesystem

Method parameters in org.apache.flink.table.filesystem with type arguments of type ResolvedExpression

Modifier and Type	Method and Description
SupportsFilterPushDown.Result	FileSystemTableSource.applyFilters(List<ResolvedExpression> filters)

Uses of ResolvedExpression in org.apache.flink.table.operations

Methods in org.apache.flink.table.operations that return ResolvedExpression

Modifier and Type	Method and Description
ResolvedExpression	JoinQueryOperation.getCondition()
ResolvedExpression	FilterQueryOperation.getCondition()

Methods in org.apache.flink.table.operations that return types with arguments of type ResolvedExpression

Modifier and Type	Method and Description
List<ResolvedExpression>	AggregateQueryOperation.getAggregateExpressions()
List<ResolvedExpression>	WindowAggregateQueryOperation.getAggregateExpressions()
List<ResolvedExpression>	CalculatedQueryOperation.getArguments()
List<ResolvedExpression>	AggregateQueryOperation.getGroupingExpressions()
List<ResolvedExpression>	WindowAggregateQueryOperation.getGroupingExpressions()
List<ResolvedExpression>	SortQueryOperation.getOrder()
List<ResolvedExpression>	ProjectQueryOperation.getProjectList()
List<List<ResolvedExpression>>	ValuesQueryOperation.getValues()
List<ResolvedExpression>	WindowAggregateQueryOperation.getWindowPropertiesExpressions()

Constructors in org.apache.flink.table.operations with parameters of type ResolvedExpression

Constructor and Description
FilterQueryOperation(ResolvedExpression condition, QueryOperation child)
JoinQueryOperation(QueryOperation left, QueryOperation right, JoinQueryOperation.JoinType joinType, ResolvedExpression condition, boolean correlated)

Constructor parameters in org.apache.flink.table.operations with type arguments of type ResolvedExpression

Constructor and Description
AggregateQueryOperation(List<ResolvedExpression> groupingExpressions, List<ResolvedExpression> aggregateExpressions, QueryOperation child, TableSchema tableSchema)
AggregateQueryOperation(List<ResolvedExpression> groupingExpressions, List<ResolvedExpression> aggregateExpressions, QueryOperation child, TableSchema tableSchema)
CalculatedQueryOperation(FunctionDefinition functionDefinition, FunctionIdentifier functionIdentifier, List<ResolvedExpression> arguments, TableSchema tableSchema)
ProjectQueryOperation(List<ResolvedExpression> projectList, QueryOperation child, TableSchema tableSchema)
SortQueryOperation(List<ResolvedExpression> order, QueryOperation child)
SortQueryOperation(List<ResolvedExpression> order, QueryOperation child, int offset, int fetch)
ValuesQueryOperation(List<List<ResolvedExpression>> values, TableSchema tableSchema)
WindowAggregateQueryOperation(List<ResolvedExpression> groupingExpressions, List<ResolvedExpression> aggregateExpressions, List<ResolvedExpression> windowPropertiesExpressions, WindowAggregateQueryOperation.ResolvedGroupWindow groupWindow, QueryOperation child, TableSchema tableSchema)
WindowAggregateQueryOperation(List<ResolvedExpression> groupingExpressions, List<ResolvedExpression> aggregateExpressions, List<ResolvedExpression> windowPropertiesExpressions, WindowAggregateQueryOperation.ResolvedGroupWindow groupWindow, QueryOperation child, TableSchema tableSchema)
WindowAggregateQueryOperation(List<ResolvedExpression> groupingExpressions, List<ResolvedExpression> aggregateExpressions, List<ResolvedExpression> windowPropertiesExpressions, WindowAggregateQueryOperation.ResolvedGroupWindow groupWindow, QueryOperation child, TableSchema tableSchema)

Uses of ResolvedExpression in org.apache.flink.table.operations.utils

Method parameters in org.apache.flink.table.operations.utils with type arguments of type ResolvedExpression

Modifier and Type	Method and Description
static List<Optional<String>>	OperationExpressionsUtils.extractNames(List<ResolvedExpression> expressions) Extracts names from given expressions if they have one.

Uses of ResolvedExpression in org.apache.flink.table.planner

Methods in org.apache.flink.table.planner that return ResolvedExpression

Modifier and Type	Method and Description
ResolvedExpression	ParserImpl.parseSqlExpression(String sqlExpression, TableSchema inputSchema)

Uses of ResolvedExpression in org.apache.flink.table.planner.delegation

Methods in org.apache.flink.table.planner.delegation that return ResolvedExpression

Modifier and Type	Method and Description
ResolvedExpression	ParserImpl.parseSqlExpression(String sqlExpression, TableSchema inputSchema)

Uses of ResolvedExpression in org.apache.flink.table.planner.expressions

Classes in org.apache.flink.table.planner.expressions that implement ResolvedExpression

Modifier and Type	Class and Description
class	RexNodeExpression Dummy wrapper for expressions that were converted to RexNode in a different way.

Methods in org.apache.flink.table.planner.expressions that return ResolvedExpression

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)

Methods in org.apache.flink.table.planner.expressions that return types with arguments of type ResolvedExpression

Modifier and Type	Method and Description
List<ResolvedExpression>	RexNodeExpression.getResolvedChildren()

Method parameters in org.apache.flink.table.planner.expressions with type arguments of type ResolvedExpression

Modifier and Type	Method and Description
TypeInferenceUtil.Result	PlannerTypeInferenceUtilImpl.runTypeInference(UnresolvedCallExpression unresolvedCall, List<ResolvedExpression> resolvedArgs)