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

Class IcebergMetastore

  • All Implemented Interfaces:
    org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider, org.apache.beam.sdk.extensions.sql.meta.store.MetaStore
    public class IcebergMetastore
extends org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

    • Constructor Summary

      Constructors 
      Constructor Description
      IcebergMetastore​(java.lang.String db, org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig catalogConfig)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      IcebergAlterTableOps alterTable​(java.lang.String name)  
      org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable buildBeamSqlTable​(org.apache.beam.sdk.extensions.sql.meta.Table table)  
      void createTable​(org.apache.beam.sdk.extensions.sql.meta.Table table)  
      void dropTable​(java.lang.String tableName)  
      @Nullable org.apache.beam.sdk.extensions.sql.meta.Table getTable​(java.lang.String name)  
      java.util.Map<java.lang.String,​org.apache.beam.sdk.extensions.sql.meta.Table> getTables()  
      java.lang.String getTableType()  
      void registerProvider​(org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider provider)  
      boolean supportsPartitioning​(org.apache.beam.sdk.extensions.sql.meta.Table table)  

      • Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

        getProvider, tableProviders, validateTableType

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider

        getSubProvider, getSubProviders

    • Constructor Detail

      • IcebergMetastore

        public IcebergMetastore​(java.lang.String db,
                        org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig catalogConfig)

    • Method Detail

      • getTableType

        public java.lang.String getTableType()
        Specified by:
        getTableType in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider
        Overrides:
        getTableType in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

      • createTable

        public void createTable​(org.apache.beam.sdk.extensions.sql.meta.Table table)
        Specified by:
        createTable in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider
        Overrides:
        createTable in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

      • dropTable

        public void dropTable​(java.lang.String tableName)
        Specified by:
        dropTable in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider
        Overrides:
        dropTable in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

      • getTables

        public java.util.Map<java.lang.String,​org.apache.beam.sdk.extensions.sql.meta.Table> getTables()
        Specified by:
        getTables in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider
        Overrides:
        getTables in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

      • getTable

        public @Nullable org.apache.beam.sdk.extensions.sql.meta.Table getTable​(java.lang.String name)

      • buildBeamSqlTable

        public org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable buildBeamSqlTable​(org.apache.beam.sdk.extensions.sql.meta.Table table)
        Specified by:
        buildBeamSqlTable in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider
        Overrides:
        buildBeamSqlTable in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

      • supportsPartitioning

        public boolean supportsPartitioning​(org.apache.beam.sdk.extensions.sql.meta.Table table)
        Specified by:
        supportsPartitioning in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider
        Overrides:
        supportsPartitioning in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

      • alterTable

        public IcebergAlterTableOps alterTable​(java.lang.String name)
        Specified by:
        alterTable in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider
        Overrides:
        alterTable in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

      • registerProvider

        public void registerProvider​(org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider provider)
        Specified by:
        registerProvider in interface org.apache.beam.sdk.extensions.sql.meta.store.MetaStore
        Overrides:
        registerProvider in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore