RouteEventStep
constructor(catalog: DestinationCatalog, @Named(value = "dataChannelInputFlows") inputFlows: Array<Flow<PipelineEvent<StreamKey, DestinationRecordRaw>>>, @Named(value = "fileQueue") fileQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, @Named(value = "recordQueue") recordQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>)