org.apache.flink.table.operations

Interface QueryOperation

All Superinterfaces:

Operation

All Known Implementing Classes:

AggregateQueryOperation, CalculatedQueryOperation, DataStreamQueryOperation, DistinctQueryOperation, ExternalQueryOperation, FilterQueryOperation, InternalDataStreamQueryOperation, JoinQueryOperation, PlannerExternalQueryOperation, PlannerQueryOperation, ProjectQueryOperation, RichTableSourceQueryOperation, SetQueryOperation, SortQueryOperation, SourceQueryOperation, TableSourceQueryOperation, ValuesQueryOperation, WindowAggregateQueryOperation

@PublicEvolving
public interface QueryOperation
extends Operation

Base class for representing an operation structure behind a user-facing Table API.

It represents an operation that can be a node of a relational query. It has a schema, that can be used to validate a QueryOperation applied on top of this one.

Method Summary

Modifier and Type	Method and Description
default <T> T	accept(QueryOperationVisitor<T> visitor)
default String	asSerializableString() Returns a string that fully serializes this instance.
List<QueryOperation>	getChildren()
ResolvedSchema	getResolvedSchema() Resolved schema of this operation.

Methods inherited from interface org.apache.flink.table.operations.Operation

asSummaryString

Method Detail

getResolvedSchema

ResolvedSchema getResolvedSchema()

Resolved schema of this operation.

asSerializableString

default String asSerializableString()

Returns a string that fully serializes this instance. The serialized string can be used for storing the query in e.g. a Catalog as a view.

Returns:

detailed string for persisting in a catalog

See Also:

Operation.asSummaryString()

getChildren

List<QueryOperation> getChildren()

accept

default <T> T accept(QueryOperationVisitor<T> visitor)