Index

B C E F G I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

B

buildCreateTableTransaction(String, String, StructType, String) - Method in class io.delta.kernel.unitycatalog.UCCatalogManagedClient

Deprecated.

Use UCCatalogManagedClient.buildCreateTableTransaction(String, String, StructType, String, UCTableIdentifier) which automatically finalizes the table.

buildCreateTableTransaction(String, String, StructType, String, UCTableIdentifier) - Method in class io.delta.kernel.unitycatalog.UCCatalogManagedClient

Builds a create table transaction with automatic UC finalization.

C

capture() - Method in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsCollector

capture() - Method in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

capture() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

commit(Engine, CloseableIterator<Row>, CommitMetadata) - Method in class io.delta.kernel.unitycatalog.UCCatalogManagedCommitter

commitToUcServerDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsResult

commitToUcServerTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsCollector

commitType - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

commitVersion - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

createFailureReport(Exception) - Method in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry

createFailureReport(Exception) - Method in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry

createFailureReport(Exception) - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry

createSuccessReport() - Method in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry

createSuccessReport() - Method in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry

createSuccessReport() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry

E

exception - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

exception - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

exception - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

F

fromCommitterProperties(Map<String, String>) - Static method in class io.delta.kernel.unitycatalog.adapters.UniformAdapter

Extracts Uniform metadata from committer properties.

G

get() - Method in interface io.delta.kernel.unitycatalog.utils.OperationTimer.ThrowingSupplier

getCatalogName() - Method in class io.delta.kernel.unitycatalog.UCTableIdentifier

getCommitsAlreadyPublished() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

getCommitsDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsResult

getCommitsPublished() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

getCommitsTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

getConfiguration() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getCreatedTime() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getDescription() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getFormatOptions() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getId() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getMetricsCollector() - Method in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry

getMetricsCollector() - Method in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry

getMetricsCollector() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry

getMinReaderVersion() - Method in class io.delta.kernel.unitycatalog.adapters.ProtocolAdapter

getMinWriterVersion() - Method in class io.delta.kernel.unitycatalog.adapters.ProtocolAdapter

getName() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getPartitionColumns() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getPropertiesForCreate(CommitMetadata) - Static method in class io.delta.kernel.unitycatalog.UnityCatalogUtils

Same as getPropertiesForCreate(Engine, SnapshotImpl) but reads from CommitMetadata.

getPropertiesForCreate(Engine, SnapshotImpl) - Static method in class io.delta.kernel.unitycatalog.UnityCatalogUtils

Extract all properties that should be sent to Unity Catalog when creating a table (version 0).

getProvider() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getReaderFeatures() - Method in class io.delta.kernel.unitycatalog.adapters.ProtocolAdapter

getRequiredTableProperties() - Method in class io.delta.kernel.unitycatalog.UCCatalogManagedCommitter

getSchemaName() - Method in class io.delta.kernel.unitycatalog.UCTableIdentifier

getSchemaString() - Method in class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

getTableName() - Method in class io.delta.kernel.unitycatalog.UCTableIdentifier

getWriterFeatures() - Method in class io.delta.kernel.unitycatalog.adapters.ProtocolAdapter

I

ICEBERG_CONVERTED_DELTA_TIMESTAMP_KEY - Static variable in class io.delta.kernel.unitycatalog.adapters.UniformAdapter

ICEBERG_CONVERTED_DELTA_VERSION_KEY - Static variable in class io.delta.kernel.unitycatalog.adapters.UniformAdapter

ICEBERG_METADATA_LOCATION_KEY - Static variable in class io.delta.kernel.unitycatalog.adapters.UniformAdapter

incrementCommitsAlreadyPublished() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

Increments the counter for commits already published by another process.

incrementCommitsPublished() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

io.delta.kernel.unitycatalog - package io.delta.kernel.unitycatalog

io.delta.kernel.unitycatalog.adapters - package io.delta.kernel.unitycatalog.adapters

io.delta.kernel.unitycatalog.metrics - package io.delta.kernel.unitycatalog.metrics

