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

Class IcebergCatalog

  • All Implemented Interfaces:
    org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
    public class IcebergCatalog
extends org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

    • Field Summary

      • Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

        currentDatabase, properties, tableProviders

      • Fields inherited from interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog

        DEFAULT

    • Constructor Summary

      Constructors 
      Constructor Description
      IcebergCatalog​(java.lang.String name, java.util.Map<java.lang.String,​java.lang.String> props)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean createDatabase​(java.lang.String database)  
      boolean databaseExists​(java.lang.String db)  
      java.util.Collection<java.lang.String> databases()  
      boolean dropDatabase​(java.lang.String database, boolean cascade)  
      IcebergMetastore metaStore​(java.lang.String db)  
      java.lang.String type()  
      void updateProperties​(java.util.Map<java.lang.String,​java.lang.String> setProps, java.util.Collection<java.lang.String> resetProps)  
      void useDatabase​(java.lang.String database)  

      • Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

        currentDatabase, name, properties, registerTableProvider, tableProviders, toString

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • IcebergCatalog

        public IcebergCatalog​(java.lang.String name,
                      java.util.Map<java.lang.String,​java.lang.String> props)

    • Method Detail

      • metaStore

        public IcebergMetastore metaStore​(java.lang.String db)
        Specified by:
        metaStore in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        metaStore in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

      • type

        public java.lang.String type()
        Specified by:
        type in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        type in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

      • updateProperties

        public void updateProperties​(java.util.Map<java.lang.String,​java.lang.String> setProps,
                             java.util.Collection<java.lang.String> resetProps)
        Specified by:
        updateProperties in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        updateProperties in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

      • createDatabase

        public boolean createDatabase​(java.lang.String database)
        Specified by:
        createDatabase in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        createDatabase in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

      • databases

        public java.util.Collection<java.lang.String> databases()
        Specified by:
        databases in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        databases in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

      • useDatabase

        public void useDatabase​(java.lang.String database)
        Specified by:
        useDatabase in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        useDatabase in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

      • databaseExists

        public boolean databaseExists​(java.lang.String db)
        Specified by:
        databaseExists in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        databaseExists in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

      • dropDatabase

        public boolean dropDatabase​(java.lang.String database,
                            boolean cascade)
        Specified by:
        dropDatabase in interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog
        Overrides:
        dropDatabase in class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog