Looks like the build fails:

https://travis-ci.org/twitter/scalding/builds/3935538/#L3763




On Thu, Jan 3, 2013 at 9:09 AM, Arkajit Dey <notifications@github.com>wrote:

> In src/main/scala/com/twitter/scalding/RichPipe.scala:
>
> > +        .mapTo(()->('age, 'weight) { ... }
> > +        .partition('age -> 'isAdult) { _ > 18 } { _.average('weight) }
> > +      pipe now contains the average weights of adults and minors.
> > +   */
> > +  def partition[A,R](fs: (Fields, Fields))(fn: (A) => R)(
> > +    builder: GroupBuilder => GroupBuilder)(
> > +    implicit conv: TupleConverter[A],
> > +             ord: Ordering[R],
> > +             rset: TupleSetter[R]): Pipe = {
> > +    val (fromFields, toFields) = fs
> > +    conv.assertArityMatches(
> fromFields)
> > +    val tmpFields = new Fields("__temp__")
> > +    tmpFields.setComparator("__temp__", ord)
> > +    map(fromFields -> tmpFields)(fn)(conv, SingleSetter)
> > +      .groupBy(tmpFields)(builder)
> > +      .map[R,R](tmpFields -> toFields){ (r:R) => r }(singleConverter[R], rset)
>
> Done.
>
> —
> Reply to this email directly or view it on GitHub<https://github.com/twitter/scalding/pull/246/files#r2540862>.
>
>



-- 
Oscar Boykin :: @posco :: https://twitter.com/intent/user?screen_name=posco