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

    @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
      • 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
      • Methods inherited from interface org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown

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