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>
ATableSourceQueryOperation
withFlinkStatistic
and qualifiedName. TODO this class should be deleted after unique key in TableSchema is ready and setting catalog statistic to TableSourceTable in DatabaseCalciteSchema is readyThis is only used for testing.
-
-
Constructor Summary
Constructors Constructor Description RichTableSourceQueryOperation(ObjectIdentifier identifier, TableSource<T> tableSource, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 interfaceOperation
- Overrides:
asSummaryString
in classTableSourceQueryOperation<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()
-
-