Skip to content

Instantly share code, notes, and snippets.

@bbrooks
Last active November 16, 2018 20:28
Show Gist options
  • Save bbrooks/f6f887464d4bfa07cad5528f5d330d26 to your computer and use it in GitHub Desktop.
Save bbrooks/f6f887464d4bfa07cad5528f5d330d26 to your computer and use it in GitHub Desktop.
import com.twitter.scalding.{PipeDebug}
birds
// You can dump out the current pipe contents to the console.
// This is useful when writing tests to see what your transforms are actually doing
.debug(PipeDebug().toStdOut.withPrefix("before adding doubleSpeed field"))
.map('speed -> 'doubledSpeed) { speed : Int => speed * 2 }
.debug(PipeDebug().toStdOut.withPrefix("after adding doubleSpeed field"))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment