Does Reshuffle do what you want? On Tue, Sep 11, 2018, 3:46 PM devinduan(段丁瑞) <[email protected]> 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. >
