ForwardFileRecordTask
constructor(inputQueue: PartitionedQueue<PipelineEvent<StreamKey, ObjectLoaderUploadCompleter.UploadResult<T>>>, outputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partition: Int)