@Internal
public class IcebergTableSource
extends java.lang.Object
implements org.apache.flink.table.connector.source.ScanTableSource, org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown, org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown, org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown
org.apache.flink.table.connector.source.ScanTableSource.ScanContext, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider
Constructor and Description |
---|
IcebergTableSource(TableLoader loader,
org.apache.flink.table.api.TableSchema schema,
java.util.Map<java.lang.String,java.lang.String> properties,
org.apache.flink.configuration.ReadableConfig readableConfig) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown.Result |
applyFilters(java.util.List<org.apache.flink.table.expressions.ResolvedExpression> flinkFilters) |
void |
applyLimit(long newLimit) |
void |
applyProjection(int[][] projectFields) |
java.lang.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 runtimeProviderContext) |
boolean |
supportsNestedProjection() |
public IcebergTableSource(TableLoader loader, org.apache.flink.table.api.TableSchema schema, java.util.Map<java.lang.String,java.lang.String> properties, org.apache.flink.configuration.ReadableConfig readableConfig)
public void applyProjection(int[][] projectFields)
applyProjection
in interface org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown
public void applyLimit(long newLimit)
applyLimit
in interface org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown
public org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown.Result applyFilters(java.util.List<org.apache.flink.table.expressions.ResolvedExpression> flinkFilters)
applyFilters
in interface org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown
public boolean supportsNestedProjection()
supportsNestedProjection
in interface org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown
public org.apache.flink.table.connector.ChangelogMode getChangelogMode()
getChangelogMode
in interface org.apache.flink.table.connector.source.ScanTableSource
public org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext runtimeProviderContext)
getScanRuntimeProvider
in interface org.apache.flink.table.connector.source.ScanTableSource
public org.apache.flink.table.connector.source.DynamicTableSource copy()
copy
in interface org.apache.flink.table.connector.source.DynamicTableSource
public java.lang.String asSummaryString()
asSummaryString
in interface org.apache.flink.table.connector.source.DynamicTableSource