code: public Stream partition(CustomStreamGrouping partitioner) {
          return partition(Grouping.custom_serialized(Utils.javaSerialize(partitioner)));
      }
docs: ## Repartitioning Operation
  
  @param partitioner
  @return