Package org.apache.beam.sdk.extensions.sql.meta.provider.iceberg

Class IcebergAlterTableOps

  • All Implemented Interfaces:
    org.apache.beam.sdk.extensions.sql.meta.provider.AlterTableOps
    public class IcebergAlterTableOps
extends java.lang.Object
implements org.apache.beam.sdk.extensions.sql.meta.provider.AlterTableOps
    AlterTableOps for Iceberg tables.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void updatePartitionSpec​(java.util.List<java.lang.String> partitionsToAdd, java.util.Collection<java.lang.String> partitionsToDrop)  
      void updateSchema​(java.util.List<org.apache.beam.sdk.schemas.Schema.Field> columnsToAdd, java.util.Collection<java.lang.String> columnsToDrop)  
      void updateTableProperties​(java.util.Map<java.lang.String,​java.lang.String> setProps, java.util.List<java.lang.String> resetProps)  

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • updateTableProperties

        public void updateTableProperties​(java.util.Map<java.lang.String,​java.lang.String> setProps,
                                  java.util.List<java.lang.String> resetProps)
        Specified by:
        updateTableProperties in interface org.apache.beam.sdk.extensions.sql.meta.provider.AlterTableOps

      • updateSchema

        public void updateSchema​(java.util.List<org.apache.beam.sdk.schemas.Schema.Field> columnsToAdd,
                         java.util.Collection<java.lang.String> columnsToDrop)
        Specified by:
        updateSchema in interface org.apache.beam.sdk.extensions.sql.meta.provider.AlterTableOps

      • updatePartitionSpec

        public void updatePartitionSpec​(java.util.List<java.lang.String> partitionsToAdd,
                                java.util.Collection<java.lang.String> partitionsToDrop)
        Specified by:
        updatePartitionSpec in interface org.apache.beam.sdk.extensions.sql.meta.provider.AlterTableOps