RouteEventTask
class RouteEventTask(catalog: DestinationCatalog, inputFlow: Flow<PipelineEvent<StreamKey, DestinationRecordRaw>>, fileQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, recordQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partition: Int) : Task
Constructors
Link copied to clipboard
constructor(catalog: DestinationCatalog, inputFlow: Flow<PipelineEvent<StreamKey, DestinationRecordRaw>>, fileQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, recordQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partition: Int)