org.apache.flink.table.planner.operations

Class RichTableSourceQueryOperation<T>

java.lang.Object

org.apache.flink.table.operations.TableSourceQueryOperation<T>

org.apache.flink.table.planner.operations.RichTableSourceQueryOperation<T>

All Implemented Interfaces:

Operation, QueryOperation

@Internal
public class RichTableSourceQueryOperation<T>
extends TableSourceQueryOperation<T>

A TableSourceQueryOperation with FlinkStatistic and qualifiedName. TODO this class should be deleted after unique key in TableSchema is ready and setting catalog statistic to TableSourceTable in DatabaseCalciteSchema is ready

This is only used for testing.

Constructor Summary

Constructors

Constructor and Description
RichTableSourceQueryOperation(ObjectIdentifier identifier, TableSource<T> tableSource, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

Method Summary

Modifier and Type	Method and Description
String	asSummaryString() Returns a string that summarizes this operation for printing to a console.
ObjectIdentifier	getIdentifier()
org.apache.flink.table.planner.plan.stats.FlinkStatistic	getStatistic()

Methods inherited from class org.apache.flink.table.operations.TableSourceQueryOperation

accept, getChildren, getResolvedSchema, getTableSource, isBatch

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

asSerializableString

Constructor Detail

RichTableSourceQueryOperation

public RichTableSourceQueryOperation(ObjectIdentifier identifier,
                                     TableSource<T> tableSource,
                                     org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

Method Detail

asSummaryString

public String asSummaryString()

Description copied from interface: Operation

Returns a string that summarizes this operation for printing to a console. An implementation might skip very specific properties.

Specified by:

asSummaryString in interface Operation

Overrides:

asSummaryString in class TableSourceQueryOperation<T>

Returns:

summary string of this operation for debugging purposes

getIdentifier

public ObjectIdentifier getIdentifier()

getStatistic

public org.apache.flink.table.planner.plan.stats.FlinkStatistic getStatistic()