Reading and Writing Case Classes in Scalding Reading and Writing Case Classes in Scalding hadoop hadoop

Reading and Writing Case Classes in Scalding


One way would be to use pack and unpack.

pipe  .unpack[Moments]('appearanceMoments -> ('m0, 'm1, 'm2, 'm3, 'm4))  .write(Tsv(outputPath))Tsv(args("input"), ('term, 'm0, 'm1, 'm2, 'm3, 'm4).read  .pack[Moments](('m0, 'm1, 'm2, 'm3, 'm4) -> 'appearanceMoments)