bulk-cdk-toolkit-load-iceberg-parquet/io.airbyte.cdk.load.command.iceberg.parquet

Package-level declarations

Types

CatalogConfiguration

sealed interface CatalogConfiguration

A marker interface for catalog configuration details.

CatalogType

sealed class CatalogType

A sealed class representing different catalog types for Iceberg.

GlueCatalogConfiguration

data class GlueCatalogConfiguration(@JsonPropertyDescription(value = "The AWS Account ID associated with the Glue service.") val glueId: String, val awsArnRoleConfiguration: AWSArnRoleConfiguration, val databaseName: String) : CatalogConfiguration, AWSArnRoleConfigurationProvider

Glue catalog configuration details.

GlueCatalogSpecification

class GlueCatalogSpecification(val catalogType: CatalogType.Type = Type.GLUE, val glueId: String, val roleArn: String? = null, val databaseName: String) : CatalogType, AWSArnRoleSpecification

Glue catalog specifications.

IcebergCatalogConfiguration

data class IcebergCatalogConfiguration(@JsonPropertyDescription(value = "The root location of the data warehouse used by the Iceberg catalog.") val warehouseLocation: String, @JsonPropertyDescription(value = "The primary or default branch name in the catalog repository.") val mainBranchName: String, @JsonPropertyDescription(value = "The specific configuration details of the chosen Iceberg catalog type.") val catalogConfiguration: CatalogConfiguration)

Represents a unified Iceberg catalog configuration.

IcebergCatalogConfigurationProvider

interface IcebergCatalogConfigurationProvider

Provides a way to retrieve the unified Iceberg catalog configuration.

IcebergCatalogSpecifications

interface IcebergCatalogSpecifications

Interface defining the specifications for configuring an Iceberg catalog.

NessieCatalogConfiguration

data class NessieCatalogConfiguration(@JsonPropertyDescription(value = "The base URL of the Nessie server.") val serverUri: String, @JsonPropertyDescription(value = "An optional token for authentication with the Nessie server.") val accessToken: String?, val namespace: String) : CatalogConfiguration

Nessie catalog configuration details.

NessieCatalogSpecification

class NessieCatalogSpecification(val catalogType: CatalogType.Type = Type.NESSIE, val serverUri: String, val accessToken: String?, val namespace: String) : CatalogType

Nessie catalog specifications.

PolarisCatalogConfiguration

data class PolarisCatalogConfiguration(@JsonPropertyDescription(value = "The base URL of the Polaris server.") val serverUri: String, @JsonPropertyDescription(value = "The name of the catalog in Polaris.") val catalogName: String, @JsonPropertyDescription(value = "The OAuth Client ID for authenticating with the Polaris server.") val clientId: String, @JsonPropertyDescription(value = "The OAuth Client Secret for authenticating with the Polaris server.") val clientSecret: String, val namespace: String) : CatalogConfiguration

Polaris catalog configuration details.

PolarisCatalogSpecification

class PolarisCatalogSpecification(val catalogType: CatalogType.Type = Type.POLARIS, val serverUri: String, val catalogName: String, val clientId: String, val clientSecret: String, val namespace: String) : CatalogType

Polaris catalog specifications.

RestCatalogConfiguration

data class RestCatalogConfiguration(@JsonPropertyDescription(value = "The base URL of the Rest server.") val serverUri: String, val namespace: String) : CatalogConfiguration

Rest catalog configuration details.

RestCatalogSpecification

class RestCatalogSpecification(val catalogType: CatalogType.Type = Type.REST, val serverUri: String, val namespace: String) : CatalogType

Rest catalog specifications.