Package org.apache.iceberg.flink

Class IcebergTableSink

  • All Implemented Interfaces:
    org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning, org.apache.flink.table.connector.sink.DynamicTableSink
    public class IcebergTableSink
extends java.lang.Object
implements org.apache.flink.table.connector.sink.DynamicTableSink, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.table.connector.sink.DynamicTableSink

        org.apache.flink.table.connector.sink.DynamicTableSink.Context, org.apache.flink.table.connector.sink.DynamicTableSink.DataStructureConverter, org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider

    • Constructor Summary

      Constructors 
      Constructor Description
      IcebergTableSink​(TableLoader tableLoader, org.apache.flink.table.api.TableSchema tableSchema, org.apache.flink.configuration.ReadableConfig readableConfig, java.util.Map<java.lang.String,​java.lang.String> writeProps)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void applyOverwrite​(boolean newOverwrite)  
      void applyStaticPartition​(java.util.Map<java.lang.String,​java.lang.String> partition)  
      java.lang.String asSummaryString()  
      org.apache.flink.table.connector.sink.DynamicTableSink copy()  
      org.apache.flink.table.connector.ChangelogMode getChangelogMode​(org.apache.flink.table.connector.ChangelogMode requestedMode)  
      org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider​(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)  

      • 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.sink.abilities.SupportsPartitioning

        requiresPartitionGrouping

    • Constructor Detail

      • IcebergTableSink

        public IcebergTableSink​(TableLoader tableLoader,
                        org.apache.flink.table.api.TableSchema tableSchema,
                        org.apache.flink.configuration.ReadableConfig readableConfig,
                        java.util.Map<java.lang.String,​java.lang.String> writeProps)

    • Method Detail

      • getSinkRuntimeProvider

        public org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider​(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)
        Specified by:
        getSinkRuntimeProvider in interface org.apache.flink.table.connector.sink.DynamicTableSink

      • applyStaticPartition

        public void applyStaticPartition​(java.util.Map<java.lang.String,​java.lang.String> partition)
        Specified by:
        applyStaticPartition in interface org.apache.flink.table.connector.sink.abilities.SupportsPartitioning

      • getChangelogMode

        public org.apache.flink.table.connector.ChangelogMode getChangelogMode​(org.apache.flink.table.connector.ChangelogMode requestedMode)
        Specified by:
        getChangelogMode in interface org.apache.flink.table.connector.sink.DynamicTableSink

      • copy

        public org.apache.flink.table.connector.sink.DynamicTableSink copy()
        Specified by:
        copy in interface org.apache.flink.table.connector.sink.DynamicTableSink

      • asSummaryString

        public java.lang.String asSummaryString()
        Specified by:
        asSummaryString in interface org.apache.flink.table.connector.sink.DynamicTableSink

      • applyOverwrite

        public void applyOverwrite​(boolean newOverwrite)
        Specified by:
        applyOverwrite in interface org.apache.flink.table.connector.sink.abilities.SupportsOverwrite