bulk-cdk-toolkit-load-fusion/io.airbyte.cdk.fusion/S3FusionUploader

S3FusionUploader

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

Constructors

S3FusionUploader

constructor(config: FusionConfiguration, contentType: String = "application/gzip")

Functions

open override fun close()

open override fun upload(path: Path, key: String, metadata: Map<String, String>): CompletableFuture<*>

open override fun uploadJson(bytes: ByteArray, key: String): CompletableFuture<*>