Airbyte Kotlin Bulk CDK

0.1.92

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

ForwardFileRecordTask

class ForwardFileRecordTask<T>(inputQueue: PartitionedQueue<PipelineEvent<StreamKey, ObjectLoaderUploadCompleter.UploadResult<T>>>, outputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partition: Int) : Task

Constructors

ForwardFileRecordTask

constructor(inputQueue: PartitionedQueue<PipelineEvent<StreamKey, ObjectLoaderUploadCompleter.UploadResult<T>>>, outputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partition: Int)

Properties

val log: KLogger

terminalCondition

open override val terminalCondition: TerminalCondition

Functions

open suspend override fun execute()

suspend fun handleEvent(event: PipelineEvent<StreamKey, ObjectLoaderUploadCompleter.UploadResult<T>>)