Static Function that can be used as a map lambda to translate a string into the columns for a Spark Dataframe.

ParseFlatFile.java

import org.apache.spark.sql.*;

/**
 * Parses a line of a fixed width flat file
 * @param pos list of integers describing the width of each column of the flat file
 * @param str line of the fixed width flat file
 * @return Row containing data from fixed width flat file line
 */
public static Row lSplit(List<Integer> pos, String str) {

    List<String> cols = new ArrayList<>();
    int start = 0;
    for (Integer col_pos : pos) {
        parseCol(str, col_pos, start, cols);
        start += col_pos;
    }
    return RowFactory.create(cols.toArray());
}