org.apache.paimon.flink.source

Class SystemTableSource

java.lang.Object

org.apache.paimon.flink.source.FlinkTableSource

org.apache.paimon.flink.source.SystemTableSource

All Implemented Interfaces:

org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown, org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown, org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown, org.apache.flink.table.connector.source.DynamicTableSource, org.apache.flink.table.connector.source.ScanTableSource

public class SystemTableSource
extends FlinkTableSource

A FlinkTableSource for system table.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.flink.source.FlinkTableSource

FlinkTableSource.SplitStatistics

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.ScanTableSource

org.apache.flink.table.connector.source.ScanTableSource.ScanContext, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.DynamicTableSource

org.apache.flink.table.connector.source.DynamicTableSource.Context, org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown

org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown.Result

Field Summary

Fields inherited from class org.apache.paimon.flink.source.FlinkTableSource

FLINK_INFER_SCAN_PARALLELISM, limit, predicate, projectFields, splitStatistics, table

Constructor Summary

Constructors

Constructor and Description
SystemTableSource(Table table, boolean isStreamingMode, org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)
SystemTableSource(Table table, boolean isStreamingMode, Predicate predicate, int[][] projectFields, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)

Method Summary

Modifier and Type	Method and Description
String	asSummaryString()
SystemTableSource	copy()
org.apache.flink.table.connector.ChangelogMode	getChangelogMode()
org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider	getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext scanContext)
boolean	isStreaming()

Methods inherited from class org.apache.paimon.flink.source.FlinkTableSource

applyFilters, applyLimit, applyProjection, getTable, inferSourceParallelism, scanSplitsForInference, supportsNestedProjection

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.connector.source.abilities.SupportsProjectionPushDown

applyProjection

Constructor Detail

SystemTableSource

public SystemTableSource(Table table,
                         boolean isStreamingMode,
                         org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)

SystemTableSource

public SystemTableSource(Table table,
                         boolean isStreamingMode,
                         @Nullable
                         Predicate predicate,
                         @Nullable
                         int[][] projectFields,
                         @Nullable
                         Long limit,
                         int splitBatchSize,
                         FlinkConnectorOptions.SplitAssignMode splitAssignMode,
                         org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)

Method Detail

getChangelogMode

public org.apache.flink.table.connector.ChangelogMode getChangelogMode()

getScanRuntimeProvider

public org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext scanContext)

copy

public SystemTableSource copy()

asSummaryString

public String asSummaryString()

isStreaming

public boolean isStreaming()

Specified by:

isStreaming in class FlinkTableSource