FileChunkTask
constructor(loader: ObjectLoader, catalog: DestinationCatalog, pathFactory: ObjectStoragePathFactory, fileHandleFactory: FileHandleFactory, uploadIdGenerator: UploadIdGenerator, inputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, partitioner: ObjectLoaderFormattedPartPartitioner<StreamKey, T>, partition: Int)(source)