(opLambda != null) { L52: opLambda.callback(builder); L53: } L54: if (aggsLambda != null) { L55: RoleCA ca = new RoleCA(); L56: aggsLambda.callback(ca); L57: ca.getAggregationBuilderList().forEach(builder::subAggregation); L58: } L59: } L60: L61: public void global(String name, ConditionOptionCall<GlobalAggregationBuilder> opLambda, OperatorCall<BsRoleCA> aggsLambda) { L62: GlobalAggregationBuilder builder = regGlobalA(name);...

ator({name:"hex",validatorFunction:function(a,b){if("true"===b.valAttr("allow-transparent")&&"transparent"===a)return!0;var c="#"===a[0];if(!c)return!1;var d=4===a.length||7===a.length;if(d){var e=/[0-9a-f]/i,f=a.slice(1).split(""),g=!0;return f.forEach(function(a){null===a.match(e)&&(g=!1)}),g}return!1},errorMessage:"",errorMessageKey:"badHex"}),a.formUtils.addValidator({name:"rgb",validatorFunction:function(a,b){if("true"===b.valAttr("allow-transparent")&&"transparent"===a)return!0;var c=a.replace(/...

} L73: L74: stream(params.getExtraQueries()) L75: .of(stream -> stream.filter(q -> StringUtil.isNotBlank(q) && q.length() <= maxQueryLength).forEach(q -> { L76: appendQuery(queryBuf, q); L77: })); L78: L79: stream(params.getFields()).of(stream -> stream.forEach(entry -> { L80: final String key = entry.getKey(); L81: final String[] values = entry.getValue(); L82: if (values == null) { L83: ...

final Map<String, List<QueryBuilder>> geoMap = new HashMap<>(); L44: L45: StreamUtil.stream(request.getParameterMap()) L46: .of(stream -> stream.filter(e -> e.getKey().startsWith("geo.") && e.getKey().endsWith(".point")).forEach(e -> { L47: final String key = e.getKey(); L48: for (final String geoField : geoFields) { L49: if (key.startsWith("geo." + geoField + ".")) { L50: final String...

public void insert(final User user) { L30: chains().of(stream -> stream.forEach(c -> c.update(user))); L31: } L32: L33: public boolean changePassword(final String username, final String password) { L34: return chains().get(stream -> stream.allMatch(c -> c.changePassword(username, password))); L35: } L36: L37: public void delete(final User user) { L38: chains().of(stream -> stream.forEach(c -> c.delete(user))); L39: } L40: L41: public User load(final User user)...

!= null && k.toString().startsWith(Constants.FESS_CONFIG_PREFIX)) L152: .forEach(k -> addSystemProperty(cmdList, k.toString(), null, null)); L153: } L154: L155: protected void addFessSystemProperties(final List<String> cmdList) { L156: System.getProperties().keySet().stream().filter(k -> k != null && k.toString().startsWith(Constants.SYSTEM_PROP_PREFIX)) L157: .forEach(k -> addSystemProperty(cmdList, k.toString(), null, null)); L158: } L159: L160: protected...

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:...

!= 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...