bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.write.object_storage/ObjectStorageStreamLoader

ObjectStorageStreamLoader

class ObjectStorageStreamLoader<T : RemoteObject<*>>(val stream: DestinationStream, client: ObjectStorageClient<T>, destinationStateManager: DestinationStateManager<ObjectStorageDestinationState>) : StreamLoader

Constructors

Link copied to clipboard
constructor(stream: DestinationStream, client: ObjectStorageClient<T>, destinationStateManager: DestinationStateManager<ObjectStorageDestinationState>)

Properties

Link copied to clipboard
open override val stream: DestinationStream

Functions

Link copied to clipboard
open suspend override fun close(hadNonzeroRecords: Boolean, streamFailure: StreamProcessingFailed?)
Link copied to clipboard
open suspend fun start()
Link copied to clipboard
open suspend fun teardown(completedSuccessfully: Boolean)