public class SystemTableSource extends FlinkTableSource
FlinkTableSource
for system table.org.apache.flink.table.connector.source.ScanTableSource.ScanContext, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider
limit, predicate, projectFields
Constructor and Description |
---|
SystemTableSource(Table table,
boolean isStreamingMode) |
SystemTableSource(Table table,
boolean isStreamingMode,
Predicate predicate,
int[][] projectFields,
Long limit) |
Modifier and Type | Method and Description |
---|---|
String |
asSummaryString() |
org.apache.flink.table.connector.source.DynamicTableSource |
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) |
applyFilters, applyLimit, applyProjection, supportsNestedProjection
public SystemTableSource(Table table, boolean isStreamingMode)
public org.apache.flink.table.connector.ChangelogMode getChangelogMode()
public org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext scanContext)
public org.apache.flink.table.connector.source.DynamicTableSource copy()
public String asSummaryString()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.