Sparkling 1.0.0
A Clojure Library for Apache Spark
sparkling.api
Public variables and functions:
- aggregate
- cache
- cartesian
- checkpoint
- coalesce
- coalesce-max
- cogroup
- collect
- combine-by-key
- count
- count-by-key
- count-by-value
- count-partitions
- distinct
- filter
- first
- flat-map
- flat-map-to-pair
- flat-map-values
- fold
- foreach
- foreach-partition
- glom
- group-by
- group-by-key
- hash-partitioner
- histogram
- jar-of-ns
- join
- key-by
- keys
- left-outer-join
- local-spark-context
- map
- map-partition
- map-partition-with-index
- map-partitions-to-pair
- map-to-pair
- map-values
- parallelize
- parallelize-pairs
- partition-by
- partitioner
- partitioner-aware-union
- partitions
- partitionwise-sampled-rdd
- persist
- rdd-name
- reduce
- reduce-by-key
- rekey-preserving-partitioning-without-check
- repartition
- sample
- save-as-sequence-file
- save-as-text-file
- sort-by-key
- spark-context
- STORAGE-LEVELS
- take
- text-file
- tuple
- union
- values
- with-context
sparkling.destructuring
Contains wrapper-functions to destructure scala/spark data structures
Public variables and functions: