Details
-
Sub-task
-
Status: Resolved
-
Minor
-
Resolution: Won't Fix
-
None
-
None
Description
Provide RDD transforms analogous to Scala scan(z)(f) (parallel prefix scan) and scanLeft(z)(f) (sequential prefix scan)
Discussion of a scanLeft implementation:
http://erikerlandson.github.io/blog/2014/08/09/implementing-an-rdd-scanleft-transform-with-cascade-rdds/
Discussion of scan:
http://erikerlandson.github.io/blog/2014/08/12/implementing-parallel-prefix-scan-as-a-spark-rdd-transform/
Attachments
Issue Links
- relates to
-
SPARK-9999 Dataset API on top of Catalyst/DataFrame
- Resolved
- links to