Re: How to implement repartition.

2018-09-11 Thread Robert Bradshaw
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 me?
> Thanks for your reply.
> devin.
>


How to implement repartition.

2018-09-11 Thread 段丁瑞
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.