louna.rdds.api — louna/louna-spark 0.1.0-SNAPSHOT

filter_ clj

(filter_ rdd f)

flatMap clj

(flatMap rdd f)

flatMapValues clj

(flatMapValues pair-rdd f)

foreach clj

(foreach rdd f)

keyBy clj

(keyBy rdd f)

map_ clj

(map_ rdd f)

mapPartitions clj

(mapPartitions rdd f)

mapPartitionsWithIndex clj

(mapPartitionsWithIndex rdd f preservesPartitioning)

mapToPair clj

(mapToPair rdd f)

mapValues clj

(mapValues pair-rdd f)

reduce_ clj

(reduce_ rdd f)

reduceByKey clj

(reduceByKey rdd f)

seq->rdd clj

(seq->rdd col)

(seq->rdd col numpartitions)

sortBy clj

(sortBy rdd f)

t clj

(t k v)