Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
def tabCounter() = {
implicit def input = getInput()'\t').size).reduce(_ + _)
val task = LuigiTask().requires(MyTsvJob(buildId)).output(HdfsTarget("output")).do(tabCounter)
val otherTask = LuigiTask().requires(task).output(HdfsTarget("output-2")).do(somethingElse) // schedule task and otherTask
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment