private ImmutableList loadColumns()

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();
  }