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

ProcessFileTaskLegacy

@Singleton
class ProcessFileTaskLegacy(@Named(value = "fileMessageQueue") inputQueue: MessageQueue<FileTransferQueueMessage>, @Named(value = "objectLoaderPartQueue") outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, partAccumulatorFactory: FilePartAccumulatorFactory) : Task

Constructors

Link copied to clipboard
constructor(@Named(value = "fileMessageQueue") inputQueue: MessageQueue<FileTransferQueueMessage>, @Named(value = "objectLoaderPartQueue") outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, partAccumulatorFactory: FilePartAccumulatorFactory)

Properties

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

Functions

Link copied to clipboard
open suspend override fun execute()