org.apache.iceberg.flink.util

Class FlinkAlterTableUtil

java.lang.Object

org.apache.iceberg.flink.util.FlinkAlterTableUtil

public class FlinkAlterTableUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and 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