[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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.