Package org.apache.polaris.spark.utils

Class PolarisCatalogSpark4Utils

java.lang.Object

org.apache.polaris.spark.utils.PolarisCatalogUtils

org.apache.polaris.spark.utils.PolarisCatalogSpark4Utils

public class PolarisCatalogSpark4Utils
extends PolarisCatalogUtils

Spark 4.0 implementation of PolarisCatalogUtils.

Field Summary

Fields inherited from class org.apache.polaris.spark.utils.PolarisCatalogUtils

TABLE_PATH_KEY, TABLE_PROVIDER_KEY

Constructor Summary

Constructors

Constructor	Description
PolarisCatalogSpark4Utils()

Method Summary

Modifier and Type	Method	Description
org.apache.spark.sql.connector.catalog.Table	loadV1SparkTable(GenericTable genericTable, org.apache.spark.sql.connector.catalog.Identifier identifier, String catalogName)	Return a Spark V1Table for formats that do not use DataSourceV2.

Methods inherited from class org.apache.polaris.spark.utils.PolarisCatalogUtils

getAuthSession, isTableWithSparkManagedLocation, loadV2SparkTable, normalizeTablePropertiesForLoadSparkTable, useDelta, useHudi, useIceberg, usePaimon

Methods inherited from class java.lang.Object

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

Constructor Details

PolarisCatalogSpark4Utils

public PolarisCatalogSpark4Utils()

Method Details

loadV1SparkTable

public org.apache.spark.sql.connector.catalog.Table loadV1SparkTable(GenericTable genericTable,
 org.apache.spark.sql.connector.catalog.Identifier identifier,
 String catalogName)

Description copied from class: PolarisCatalogUtils

Return a Spark V1Table for formats that do not use DataSourceV2. Currently, this is being used for Hudi tables

Specified by:

loadV1SparkTable in class PolarisCatalogUtils