DirectLoadPipelineStep
constructor(directLoaderFactory: DirectLoaderFactory<S>, accumulator: DirectLoadRecordAccumulator<S, StreamKey>, taskFactory: LoadPipelineStepTaskFactory, @Named(value = "numInputPartitions") numInputPartitions: Int)(source)