org.apache.iceberg.spark.source

Class SparkChangelogTable

java.lang.Object

org.apache.iceberg.spark.source.SparkChangelogTable

All Implemented Interfaces:

org.apache.spark.sql.connector.catalog.SupportsMetadataColumns, org.apache.spark.sql.connector.catalog.SupportsRead, org.apache.spark.sql.connector.catalog.Table

public class SparkChangelogTable
extends java.lang.Object
implements org.apache.spark.sql.connector.catalog.Table, org.apache.spark.sql.connector.catalog.SupportsRead, org.apache.spark.sql.connector.catalog.SupportsMetadataColumns

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	TABLE_NAME

Constructor Summary

Constructors

Constructor and Description
SparkChangelogTable(Table icebergTable, boolean refreshEagerly)

Method Summary

Modifier and Type	Method and Description
java.util.Set<org.apache.spark.sql.connector.catalog.TableCapability>	capabilities()
org.apache.spark.sql.connector.catalog.MetadataColumn[]	metadataColumns()
java.lang.String	name()
org.apache.spark.sql.connector.read.ScanBuilder	newScanBuilder(org.apache.spark.sql.util.CaseInsensitiveStringMap options)
org.apache.spark.sql.types.StructType	schema()

Methods inherited from class java.lang.Object

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

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

columns, partitioning, properties

Field Detail

TABLE_NAME

public static final java.lang.String TABLE_NAME

See Also:

Constant Field Values

Constructor Detail

SparkChangelogTable

public SparkChangelogTable(Table icebergTable,
                           boolean refreshEagerly)

Method Detail

name

public java.lang.String name()

Specified by:

name in interface org.apache.spark.sql.connector.catalog.Table

schema

public org.apache.spark.sql.types.StructType schema()

Specified by:

schema in interface org.apache.spark.sql.connector.catalog.Table

capabilities

public java.util.Set<org.apache.spark.sql.connector.catalog.TableCapability> capabilities()

Specified by:

capabilities in interface org.apache.spark.sql.connector.catalog.Table

newScanBuilder

public org.apache.spark.sql.connector.read.ScanBuilder newScanBuilder(org.apache.spark.sql.util.CaseInsensitiveStringMap options)

Specified by:

newScanBuilder in interface org.apache.spark.sql.connector.catalog.SupportsRead

metadataColumns

public org.apache.spark.sql.connector.catalog.MetadataColumn[] metadataColumns()

Specified by:

metadataColumns in interface org.apache.spark.sql.connector.catalog.SupportsMetadataColumns