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

Packages that use Expression

Package	Description
org.apache.flink.table.api
org.apache.flink.table.api.internal
org.apache.flink.table.catalog
org.apache.flink.table.expressions

Uses of Expression in org.apache.flink.table.api

Classes in org.apache.flink.table.api that implement Expression

Modifier and Type	Class	Description
final class	ApiExpression	Java API class that gives access to expression operations.

Methods in org.apache.flink.table.api that return Expression

Modifier and Type	Method	Description
Expression	GroupWindow.getAlias()
Expression	OverWindow.getAlias()
Expression	Schema.UnresolvedComputedColumn.getExpression()
Expression	SessionWithGapOnTimeWithAlias.getGap()
Expression	OverWindow.getOrder()
Expression	SlideWithSizeAndSlideOnTimeWithAlias.getSize()
Expression	TumbleWithSizeOnTimeWithAlias.getSize()
Expression	SlideWithSizeAndSlideOnTimeWithAlias.getSlide()
Expression	GroupWindow.getTimeField()
Expression	Schema.UnresolvedWatermarkSpec.getWatermarkExpression()
Expression	ApiExpression.toExpr()

Methods in org.apache.flink.table.api that return types with arguments of type Expression

Modifier and Type	Method	Description
List<Expression>	ApiExpression.getChildren()
Optional<Expression>	OverWindow.getFollowing()
List<Expression>	OverWindow.getPartitioning()
Optional<Expression>	OverWindow.getPreceding()

Methods in org.apache.flink.table.api with parameters of type Expression

Modifier and Type	Method	Description
Table	Table.addColumns(Expression... fields)	Adds additional columns.
Table	Table.addOrReplaceColumns(Expression... fields)	Adds additional columns.
AggregatedTable	GroupedTable.aggregate(Expression aggregateFunction)	Performs an aggregate operation with an aggregate function.
AggregatedTable	Table.aggregate(Expression aggregateFunction)	Performs a global aggregate operation with an aggregate function.
AggregatedTable	WindowGroupedTable.aggregate(Expression aggregateFunction)	Performs an aggregate operation on a window grouped table.
OverWindow	OverWindowPartitionedOrdered.as(Expression alias)	Assigns an alias for this window that the following select() clause can refer to.
OverWindow	OverWindowPartitionedOrderedPreceding.as(Expression alias)	Assigns an alias for this window that the following select() clause can refer to.
SessionWithGapOnTimeWithAlias	SessionWithGapOnTime.as(Expression alias)	Assigns an alias for this window that the following groupBy() and select() clause can refer to.
SlideWithSizeAndSlideOnTimeWithAlias	SlideWithSizeAndSlideOnTime.as(Expression alias)	Assigns an alias for this window that the following groupBy() and select() clause can refer to.
Table	Table.as(Expression... fields)	Deprecated. use Table.as(String, String...)
TumbleWithSizeOnTimeWithAlias	TumbleWithSizeOnTime.as(Expression alias)	Assigns an alias for this window that the following groupBy() and select() clause can refer to.
Schema.Builder	Schema.Builder.columnByExpression(String columnName, Expression expression)	Declares a computed column that is appended to this schema.
TemporalTableFunction	Table.createTemporalTableFunction(Expression timeAttribute, Expression primaryKey)	Creates TemporalTableFunction backed up by this table as a history table.
Table	Table.dropColumns(Expression... fields)	Drops existing columns.
SlideWithSizeAndSlide	SlideWithSize.every(Expression slide)	Specifies the window's slide as time or row-count interval.
Table	Table.filter(Expression predicate)	Filters out elements that don't pass the filter predicate.
FlatAggregateTable	GroupedTable.flatAggregate(Expression tableAggFunction)	Performs a flatAggregate operation on a grouped table.
FlatAggregateTable	Table.flatAggregate(Expression tableAggregateFunction)	Perform a global flatAggregate without groupBy.
FlatAggregateTable	WindowGroupedTable.flatAggregate(Expression tableAggregateFunction)	Performs a flatAggregate operation on a window grouped table.
Table	Table.flatMap(Expression tableFunction)	Performs a flatMap operation with an user-defined table function or built-in table function.
OverWindowPartitionedOrderedPreceding	OverWindowPartitionedOrderedPreceding.following(Expression following)	Set the following offset (based on time or row-count intervals) for over window.
Table	Table.fromChangelog(Expression... arguments)	Converts this append-only table with an explicit operation code column into a (potentially updating) dynamic table.
Table	TableEnvironment.fromValues(Expression... values)	Creates a Table from given values.
Table	TableEnvironment.fromValues(AbstractDataType<?> rowType, Expression... values)	Creates a Table from given collection of objects with a given row type.
Table	Table.fullOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
WindowGroupedTable	GroupWindowedTable.groupBy(Expression... fields)	Groups the elements by a mandatory window and one or more optional grouping attributes.
GroupedTable	Table.groupBy(Expression... fields)	Groups the elements on some grouping keys.
Table	Table.join(Table right, Expression joinPredicate)	Joins two Tables.
Table	Table.joinLateral(Expression tableFunctionCall)	Joins this Table with an user-defined TableFunction.
Table	Table.joinLateral(Expression tableFunctionCall, Expression joinPredicate)	Joins this Table with an user-defined TableFunction.
Table	Table.leftOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
Table	Table.leftOuterJoinLateral(Expression tableFunctionCall)	Joins this Table with an user-defined TableFunction.
Table	Table.leftOuterJoinLateral(Expression tableFunctionCall, Expression joinPredicate)	Joins this Table with an user-defined TableFunction.
Table	Table.map(Expression mapFunction)	Performs a map operation with an user-defined scalar function or built-in scalar function.
SessionWithGapOnTime	SessionWithGap.on(Expression timeField)	Specifies the time attribute on which rows are grouped.
SlideWithSizeAndSlideOnTime	SlideWithSizeAndSlide.on(Expression timeField)	Specifies the time attribute on which rows are grouped.
TumbleWithSizeOnTime	TumbleWithSize.on(Expression timeField)	Specifies the time attribute on which rows are grouped.
static OverWindowPartitionedOrdered	Over.orderBy(Expression orderBy)	Specifies the time attribute on which rows are ordered.
OverWindowPartitionedOrdered	OverWindowPartitioned.orderBy(Expression orderBy)	Specifies the time attribute on which rows are ordered.
PartitionedTable	PartitionedTable.orderBy(Expression... fields)	Sorts the partitioned table within each partition.
Table	Table.orderBy(Expression... fields)	Sorts the given Table.
static SlideWithSize	Slide.over(Expression size)	Creates a sliding window.
static TumbleWithSize	Tumble.over(Expression size)	Creates a tumbling window.
static OverWindowPartitioned	Over.partitionBy(Expression... partitionBy)	Partitions the elements on some partition keys.
PartitionedTable	Table.partitionBy(Expression... fields)	Partitions the table by a set of partition keys.
OverWindowPartitionedOrderedPreceding	OverWindowPartitionedOrdered.preceding(Expression preceding)	Set the preceding offset (based on time or row-count intervals) for over window.
Table	Table.renameColumns(Expression... fields)	Renames existing columns.
Table	Table.rightOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
Table	AggregatedTable.select(Expression... fields)	Performs a selection operation after an aggregate operation.
Table	FlatAggregateTable.select(Expression... fields)	Performs a selection operation on a FlatAggregateTable table.
Table	GroupedTable.select(Expression... fields)	Performs a selection operation on a grouped table.
Table	OverWindowedTable.select(Expression... fields)	Performs a selection operation on a over windowed table.
Table	Table.select(Expression... fields)	Performs a selection operation.
Table	WindowGroupedTable.select(Expression... fields)	Performs a selection operation on a window grouped table.
protected ApiExpression	ApiExpression.toApiSpecificExpression(Expression expression)
Table	Table.toChangelog(Expression... arguments)	Converts this dynamic table into an append-only table with an explicit operation code column using the built-in TO_CHANGELOG process table function.
Schema.Builder	Schema.Builder.watermark(String columnName, Expression watermarkExpression)	Declares that the given column should serve as an event-time (i.e. rowtime) attribute and specifies a corresponding watermark strategy as an expression.
Table	Table.where(Expression predicate)	Filters out elements that don't pass the filter predicate.
static SessionWithGap	Session.withGap(Expression gap)	Creates a session window.

