mixle.data.sources.spark_source module¶

take_sample(rdd, with_replacement, n, seed=None)[source]

Parameters:

rdd (Any)
with_replacement (bool)
n (int)
seed (int | None)

sample_seq_as_rdd(sc, dist, seq_len, count_per_split, num_splits, seed=None)[source]

sample_rdd(sc, dist, count_per_split, num_splits, seed=None)[source]