

@discover.register(RDD)
def discover_rdd(rdd, n=50, **kwargs):
    data = rdd.take(n)
    return (var * discover(data).subshape[0])

dataset/ETHPy150Open blaze/odo/odo/backends/spark.py discover_rdd/original