org.apache.iceberg.flink

Class IcebergTableSource

java.lang.Object

org.apache.iceberg.flink.IcebergTableSource

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 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

Flink Iceberg table source.

Nested Class Summary

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

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergTableSource

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)

Method Detail

applyProjection

public void applyProjection(int[][] projectFields)

Specified by:

applyProjection in interface org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown

applyLimit

public void applyLimit(long newLimit)

Specified by:

applyLimit in interface org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown

applyFilters

public org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown.Result applyFilters(java.util.List<org.apache.flink.table.expressions.ResolvedExpression> flinkFilters)

Specified by:

applyFilters in interface org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown

supportsNestedProjection

public boolean supportsNestedProjection()

Specified by:

supportsNestedProjection in interface org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown

getChangelogMode

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

Specified by:

getChangelogMode in interface org.apache.flink.table.connector.source.ScanTableSource

getScanRuntimeProvider

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

Specified by:

getScanRuntimeProvider in interface org.apache.flink.table.connector.source.ScanTableSource

copy

public org.apache.flink.table.connector.source.DynamicTableSource copy()

Specified by:

copy in interface org.apache.flink.table.connector.source.DynamicTableSource

asSummaryString

public java.lang.String asSummaryString()

Specified by:

asSummaryString in interface org.apache.flink.table.connector.source.DynamicTableSource