Package-level declarations

Types

class FusionConfiguration(val roleArn: String, val externalId: String?, val accessKeyId: String? = null, val secretAccessKey: String? = null, val bucket: String, val region: String, val connectionId: UUID, val workspaceId: UUID, val sourceId: UUID, val prefix: String, val organizationId: UUID, val destinationId: UUID)

Fusion is enabled and configured solely by the platform environment.

Shared run identity for the schema, completion marker, and S3 batch headers.

A run owns its schema, completion marker, and all batch objects.

Extract the original configured catalog without a dependency on either CDK's stream model.

class S3FusionUploader @JvmOverloads constructor(config: FusionConfiguration, contentType: String = "application/gzip") : FusionUploader