createAccumulator

abstract fun createAccumulator(streamDescriptor: DestinationStream.Descriptor, partition: Int): InsertLoaderRequestBuilder<Q>