createOnlyStep
fun <S : AutoCloseable, K2 : WithStream, U : Any> createOnlyStep(batchAccumulator: BatchAccumulator<S, StreamKey, DestinationRecordRaw, U>, part: Int, numWorkers: Int, maxNumConcurrentKeys: Int? = null): LoadPipelineStepTask<S, StreamKey, DestinationRecordRaw, K2, U>