This looks awesome. I wonder if  implicit transformer: Bijection[T, U])
would have serialization issues or should be lazy?


On Thu, May 29, 2014 at 1:09 PM, ianoc <notifications@github.com> wrote:

> In
> scalding-core/src/main/scala/com/twitter/scalding/typed/BijectedSourceSink.scala:
>
> > +*/
> > +package com.twitter.scalding.typed
> > +
> > +import cascading.flow.FlowDef
> > +import cascading.pipe.Pipe
> > +
> > +import com.twitter.bijection.Bijection
> > +import com.twitter.scalding._
> > +
> > +
> > +object BijectedSourceSink {
> > +  type SourceSink[T] = TypedSource[T] with TypedSink[T]
> > +  def apply[T, U](parent: SourceSink[T])(implicit transformer: Bijection[T, U]) = new BijectedSourceSink(parent)(transformer)
> > +}
> > +
> > +class BijectedSourceSink[T, U](parent: BijectedSourceSink.SourceSink[T])(implicit transformer: Bijection[T, U]) extends TypedSource[U] with TypedSink[U] {
>
> had tried that, it didn't like extending off the class defined type for
> some reason
>
> —
> Reply to this email directly or view it on GitHub
> <https://github.com/twitter/scalding/pull/886/files#r13195197>.
>