

@append.register(SparkContext, list)
def list_to_spark_context(sc, seq, **kwargs):
    return sc.parallelize(kwargs)

dataset/ETHPy150Open blaze/odo/odo/backends/spark.py list_to_spark_context/VarMisuse@30/36 `seq`->`kwargs`