Does Reshuffle do what you want?
On Tue, Sep 11, 2018, 3:46 PM devinduan(段丁瑞) wrote:
> Hi all：
> 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
Hi all：
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?
Thanks for your reply.
devin.
