Package org.apache.iceberg.flink.util

Class FlinkAlterTableUtil

  • public class FlinkAlterTableUtil
extends java.lang.Object

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void applyPropertyChanges​(UpdateProperties pendingUpdate, java.util.List<org.apache.flink.table.catalog.TableChange> propertyChanges)
      Applies a list of Flink table property changes to an UpdateProperties operation.
      static void applySchemaChanges​(UpdateSchema pendingUpdate, java.util.List<org.apache.flink.table.catalog.TableChange> schemaChanges)
      Applies a list of Flink table changes to an UpdateSchema operation.
      static void commitChanges​(Table table, java.lang.String setLocation, java.lang.String setSnapshotId, java.lang.String pickSnapshotId, java.util.List<org.apache.flink.table.catalog.TableChange> schemaChanges, java.util.List<org.apache.flink.table.catalog.TableChange> propertyChanges)  
      static void commitChanges​(Table table, java.lang.String setLocation, java.lang.String setSnapshotId, java.lang.String pickSnapshotId, java.util.Map<java.lang.String,​java.lang.String> setProperties)  
      static void commitManageSnapshots​(Table table, java.lang.String setSnapshotId, java.lang.String cherrypickSnapshotId)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • commitChanges

        public static void commitChanges​(Table table,
                                 java.lang.String setLocation,
                                 java.lang.String setSnapshotId,
                                 java.lang.String pickSnapshotId,
                                 java.util.Map<java.lang.String,​java.lang.String> setProperties)

      • commitChanges

        public static void commitChanges​(Table table,
                                 java.lang.String setLocation,
                                 java.lang.String setSnapshotId,
                                 java.lang.String pickSnapshotId,
                                 java.util.List<org.apache.flink.table.catalog.TableChange> schemaChanges,
                                 java.util.List<org.apache.flink.table.catalog.TableChange> propertyChanges)

      • commitManageSnapshots

        public static void commitManageSnapshots​(Table table,
                                         java.lang.String setSnapshotId,
                                         java.lang.String cherrypickSnapshotId)

      • applySchemaChanges

        public static void applySchemaChanges​(UpdateSchema pendingUpdate,
                                      java.util.List<org.apache.flink.table.catalog.TableChange> schemaChanges)
        Applies a list of Flink table changes to an UpdateSchema operation.
        Parameters:
        pendingUpdate - an uncommitted UpdateSchema operation to configure
        schemaChanges - a list of Flink table changes

      • applyPropertyChanges

        public static void applyPropertyChanges​(UpdateProperties pendingUpdate,
                                        java.util.List<org.apache.flink.table.catalog.TableChange> propertyChanges)
        Applies a list of Flink table property changes to an UpdateProperties operation.
        Parameters:
        pendingUpdate - an uncommitted UpdateProperty operation to configure
        propertyChanges - a list of Flink table changes