Package org.apache.iceberg.flink

Class 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.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.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.abilities.SupportsFilterPushDown

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

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

      • 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