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.SupportsMetadataColumns

canRenameConflictingMetadataColumns

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