userInfoBhv.batchUpdate(updateList); L330: searchLogList.stream().forEach(searchLog -> { L331: searchLog.getUserInfo().ifPresent(userInfo -> { L332: searchLog.setUserInfoId(userInfo.getId()); L333: }); L334: }); L335: if (fessConfig.isLoggingSearchUseLogfile()) { L336: insertList.forEach(this::writeSearchLogEvent); L337: updateList.forEach(this::writeSearchLogEvent); L338: } L339: }...

!= null) { L92: builder.setQuery(queryBuilder); L93: } L94: _conditionQuery.getFieldSortBuilderList().forEach(sort -> { L95: builder.addSort(sort); L96: }); L97: } L98: L99: if (_conditionAggregation != null) { L100: _conditionAggregation.getAggregationBuilderList().forEach(builder::addAggregation); L101: } L102: L103: if (_specification != null) { L104: builder.setFetchSource(_specifi...

!= null) { L92: builder.setQuery(queryBuilder); L93: } L94: _conditionQuery.getFieldSortBuilderList().forEach(sort -> { L95: builder.addSort(sort); L96: }); L97: } L98: L99: if (_conditionAggregation != null) { L100: _conditionAggregation.getAggregationBuilderList().forEach(builder::addAggregation); L101: } L102: L103: if (_specification != null) { L104: builder.setFetchSource(_specifi...

!= null) { L92: builder.setQuery(queryBuilder); L93: } L94: _conditionQuery.getFieldSortBuilderList().forEach(sort -> { L95: builder.addSort(sort); L96: }); L97: } L98: L99: if (_conditionAggregation != null) { L100: _conditionAggregation.getAggregationBuilderList().forEach(builder::addAggregation); L101: } L102: L103: if (_specification != null) { L104: builder.setFetchSource(_specifi...

aseSeed); L77: stream(baseTags).of(stream -> stream.forEach(tag -> popularWordsRequestBuilder.addTag(tag))); L78: stream(baseRoles).of(stream -> stream.forEach(role -> popularWordsRequestBuilder.addRole(role))); L79: stream(baseFields).of(stream -> stream.forEach(field -> popularWordsRequestBuilder.addField(field))); L80: stream(baseExcludes).of(stream -> stream.forEach(exclude -> popularWordsRequestBuilder.addExcludeWord(exclude))); L81:...

list) { L140: final String key = ComponentUtil.getVirtualHostHelper().getVirtualHostKey(); L141: keywordList.stream().forEach(keyword -> { L142: final List<Tuple3<String, QueryBuilder, ScoreFunctionBuilder<?>>> boostList = getQueryMap(key).get(toLowerCase(keyword)); L143: if (boostList != null) { L144: boostList.forEach(pair -> list.add(new FilterFunctionBuilder(pair.getValue2(), pair.getValue3()))); L145: } L146: }); L147: } L148:...

permissionSet.add(systemHelper.getSearchRoleByUser(values[0])); L108: } L109: } L110: stream(groups).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByGroup(s)))); L111: stream(roles).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByRole(s)))); L112: permissions = permissionSet.stream().filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]);...

unctions.date(expiredTime)) + ")."); L106: } L107: stream(accessToken.getPermissions()).of(stream -> stream.forEach(permissionSet::add)); L108: final String name = accessToken.getParameterName(); L109: stream(request.getParameterValues(name)).of(stream -> stream.filter(StringUtil::isNotBlank).forEach(permissionSet::add)); L110: return OptionalEntity.of(permissionSet); L111: }).orElseThrow(() -> new InvalidAcces...

!= null) { L92: builder.setQuery(queryBuilder); L93: } L94: _conditionQuery.getFieldSortBuilderList().forEach(sort -> { L95: builder.addSort(sort); L96: }); L97: } L98: L99: if (_conditionAggregation != null) { L100: _conditionAggregation.getAggregationBuilderList().forEach(builder::addAggregation); L101: } L102: L103: if (_specification != null) { L104: builder.setFetchSource(_specifi...

!= null) { L92: builder.setQuery(queryBuilder); L93: } L94: _conditionQuery.getFieldSortBuilderList().forEach(sort -> { L95: builder.addSort(sort); L96: }); L97: } L98: L99: if (_conditionAggregation != null) { L100: _conditionAggregation.getAggregationBuilderList().forEach(builder::addAggregation); L101: } L102: L103: if (_specification != null) { L104: builder.setFetchSource(_specifi...