i)}return n}function l(o){for(var t=1;t<arguments.length;t++){var r=null!=arguments[t]?arguments[t]:{};t%2?e(Object(r),!0).forEach(function(t){var e,n,i;e=o,i=r[n=t],n in e?Object.defineProperty(e,n,{value:i,enumerable:!0,configurable:!0,writable:!0}):e[n]=i}):Object.getOwnPropertyDescriptors?Object.defineProperties(o,Object.getOwnPropertyDescriptors(r)):e(Object(r)).forEach(function(t){Object.defineProperty(o,t,Object.getOwnPropertyDescriptor(r,t))})}return o}g=g&&g.hasOwnProperty("default")?g....

newLabelSet = new HashSet<>(); L109: final String[] oldLabels = DocumentUtil.getValue(dataMap, fessConfig.getIndexFieldLabel(), String[].class); L110: StreamUtil.stream(oldLabels).of(stream -> stream.forEach(newLabelSet::add)); L111: matchedLabelSet.stream().forEach(newLabelSet::add); L112: dataMap.put(fessConfig.getIndexFieldLabel(), newLabelSet.toArray(new String[newLabelSet.size()])); L113: } L114: L115: if (!dataMap.containsKey(fessConfig.getIndexFieldDocId()))...

catch (final Exception e) { L188: logger.warn("Failed to access /_{}/{}", v1, v2, e); L189: } L190: } L191: L192: protected void writeFesenCat(final ZipOutputStream zos, final String id) { L193: Arrays.stream(CAT_NAMES).forEach(name -> { L194: final ZipEntry entry = new ZipEntry(id + "/es_cat_" + name + ".txt"); L195: try { L196: zos.putNextEntry(entry); L197: try (CurlResponse response = ComponentUtil.getCurlHelper().get("/_cat/"...

L121: L122: public static List<Map<String, String>> getFessPropItems(final FessConfig fessConfig) { L123: final List<Map<String, String>> itemList = new ArrayList<>(); L124: ComponentUtil.getSystemProperties().entrySet().stream().forEach(e -> { L125: final String k = e.getKey().toString(); L126: final String value; L127: if (isMaskedValue(k)) { L128: value = MASKED_VALUE; L129: } else { L130: value = e.getValue().toString();...

eryMaxFetchSizeAsInteger()); L52: }); L53: } L54: L55: @Override L56: public int load() { L57: final Map<String, Map<String, String[]>> relatedQueryMap = new HashMap<>(); L58: getAvailableRelatedQueryList().stream().forEach(entity -> { L59: final String key = getHostKey(entity); L60: Map<String, String[]> map = relatedQueryMap.get(key); L61: if (map == null) { L62: map = new HashMap<>(); L63: relatedQueryMap.put(key,...

L176: } L177: } catch (final ChildUrlsException e) { L178: crawlerStatsHelper.record(keyObj, StatsAction.CHILD_URLS); L179: e.getChildUrlList().stream().map(RequestData::getUrl).forEach(urlQueue::offer); L180: } catch (final DataStoreCrawlingException e) { L181: crawlerStatsHelper.record(keyObj, StatsAction.ACCESS_EXCEPTION); L182: final Throwable cause = e.getCause(); L183: ...

fessConfig.getMailFromName()); L61: postcard.addReplyTo(fessConfig.getMailReturnPath()); L62: if (toAddresses.length > 0) { L63: stream(toAddresses).of(stream -> stream.map(String::trim).forEach(address -> { L64: postcard.addTo(address); L65: })); L66: } else { L67: postcard.addTo(fessConfig.getMailFromAddress()); L68: ...

LogManager.getLogger(ScoreUpdater.class); L26: L27: private final List<ScoreBooster> scoreBoosterList = new ArrayList<>(); L28: L29: public String execute() { L30: final StringBuilder resultBuf = new StringBuilder(); L31: scoreBoosterList.forEach(b -> { L32: try { L33: final long count = b.process(); L34: resultBuf.append(b.getClass().getSimpleName()).append(" : ").append(count).append('\n'); L35: } catch (final Exception e) { L36: ...

.ENGLISH)); L125: valueMap.put("user", user.map(FessUserBean::getUserId).orElse("-")); L126: final Comparator<Map.Entry<String, String>> c = Comparator.comparing(Map.Entry::getKey); L127: params.entrySet().stream().sorted(c).forEach(e -> { L128: valueMap.put(e.getKey(), e.getValue().replace('\t', '_')); L129: }); L130: log(valueMap); L131: } L132: L133: protected void log(final Map<String, String> valueMap) { L134: valueMap.put("ip", getClientIp());...

@PostConstruct L29: public void register() { L30: final CorsHandlerFactory factory = ComponentUtil.getCorsHandlerFactory(); L31: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L32: fessConfig.getApiCorsAllowOriginList().forEach(s -> factory.add(s, this)); L33: } L34: L35: @Override L36: public void process(final String origin, final ServletRequest request, final ServletResponse response) { L37: final FessConfig fessConfig = ComponentUtil.getFessConfig();...