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

FilePartAccumulatorLegacy

class FilePartAccumulatorLegacy(pathFactory: ObjectStoragePathFactory, stream: DestinationStream, outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, loadStrategy: ObjectLoader)

Constructors

Link copied to clipboard

Properties

Link copied to clipboard
val log: KLogger
Link copied to clipboard

Functions

Link copied to clipboard
suspend fun handleFileMessage(file: DestinationFile, index: Long, checkpointId: CheckpointId)