

@convert.register(list, (RDD, PipelinedRDD))
def rdd_to_list(rdd, **kwargs):
    return kwargs.collect()

dataset/ETHPy150Open blaze/odo/odo/backends/spark.py rdd_to_list/VarMisuse@28/38 `rdd`->`kwargs`