GcsStreamingUpload

class GcsStreamingUpload(storage: Storage, key: String, config: GcsClientConfiguration, metadata: Map<String, String>) : StreamingUpload<GcsBlob>

This class is responsible for uploading individual parts to GCS and composing them at the end.

/!\ Unlike typical "multipart upload" semantics, each part is visible as a standalone object until it is composed into a final object. That’s usually acceptable for BigQuery usage, but Will be an issue with a dedicated GCS destination as it would probably be a breaking change

Constructors

Link copied to clipboard
constructor(storage: Storage, key: String, config: GcsClientConfiguration, metadata: Map<String, String>)

Functions

Link copied to clipboard
open suspend override fun complete(): GcsBlob

Compose all parts into the final object.

Link copied to clipboard
open suspend override fun uploadPart(part: ByteArray, index: Int)

Upload a part to GCS. Each part is stored as a temporary blob.