twitter / scalding

A Scala API for Cascading
http://twitter.com/scalding
Apache License 2.0
3.48k stars 704 forks source link

Make SparkWriter work #1869

Closed johnynek closed 5 years ago

johnynek commented 5 years ago

Note, this is a PR into #1868 (so, I will point it at develop after that merges).

This is part to support Execution in spark.

With this, you can run an Execution[A] in SparkMode which pretty much gets us to probably an alpha version of this code.

The last thing to do is provide standard SparkSources that convert the common sources/sinks to spark (e.g. TypedText.tsv, TextLine, SequenceFile, and maybe a few others).

cc @ianoc @non