csvtask

CSVTask.scala

object CSVTask {

  def apply(name: String, file: File)(implicit plugins: PluginSet) =
    new TaskBuilder { builder ⇒

      private var _columns = new ListBuffer[(String, Prototype[_])]

      def columns = _columns.toList

      def addColumn(proto: Prototype[_]): this.type = this.addColumn(proto.name, proto)
      def addColumn(name: String, proto: Prototype[_]): builder.type = {
        _columns += (name -> proto)
        this
      }

      def toTask = new CSVTask(name, file) {
        val inputs = builder.inputs
        val outputs = builder.outputs
        val parameters = builder.parameters
        val columns = builder.columns
      }

    }

}