Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.pipline.object_storage/ObjectLoaderUploadCompleter

ObjectLoaderUploadCompleter

@Singleton

@Requires(bean = ObjectLoader::class)

class ObjectLoaderUploadCompleter<T : RemoteObject<*>>(val objectLoader: ObjectLoader) : BatchAccumulator<ObjectLoaderUploadCompleter.State, ObjectKey, ObjectLoaderPartLoader.PartResult<T>, ObjectLoaderUploadCompleter.UploadResult<T>>

Constructors

ObjectLoaderUploadCompleter

constructor(objectLoader: ObjectLoader)

Types

data class State(val objectKey: String, val partBookkeeper: PartBookkeeper) : AutoCloseable

data class UploadResult<T>(val state: BatchState, val remoteObject: T?) : WithBatchState

Properties

val objectLoader: ObjectLoader

Functions

open suspend override fun accept(input: ObjectLoaderPartLoader.PartResult<T>, state: ObjectLoaderUploadCompleter.State): BatchAccumulatorResult<ObjectLoaderUploadCompleter.State, ObjectLoaderUploadCompleter.UploadResult<T>>

open suspend override fun finish(state: ObjectLoaderUploadCompleter.State): FinalOutput<ObjectLoaderUploadCompleter.State, ObjectLoaderUploadCompleter.UploadResult<T>>

open suspend override fun start(key: ObjectKey, part: Int): ObjectLoaderUploadCompleter.State