io.delta.kernel.unitycatalog.utils - package io.delta.kernel.unitycatalog.utils

K

kernelFileStatusToHadoopFileStatus(FileStatus) - Static method in class io.delta.kernel.unitycatalog.UCCatalogManagedCommitter

kernelSnapshotBuildDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsResult

kernelSnapshotBuildTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

L

loadCommitRange(Engine, String, String, Optional<Long>, Optional<Long>, Optional<Long>, Optional<Long>) - Method in class io.delta.kernel.unitycatalog.UCCatalogManagedClient

Loads a Kernel CommitRange for the provided boundaries.

loadLatestSnapshotForTimestampTimeTravelDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsResult

loadLatestSnapshotForTimestampTimeTravelTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

loadSnapshot(Engine, String, String, Optional<Long>, Optional<Long>) - Method in class io.delta.kernel.unitycatalog.UCCatalogManagedClient

Loads a Kernel Snapshot.

M

MetadataAdapter - Class in io.delta.kernel.unitycatalog.adapters

Adapter from Metadata to AbstractMetadata.

MetadataAdapter(Metadata) - Constructor for class io.delta.kernel.unitycatalog.adapters.MetadataAdapter

metrics - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

metrics - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

metrics - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

MetricsCollector() - Constructor for class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsCollector

MetricsCollector() - Constructor for class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

MetricsCollector() - Constructor for class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

N

numCatalogCommits - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsResult

numCommitsAlreadyPublished - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsResult

numCommitsPublished - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsResult

numCommitsToPublish - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

O

OperationTimer - Class in io.delta.kernel.unitycatalog.utils

Utility class for timing operations and logging their execution duration.

OperationTimer.ThrowingSupplier<T,E> - Interface in io.delta.kernel.unitycatalog.utils

operationType - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

operationType - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

operationType - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

P

ProtocolAdapter - Class in io.delta.kernel.unitycatalog.adapters

Adapter from Protocol to AbstractProtocol.

ProtocolAdapter(Protocol) - Constructor for class io.delta.kernel.unitycatalog.adapters.ProtocolAdapter

publish(Engine, PublishMetadata) - Method in class io.delta.kernel.unitycatalog.UCCatalogManagedCommitter

R

Report(UcCommitTelemetry.MetricsResult, Optional<Exception>) - Constructor for class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

Report(UcLoadSnapshotTelemetry.MetricsResult, Optional<Exception>) - Constructor for class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

Report(UcPublishTelemetry.MetricsResult, Optional<Exception>) - Constructor for class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

reportUUID - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

reportUUID - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

reportUUID - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

resolvedSnapshotVersion - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsResult

S

setNumCatalogCommits(int) - Method in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

setResolvedSnapshotVersion(long) - Method in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

snapshotVersion - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

T

timeCheckedOperation(Logger, String, String, OperationTimer.ThrowingSupplier<T, E>) - Static method in class io.delta.kernel.unitycatalog.utils.OperationTimer

Times an operation that throws a checked exception of type E and logs the duration.

timestampOpt - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

timeUncheckedOperation(Logger, String, String, Supplier<T>) - Static method in class io.delta.kernel.unitycatalog.utils.OperationTimer

Times an operation and logs the duration.

toColumnDefs(StructType) - Static method in class io.delta.kernel.unitycatalog.UnityCatalogUtils

Converts a Kernel StructType schema to a list of UC UCClient.ColumnDef definitions suitable for the Unity Catalog createTable API.

toJson() - Method in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

toJson() - Method in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

toJson() - Method in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

totalCommitDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsResult

totalCommitTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsCollector

totalLoadSnapshotDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsResult

totalPublishDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsResult

totalPublishTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

totalSnapshotLoadTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.MetricsCollector

U

UC_PROPERTY_NAMESPACE_PREFIX - Static variable in class io.delta.kernel.unitycatalog.UCCatalogManagedClient

UC_TABLE_ID_KEY - Static variable in class io.delta.kernel.unitycatalog.UCCatalogManagedClient

