Package org.apache.iceberg.spark.source
Class SparkView
- java.lang.Object
-
- org.apache.iceberg.spark.source.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 Summary
Fields Modifier and Type Field Description static java.lang.String
QUERY_COLUMN_NAMES
static java.util.Set<java.lang.String>
RESERVED_PROPERTIES
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String[]
columnAliases()
java.lang.String[]
columnComments()
java.lang.String
currentCatalog()
java.lang.String[]
currentNamespace()
boolean
equals(java.lang.Object other)
int
hashCode()
java.lang.String
name()
java.util.Map<java.lang.String,java.lang.String>
properties()
java.lang.String
query()
java.lang.String[]
queryColumnNames()
org.apache.spark.sql.types.StructType
schema()
java.lang.String
toString()
View
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 interfaceorg.apache.spark.sql.connector.catalog.View
-
query
public java.lang.String query()
- Specified by:
query
in interfaceorg.apache.spark.sql.connector.catalog.View
-
currentCatalog
public java.lang.String currentCatalog()
- Specified by:
currentCatalog
in interfaceorg.apache.spark.sql.connector.catalog.View
-
currentNamespace
public java.lang.String[] currentNamespace()
- Specified by:
currentNamespace
in interfaceorg.apache.spark.sql.connector.catalog.View
-
schema
public org.apache.spark.sql.types.StructType schema()
- Specified by:
schema
in interfaceorg.apache.spark.sql.connector.catalog.View
-
queryColumnNames
public java.lang.String[] queryColumnNames()
- Specified by:
queryColumnNames
in interfaceorg.apache.spark.sql.connector.catalog.View
-
columnAliases
public java.lang.String[] columnAliases()
- Specified by:
columnAliases
in interfaceorg.apache.spark.sql.connector.catalog.View
-
columnComments
public java.lang.String[] columnComments()
- Specified by:
columnComments
in interfaceorg.apache.spark.sql.connector.catalog.View
-
properties
public java.util.Map<java.lang.String,java.lang.String> properties()
- Specified by:
properties
in interfaceorg.apache.spark.sql.connector.catalog.View
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object other)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
-