How to implement repartition.

[段丁瑞]

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.