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