Key for identifying Unity Catalog table ID.

UCCatalogManagedClient - Class in io.delta.kernel.unitycatalog

Client for interacting with Unity Catalog (UC) catalog-managed Delta tables.

UCCatalogManagedClient(UCClient) - Constructor for class io.delta.kernel.unitycatalog.UCCatalogManagedClient

UCCatalogManagedCommitter - Class in io.delta.kernel.unitycatalog

An implementation of Committer that handles commits to Delta tables managed by Unity Catalog.

UCCatalogManagedCommitter(UCClient, String, String) - Constructor for class io.delta.kernel.unitycatalog.UCCatalogManagedCommitter

Creates a committer for an existing Unity Catalog-managed Delta table (version >= 1 writes).

UCCatalogManagedCommitter(UCClient, String, String, UCTableIdentifier) - Constructor for class io.delta.kernel.unitycatalog.UCCatalogManagedCommitter

Creates a committer for a new Unity Catalog-managed Delta table (CREATE TABLE).

UcCommitTelemetry - Class in io.delta.kernel.unitycatalog.metrics

Telemetry framework for Unity Catalog commit operations.

UcCommitTelemetry(String, String, CommitMetadata) - Constructor for class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry

UcCommitTelemetry.MetricsCollector - Class in io.delta.kernel.unitycatalog.metrics

Mutable collector for gathering metrics during commit.

UcCommitTelemetry.MetricsResult - Class in io.delta.kernel.unitycatalog.metrics

Immutable snapshot of collected metric results.

UcCommitTelemetry.Report - Class in io.delta.kernel.unitycatalog.metrics

Complete UC commit report with metadata and metrics.

UcLoadSnapshotTelemetry - Class in io.delta.kernel.unitycatalog.metrics

Telemetry framework for Unity Catalog snapshot loading operations.

UcLoadSnapshotTelemetry(String, String, Optional<Long>, Optional<Long>) - Constructor for class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry

UcLoadSnapshotTelemetry.MetricsCollector - Class in io.delta.kernel.unitycatalog.metrics

Mutable collector for gathering metrics during snapshot loading.

UcLoadSnapshotTelemetry.MetricsResult - Class in io.delta.kernel.unitycatalog.metrics

Immutable snapshot of collected metric results.

UcLoadSnapshotTelemetry.Report - Class in io.delta.kernel.unitycatalog.metrics

Complete UC snapshot loading report with metadata and metrics.

UcPublishTelemetry - Class in io.delta.kernel.unitycatalog.metrics

Telemetry framework for Unity Catalog publish operations.

UcPublishTelemetry(String, String, long, int) - Constructor for class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry

UcPublishTelemetry.MetricsCollector - Class in io.delta.kernel.unitycatalog.metrics

Mutable collector for gathering metrics during publish.

UcPublishTelemetry.MetricsResult - Class in io.delta.kernel.unitycatalog.metrics

Immutable snapshot of collected metric results.

UcPublishTelemetry.Report - Class in io.delta.kernel.unitycatalog.metrics

Complete UC publish report with metadata and metrics.

ucTableId - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

ucTableId - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

ucTableId - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

UCTableIdentifier - Class in io.delta.kernel.unitycatalog

Logical Unity Catalog table identifier used for create-time finalization.

UCTableIdentifier(String, String, String) - Constructor for class io.delta.kernel.unitycatalog.UCTableIdentifier

ucTablePath - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.Report

ucTablePath - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

ucTablePath - Variable in class io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.Report

UniformAdapter - Class in io.delta.kernel.unitycatalog.adapters

Adapter for Delta Uniform metadata to UniformMetadata.

UnityCatalogUtils - Class in io.delta.kernel.unitycatalog

V

versionOpt - Variable in class io.delta.kernel.unitycatalog.metrics.UcLoadSnapshotTelemetry.Report

W

writeCommitFileDurationNs - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsResult

writeCommitFileTimer - Variable in class io.delta.kernel.unitycatalog.metrics.UcCommitTelemetry.MetricsCollector

B C E F G I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values