org.apache.iceberg.spark

Interface SupportsReplaceView

All Superinterfaces:

org.apache.spark.sql.connector.catalog.CatalogPlugin, org.apache.spark.sql.connector.catalog.ViewCatalog

All Known Implementing Classes:

SparkCatalog

public interface SupportsReplaceView
extends org.apache.spark.sql.connector.catalog.ViewCatalog

Field Summary

Fields inherited from interface org.apache.spark.sql.connector.catalog.ViewCatalog

PROP_COMMENT, PROP_CREATE_ENGINE_VERSION, PROP_ENGINE_VERSION, PROP_OWNER, RESERVED_PROPERTIES

Method Summary

Modifier and Type

Method and Description

org.apache.spark.sql.connector.catalog.View

replaceView(org.apache.spark.sql.connector.catalog.Identifier ident, java.lang.String sql, java.lang.String currentCatalog, java.lang.String[] currentNamespace, org.apache.spark.sql.types.StructType schema, java.lang.String[] queryColumnNames, java.lang.String[] columnAliases, java.lang.String[] columnComments, java.util.Map<java.lang.String,java.lang.String> properties) Replace a view in the catalog

Methods inherited from interface org.apache.spark.sql.connector.catalog.ViewCatalog

alterView, createView, dropView, invalidateView, listViews, loadView, renameView, viewExists

Methods inherited from interface org.apache.spark.sql.connector.catalog.CatalogPlugin

defaultNamespace, initialize, name

Method Detail

replaceView

org.apache.spark.sql.connector.catalog.View replaceView(org.apache.spark.sql.connector.catalog.Identifier ident,
                                                        java.lang.String sql,
                                                        java.lang.String currentCatalog,
                                                        java.lang.String[] currentNamespace,
                                                        org.apache.spark.sql.types.StructType schema,
                                                        java.lang.String[] queryColumnNames,
                                                        java.lang.String[] columnAliases,
                                                        java.lang.String[] columnComments,
                                                        java.util.Map<java.lang.String,java.lang.String> properties)
                                                 throws org.apache.spark.sql.catalyst.analysis.NoSuchViewException,
                                                        org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException

Replace a view in the catalog

Parameters:

ident - a view identifier

sql - the SQL text that defines the view

currentCatalog - the current catalog

currentNamespace - the current namespace

schema - the view query output schema

queryColumnNames - the query column names

columnAliases - the column aliases

columnComments - the column comments

properties - the view properties

Throws:

org.apache.spark.sql.catalyst.analysis.NoSuchViewException - If the view doesn't exist or is a table

org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException - If the identifier namespace does not exist (optional)