fun <E> partition(input: Stream<E>, partitionSize: Int): Stream<List<E>>
fun <E> partition(input: Stream<E>, partitionSize: Int, batchSize: Int): Stream<List<E>>