case class Foo(i: Int, x: Long, s: String)
case class Bar(ij: Long, ss: String)
val pipeline: DataPipelineT[F, Bar, E] = ???
pipeline.withColumn[Foo](_ / 2)
select:
case class Foo(i: Int, x: Long, s: String)
case class Bar(ij: Long, ss: String)
val pipeline: DataPipelineT[F, Foo, E] = ???
pipeline.select[Bar](a => a.i + a.j, _.s * 2)
Add the following methods (like in sparksql):