Airbyte Kotlin Bulk CDK

0.1.92

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

RouteEventTask

class RouteEventTask(catalog: DestinationCatalog, inputFlow: Flow<PipelineEvent<StreamKey, DestinationRecordRaw>>, fileQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, recordQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partition: Int) : Task

Constructors

constructor(catalog: DestinationCatalog, inputFlow: Flow<PipelineEvent<StreamKey, DestinationRecordRaw>>, fileQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, recordQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partition: Int)

Properties

terminalCondition

open override val terminalCondition: TerminalCondition

Functions

open suspend override fun execute()

suspend fun handleEvent(event: PipelineEvent<StreamKey, DestinationRecordRaw>): Unit?