Package org.apache.polaris.spark.utils

Class DeltaHelper

java.lang.Object

org.apache.polaris.spark.utils.DeltaHelper

public class DeltaHelper
extends Object

Helper class for integrating Delta table functionality with Polaris Spark Catalog.

This class is responsible for dynamically loading and configuring a Delta Catalog implementation to work with Polaris. It sets up the Delta Catalog as a delegating catalog extension with Polaris Spark Catalog as the delegate, enabling Delta table operations through Polaris.

The class uses reflection to configure the Delta Catalog to behave identically to Unity Catalog, as the current Delta Catalog implementation is hardcoded for Unity Catalog. This is a temporary workaround until Delta extends support for other catalog implementations (see https://github.com/delta-io/delta/issues/4306).

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DELTA_CATALOG_IMPL_KEY

Constructor Summary

Constructors

Constructor	Description
DeltaHelper(org.apache.spark.sql.util.CaseInsensitiveStringMap options)

Method Summary

Modifier and Type	Method	Description
org.apache.spark.sql.connector.catalog.TableCatalog	loadDeltaCatalog(PolarisSparkCatalog polarisSparkCatalog)

Methods inherited from class java.lang.Object

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

Field Details

DELTA_CATALOG_IMPL_KEY

public static final String DELTA_CATALOG_IMPL_KEY

See Also:

• Constant Field Values

Constructor Details

DeltaHelper

public DeltaHelper(org.apache.spark.sql.util.CaseInsensitiveStringMap options)

Method Details

loadDeltaCatalog

public org.apache.spark.sql.connector.catalog.TableCatalog loadDeltaCatalog(PolarisSparkCatalog polarisSparkCatalog)