PipelineSteps.kt

typealias SpitedFileLine = List<String>
typealias FileLine = String
fun splitCsvLine(): MapElements<FileLine, SpitedFileLine> {
    return MapElements.into(
            TypeDescriptors.lists(
                    TypeDescriptor.of(String::class.java)
            )
    )
    .via(ProcessFunction<FileLine, SpitedFileLine> {
           it.split(",") 
     })
}