@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/operator `*` -> `%`