Thanks for your reply.
Reshuffle Class has no param to set.
I see the code of Reshuffle , constructor for this class is private, and code comment "For
internal use only; no backwards compatibility guarantees"
I mean... I want to set rdd partition number like
rdd.repartition(3) or simliar to Flink DataStream.setParallelism(3)
Could you help me...
Date: 2018-09-11 21:50
Subject: Re: How to implement repartition.(Internet mail)
Does Reshuffle do what you want?
I recently start studying the Beam on spark runner.
I want to implement a method
repartition similar to Spark rdd.repartition() , but I can't find a solution.
Could anyone help me?
for your reply.