Package org.apache.iceberg.flink.source
Class IcebergTableSource
- java.lang.Object
-
- org.apache.iceberg.flink.source.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
@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
Flink Iceberg table source.
-
-
Nested Class Summary
-
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
-
-
Constructor Summary
Constructors Constructor 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
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
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 interfaceorg.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown
-
applyLimit
public void applyLimit(long newLimit)
- Specified by:
applyLimit
in interfaceorg.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 interfaceorg.apache.flink.table.connector.source.abilities.SupportsFilterPushDown
-
supportsNestedProjection
public boolean supportsNestedProjection()
- Specified by:
supportsNestedProjection
in interfaceorg.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown
-
getChangelogMode
public org.apache.flink.table.connector.ChangelogMode getChangelogMode()
- Specified by:
getChangelogMode
in interfaceorg.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 interfaceorg.apache.flink.table.connector.source.ScanTableSource
-
copy
public org.apache.flink.table.connector.source.DynamicTableSource copy()
- Specified by:
copy
in interfaceorg.apache.flink.table.connector.source.DynamicTableSource
-
asSummaryString
public java.lang.String asSummaryString()
- Specified by:
asSummaryString
in interfaceorg.apache.flink.table.connector.source.DynamicTableSource
-
-