search

twitter / scalding

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

Extend TextLine with TypedSink #1752

Closed snoble closed 6 years ago

snoble commented 6 years ago

https://github.com/twitter/scalding/issues/1751

attn @johnynek

johnynek commented 6 years ago

can we add a test to https://github.com/twitter/scalding/blob/develop/scalding-core/src/test/scala/com/twitter/scalding/TypedPipeTest.scala. We should use .runHadoop I think to test it out.

snoble commented 6 years ago

@johnynek test added

snoble commented 6 years ago

I'll figure out why this test is failing tomorrow

johnynek commented 6 years ago

Nice work @snoble ! Thanks for fixing this broken window!