I am trying to figure out a solution using Akka Stream but after spending couple of days couldn’t figure out how to solve this particular problem.
Following is my problem:
Source[String, NotUsed], following is an example of source:
abc,...,.... xyz,...,.. lmn,...,... xyz,...,... abc,...,...
Now we need to transfer given source to
Source[Map(String, Seq[String), NotUsed], where key of the map is the first value of each line of
CSV file. Once we have this we need to save the values of each key-value pair in separate file (actually it needs to save in the
S3) where name of the needs to be in the following format:
For example, name of one the file would be:
and its content would be:
Any suggestion how to approach this?