Constructors in org.apache.flink.table.api with parameters of type Expression

Modifier	Constructor	Description
	ApiExpression(Expression wrappedExpression)
	UnresolvedComputedColumn(String columnName, Expression expression)
	UnresolvedComputedColumn(String columnName, Expression expression, String comment)
	UnresolvedWatermarkSpec(String columnName, Expression watermarkExpression)

Uses of Expression in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal that return Expression

Modifier and Type	Method	Description
protected abstract Expression	BaseExpressions.toExpr()

Methods in org.apache.flink.table.api.internal with parameters of type Expression

Modifier and Type	Method	Description
protected abstract OutType	BaseExpressions.toApiSpecificExpression(Expression expression)

Uses of Expression in org.apache.flink.table.catalog

Method parameters in org.apache.flink.table.catalog with type arguments of type Expression

Modifier and Type	Method	Description
List<org.apache.flink.table.catalog.CatalogPartitionSpec>	Catalog.listPartitionsByFilter(org.apache.flink.table.catalog.ObjectPath tablePath, List<Expression> filters)	Get CatalogPartitionSpec of partitions by expression filters in the table.

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

Subinterfaces of Expression in org.apache.flink.table.expressions

Modifier and Type	Interface	Description
interface	ResolvedExpression	Expression that has been fully resolved and validated.

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

Modifier and Type	Class	Description
final class	SqlCallExpression	A call to a SQL expression.

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

Modifier and Type	Method	Description
List<Expression>	Expression.getChildren()
List<Expression>	SqlCallExpression.getChildren()

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

Modifier and Type	Method	Description
R	ExpressionVisitor.visit(Expression other)