public void setQueryBuilder(final QueryBuilder queryBuilder) { L111: this.queryBuilder = queryBuilder; L112: } L113: L114: public void addSorts(final SortBuilder<?>... sortBuilders) { L115: stream(sortBuilders).of(stream -> stream.forEach(sortBuilder -> sortBuilderList.add(sortBuilder))); L116: } L117: L118: public boolean hasSorts() { L119: return !sortBuilderList.isEmpty(); L120: } L121: L122: public List<SortBuilder<?>> sortBuilders() { L123: return sortBuilderList;...

}); L61: } L62: L63: @Override L64: public int load() { L65: final Map<String, Pair<Map<String, String>, List<Pair<Pattern, String>>>> relatedContentMap = new HashMap<>(); L66: getAvailableRelatedContentList().stream().forEach(entity -> { L67: final String key = getHostKey(entity); L68: Pair<Map<String, String>, List<Pair<Pattern, String>>> pair = relatedContentMap.get(key); L69: if (pair == null) { L70: pair = new Pair<>(new...

tIndexFieldBoost(), config.getBoost().toString()); L100: // label: labelType L101: // role: roleType L102: final List<String> roleTypeList = new ArrayList<>(); L103: stream(config.getPermissions()).of(stream -> stream.forEach(p -> roleTypeList.add(p))); L104: defaultDataMap.put(fessConfig.getIndexFieldRole(), roleTypeList); L105: // mimetype L106: defaultDataMap.put(fessConfig.getIndexFieldMimetype(), mimeType); L107: // title L108: //...

this; L51: } L52: L53: public PythonJob arg(final String value) { L54: argList.add(value); L55: return this; L56: } L57: L58: public PythonJob args(final String... values) { L59: stream(values).of(stream -> stream.forEach(argList::add)); L60: return this; L61: } L62: L63: @Override L64: public String execute() { L65: final StringBuilder resultBuf = new StringBuilder(); L66: L67: if (sessionId == null) { // create session id L68: ...

response = esCb.build(builder).execute().actionGet(searchTimeout); L146: L147: final EsPagingResultBean<RESULT> list = new EsPagingResultBean<>(builder); L148: final SearchHits searchHits = getSearchHits(response); L149: searchHits.forEach(hit -> { L150: final Map<String, Object> source = hit.getSourceAsMap(); L151: final RESULT entity = createEntity(source, entityType); L152: final DocMeta docMeta = ((EsAbstractEntity) entity).asDocMeta(); L153: ...

response = esCb.build(builder).execute().actionGet(searchTimeout); L146: L147: final EsPagingResultBean<RESULT> list = new EsPagingResultBean<>(builder); L148: final SearchHits searchHits = getSearchHits(response); L149: searchHits.forEach(hit -> { L150: final Map<String, Object> source = hit.getSourceAsMap(); L151: final RESULT entity = createEntity(source, entityType); L152: final DocMeta docMeta = ((EsAbstractEntity) entity).asDocMeta(); L153: ...

L287: cmdList.add("-Dorg.apache.tika.service.error.warn=true"); L288: } L289: } L290: stream(fessConfig.getJvmCrawlerOptionsAsArray()) L291: .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(value -> cmdList.add(value))); L292: L293: File ownTmpDir = null; L294: final String tmpDir = System.getProperty("java.io.tmpdir"); L295: if (fessConfig.isUseOwnTmpDir() && StringUtil.isNotBlank(tmpDir)) { L296: ownTmpDir...

logger.debug("{} does not exists.", dir); L111: } L112: return; L113: } L114: try (Stream<Path> walk = Files.walk(dir, FileVisitOption.FOLLOW_LINKS)) { L115: walk.sorted(Comparator.reverseOrder()).forEach(f -> { L116: if (logger.isDebugEnabled()) { L117: logger.debug("Deleting {}", f); L118: } L119: try { L120: Files.delete(f); L121: } catch (final IOException...

ls(scheme)) { L69: final Properties props = new Properties(); L70: getWebConfig().getConfigParameterMap(ConfigName.CONFIG).entrySet().stream() L71: .filter(e -> e.getKey().startsWith(Config.JCIFS_PREFIX)).forEach(e -> { L72: props.setProperty(e.getKey(), e.getValue()); L73: }); L74: return new NTLMScheme(new JcifsEngine(props)); L75: } L76: if (Constants.FORM.equals(scheme)) { L77: ...

L104: } L105: } L106: } L107: } catch (final IOException e) { L108: logger.warn("Cannot load subpackages from {}", basePackage, e); L109: } L110: L111: subPackages.stream().forEach(protocol -> { L112: try { L113: final Class<Object> handlerClazz = ClassUtil.forName(basePackage + "." + protocol + ".Handler"); L114: final Field protocolTypeField = ClassUtil.getDeclaredField(handlerClazz,...