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