rapture-csv in Ammonite REPL

after.csv

before.csv

build.sbt

scalaVersion := "2.11.8"

// copied from http://www.lihaoyi.com/Ammonite/#Ammonite-REPLinSBT

libraryDependencies += "com.lihaoyi" % "ammonite-repl" % "0.5.7" %
"test" cross CrossVersion.full

initialCommands in (Test, console) := """ammonite.repl.Main.run("")"""

repl_session.txt

// started with `s// start REPL with `sbt test:console`

load.ivy("com.propensive" %% "rapture-csv" % "2.0.0-M5")

import rapture.uri._

// to support "file://" URLs
import rapture.fs._ 

val file_before = uri"file:///tmp/before.csv"  
val file_after = uri"file:///tmp/after.csv"  


// so we know how to decode the bytes on disk
import rapture.codec.encodings.`UTF-8`._

// so we know how to parse CSV
import rapture.csv._
import rapture.csv.csvBackends.simple._


val c1 = Csv.parse(file_before)
val c2 = Csv.parse(file_after)


// now we can explore, for example...
c1.filter( i => i(1).toString.startsWith("F") ) 


// goal: map old territory IDs to new

// we'll include a filter to keep the results smaller for discussion
val letter = "J"

val byEmp1 = c1.
  filter( i => i(1).toString.startsWith(letter) ).
  map( i => ( i(4).toString, i(0).toString ) ).toMap 

val byEmp2 = c2.
  filter( i => i(1).toString.startsWith(letter) ).
  map( i => ( i(4).toString, i(0).toString ) ).toMap 


val mapping = byEmp1.map( b => (b._2, byEmp2(b._1) ) )