in beam-collector/src/main/java/com/google/collector/loaders/LoadFromCsv.java [64:76]
private ImmutableList<String> loadColumns(ProcessContext ctx) {
ImmutableList.Builder<String> values = ImmutableList.builder();
try (Scanner rowScanner = new Scanner(
ctx.element().replaceAll("\n", "")
)) {
rowScanner.useDelimiter(",");
while (rowScanner.hasNext()) {
values.add(rowScanner.next());
}
}
return values.build();
}