Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-load-azure-blob-storage/io.airbyte.cdk.load.file.azureBlobStorage/AzureBlobStreamingUpload

AzureBlobStreamingUpload

class AzureBlobStreamingUpload(blockBlobClient: BlockBlobClient, config: AzureBlobStorageClientConfiguration, metadata: Map<String, String>) : StreamingUpload<AzureBlob>

Constructors

AzureBlobStreamingUpload

constructor(blockBlobClient: BlockBlobClient, config: AzureBlobStorageClientConfiguration, metadata: Map<String, String>)

Functions

open suspend override fun complete(): AzureBlob

After all parts are uploaded, we finalize by committing the block list in ascending order. If no parts were uploaded, we skip.

generateBlockId

fun generateBlockId(index: Int): String

open suspend override fun uploadPart(part: ByteArray, index: Int)

Each part that arrives is treated as a new block. We must generate unique block IDs for each call (Azure requires base64-encoded strings).