Package org.apache.flink.table.operations

Interface Summary

Interface	Description
ModifyOperation	A Operation that describes the DML queries such as e.g.
ModifyOperationVisitor<T>	Class that implements visitor pattern.
Operation	Covers all sort of Table operations such as queries(DQL), modifications(DML), definitions(DDL), or control actions(DCL).
QueryOperation	Base class for representing an operation structure behind a user-facing Table API.
QueryOperationVisitor<T>	Class that implements visitor pattern.
ShowOperation	An Operation that show one kind of objects, e.g.
UseOperation	An Operation that describes the catalog/database switch statements, e.g.

Class Summary

Class	Description
AggregateQueryOperation	Relational operation that performs computations on top of subsets of input rows grouped by key.
CalculatedQueryOperation	Describes a relational operation that was created from applying a TableFunction.
CatalogQueryOperation	Describes a relational operation that was created from a lookup to a catalog.
CatalogSinkModifyOperation	DML operation that tells to write to a sink.
DataSetQueryOperation<E>	Describes a relational operation that reads from a DataSet.
DescribeTableOperation	Operation to describe a DESCRIBE [EXTENDED] [[catalogName.] dataBasesName].sqlIdentifier statement.
DistinctQueryOperation	Removes duplicated rows of underlying relational operation.
ExplainOperation	Operation to describe an EXPLAIN statement.
FilterQueryOperation	Filters out rows of underlying relational operation that do not match given condition.
JavaDataStreamQueryOperation<E>	Describes a relational operation that reads from a DataStream.
JoinQueryOperation	Table operation that joins two relational operations based on given condition.
OperationUtils	Helper methods for Operations.
OutputConversionModifyOperation	Special, internal kind of ModifyOperation that allows converting a tree of QueryOperations to a Transformation of given type described with TypeInformation.
ProjectQueryOperation	Table operation that computes new table using given Expressions from its input relational operation.
ScalaDataStreamQueryOperation<E>	Describes a relational operation that reads from a DataStream.
SelectSinkOperation	Special, internal kind of ModifyOperation that collects the content of QueryOperation to local.
SetQueryOperation	A set operation on two relations.
ShowCatalogsOperation	Operation to describe a SHOW CATALOGS statement.
ShowCurrentCatalogOperation	Operation to describe a SHOW CURRENT CATALOG statement.
ShowCurrentDatabaseOperation	Operation to describe SHOW CURRENT DATABASE operation.
ShowDatabasesOperation	Operation to describe a SHOW DATABASES statement.
ShowFunctionsOperation	Operation to describe a SHOW FUNCTIONS statement.
ShowPartitionsOperation	Operation to describe a SHOW PARTITIONS statement.
ShowTablesOperation	Operation to describe a SHOW TABLES statement.
ShowViewsOperation	Operation to describe a SHOW VIEWS statement.
SortQueryOperation	Expresses sort operation of rows of the underlying relational operation with given order.
TableSourceQueryOperation<T>	Inline scan of a TableSource.
UnregisteredSinkModifyOperation<T>	DML operation that tells to write to the given sink.
UseCatalogOperation	Operation to describe a USE CATALOG statement.
UseDatabaseOperation	Operation to describe a USE [catalogName.]dataBaseName statement.
ValuesQueryOperation	Table operation that computes new table using given Expressions from its input relational operation.
WindowAggregateQueryOperation	Relational operation that performs computations on top of subsets of input rows grouped by key and group window.
WindowAggregateQueryOperation.ResolvedGroupWindow	Wrapper for resolved expressions of a GroupWindow.

Enum Summary

Enum	Description
JoinQueryOperation.JoinType	Specifies how the two Tables should be joined.
OutputConversionModifyOperation.UpdateMode	Should the output type contain the change flag, and what should the flag represent (retraction or deletion).
SetQueryOperation.SetQueryOperationType	Represent kind of this set operation.
WindowAggregateQueryOperation.ResolvedGroupWindow.WindowType	The type of window.