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