ForwardFileRecordStep
constructor(@Named(value = "fileCompletedQueue") inputQueue: PartitionedQueue<PipelineEvent<StreamKey, ObjectLoaderUploadCompleter.UploadResult<T>>>, @Named(value = "recordQueue") outputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>)