ArrayList<>(); L134: try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) { L135: long id = 0; L136: String line = null; L137: while ((line = reader.readLine()) != null) { L138: // Remove comments L139: final String replacedLine = line.replaceAll("#.*$", StringUtil.EMPTY).trim(); L140: L141: // Skip empty lines or comment lines L142: if (replacedLine.length() == 0) { L143:...

ArrayList<>(); L134: try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) { L135: long id = 0; L136: String line = null; L137: while ((line = reader.readLine()) != null) { L138: // Remove comments L139: final String replacedLine = line.replaceAll("#.*$", StringUtil.EMPTY).trim(); L140: L141: // Skip empty lines or comment lines L142: if (replacedLine.length() == 0) { L143:...

Stream(), Constants.CHARSET_UTF_8))) { L200: String line; L201: while ((line = br.readLine()) != null) { L202: if (StringUtil.isNotBlank(line)) { L203: final Map<String, Map<String, String>> dataObj; L204: if (line.contains("\"_index\"") || line.contains("\"_type\"")) { L205: dataObj = parseObject(mapper, line); L206: } else { L207: ...

} L165: } L166: L167: protected int getBoundaryLimitSize() { L168: // one HTTP proxy tool already limits the size (e.g. 3450 bytes) L169: // so specify this size for test L170: return 2000; // you can override as you like it L171: } L172: L173: protected void throwTooLongBoundarySizeException(final String contentType, final int boundarySize, final int limitSize) { L174: final ExceptionMessageBuilder br = new ExceptionMessageBuilder(); L175: br.addNotice("Too...

reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) { L127: long id = 0; L128: String line = null; L129: while ((line = reader.readLine()) != null) { L130: if (line.length() == 0 || line.charAt(0) == '#') { L131: if (updater != null) { L132: updater.write(line); L133: } L134: continue; // ignore empty lines and comments L135: } L136: L137:...

reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) { L127: long id = 0; L128: String line = null; L129: while ((line = reader.readLine()) != null) { L130: if (line.length() == 0 || line.charAt(0) == '#') { L131: if (updater != null) { L132: updater.write(line); L133: } L134: continue; // ignore empty lines and comments L135: } L136: L137:...

Arrays.stream(FileUtil.readUTF8(dataPath).split("\n")).map(line -> line// L756: .replace("\"_index\":\"fess_config.", "\"_index\":\"" + fessConfig.getIndexConfigIndex() + ".")// L757: .replace("\"_index\":\"fess_user.", "\"_index\":\"" + fessConfig.getIndexUserIndex() + ".")// L758: .replace("\"_index\":\"fess_log.", "\"_index\":\"" + fessConfig.getIndexLogIndex() + ".")).reduce((prev, line) -> { L759: try { L760: ...

stream.filter(StringUtil::isNotBlank).map(String::trim).forEach(line -> { L169: if (!line.startsWith("#")) { L170: final String urlValue; L171: if (urlEncodeDisabled.get()) { L172: urlValue = line; L173: urlEncodeDisabled.set(false); L174: } else { L175: urlValue = systemHelper.encodeUrlFilter(line); L176: } L177: crawler...

reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) { L128: long id = 0; L129: String line = null; L130: while ((line = reader.readLine()) != null) { L131: if (line.length() == 0 || line.charAt(0) == '#') { L132: if (updater != null) { L133: updater.write(line); L134: } L135: continue; // ignore empty lines and comments L136: } L137: L138:...

ArrayList<>(); L127: try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) { L128: long id = 0; L129: String line = null; L130: while ((line = reader.readLine()) != null) { L131: // Remove comments L132: final String replacedLine = line.replaceAll("#.*$", StringUtil.EMPTY).trim(); L133: L134: // Skip empty lines or comment lines L135: if (replacedLine.length() == 0) { L136:...