CsvLogRecordParser { String[] constructFieldNames(String[] headers, String fileType, boolean cleanKeysForES) { String[] fieldNames = new String[headers.length]; for (int i = 0; i < headers.length; i++) { String fieldName = constructFieldName(fileType, i, headers[i]); fieldNames[i] = cleanKeysForES ? ElasticsearchUtil.cleanKey(fieldName) : fieldName; } return fieldNames; } CsvLogRecordParser(CsvLogRecordParserConfig csvLogRecordParserConfig); void parse(Reader fileReader, String fileType, LogRecordCollector collector);  }
@Test public void testConstructFieldNames() { assertThat(parser.constructFieldNames(new String[]{"field-meh"}, "type", true)[0], is("type_00000_field_meh")); }