Skip to content

Instantly share code, notes, and snippets.

@krishnanraman
Created March 27, 2013 21:13
Show Gist options
  • Save krishnanraman/5258053 to your computer and use it in GitHub Desktop.
Save krishnanraman/5258053 to your computer and use it in GitHub Desktop.
multiple columns in IterableSource
import com.twitter.scalding._
class HistogramTest(args : Args) extends Job(args) {
IterableSource(List((1,2),(3,4),(5,6),(7,8)), List('a,'b))
.read
.map(('a,'b)->('c)){
x:(Int,Int) =>
x._1+x._2
}.write(Tsv("data/histo_test"))
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment