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

FilePartAccumulatorFactory

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

Constructors

Link copied to clipboard

Functions

Link copied to clipboard