Interface ViewSessionCatalog

    • Method Detail

      • name

        java.lang.String name()
        Return the name for this catalog.
        Returns:
        this catalog's name
      • viewExists

        default boolean viewExists​(SessionCatalog.SessionContext context,
                                   TableIdentifier identifier)
        Check whether view exists.
        Parameters:
        identifier - a view identifier
        Returns:
        true if the view exists, false otherwise
      • dropView

        boolean dropView​(SessionCatalog.SessionContext context,
                         TableIdentifier identifier)
        Drop a view.
        Parameters:
        identifier - a view identifier
        Returns:
        true if the view was dropped, false if the view did not exist
      • invalidateView

        default void invalidateView​(SessionCatalog.SessionContext context,
                                    TableIdentifier identifier)
        Invalidate cached view metadata from current catalog.

        If the view is already loaded or cached, drop cached data. If the view does not exist or is not cached, do nothing.

        Parameters:
        identifier - a view identifier
      • initialize

        void initialize​(java.lang.String name,
                        java.util.Map<java.lang.String,​java.lang.String> properties)
        Initialize a view catalog given a custom name and a map of catalog properties.

        A custom view catalog implementation must have a no-arg constructor. A compute engine like Spark or Flink will first initialize the catalog without any arguments, and then call this method to complete catalog initialization with properties passed into the engine.

        Parameters:
        name - a custom name for the catalog
        properties - catalog properties