Package org.apache.iceberg.spark.source

Class SparkView

  • All Implemented Interfaces:
    org.apache.spark.sql.connector.catalog.View
    public class SparkView
extends java.lang.Object
implements org.apache.spark.sql.connector.catalog.View

    • Field Detail

      • QUERY_COLUMN_NAMES

        public static final java.lang.String QUERY_COLUMN_NAMES
        See Also:
        Constant Field Values

      • RESERVED_PROPERTIES

        public static final java.util.Set<java.lang.String> RESERVED_PROPERTIES

    • Constructor Detail

      • SparkView

        public SparkView​(java.lang.String catalogName,
                 View icebergView)

    • Method Detail

      • view

        public View view()

      • name

        public java.lang.String name()
        Specified by:
        name in interface org.apache.spark.sql.connector.catalog.View

      • query

        public java.lang.String query()
        Specified by:
        query in interface org.apache.spark.sql.connector.catalog.View

      • currentCatalog

        public java.lang.String currentCatalog()
        Specified by:
        currentCatalog in interface org.apache.spark.sql.connector.catalog.View

      • currentNamespace

        public java.lang.String[] currentNamespace()
        Specified by:
        currentNamespace in interface org.apache.spark.sql.connector.catalog.View

      • schema

        public org.apache.spark.sql.types.StructType schema()
        Specified by:
        schema in interface org.apache.spark.sql.connector.catalog.View

      • queryColumnNames

        public java.lang.String[] queryColumnNames()
        Specified by:
        queryColumnNames in interface org.apache.spark.sql.connector.catalog.View

      • columnAliases

        public java.lang.String[] columnAliases()
        Specified by:
        columnAliases in interface org.apache.spark.sql.connector.catalog.View

      • columnComments

        public java.lang.String[] columnComments()
        Specified by:
        columnComments in interface org.apache.spark.sql.connector.catalog.View

      • properties

        public java.util.Map<java.lang.String,​java.lang.String> properties()
        Specified by:
        properties in interface org.apache.spark.sql.connector.catalog.View

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object

      • equals

        public boolean equals​(java.lang.Object other)
        Overrides:
        equals in class java.lang.Object

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object