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(/...

(opLambda != null) { L62: opLambda.callback(builder); L63: } L64: if (aggsLambda != null) { L65: KeyMatchCA ca = new KeyMatchCA(); L66: aggsLambda.callback(ca); L67: ca.getAggregationBuilderList().forEach(builder::subAggregation); L68: } L69: } L70: L71: public void global(String name, ConditionOptionCall<GlobalAggregationBuilder> opLambda, OperatorCall<BsKeyMatchCA> aggsLambda) { L72: GlobalAggregationBuilder builder = regGlobalA(name);...

split(fessConfig.getSuggestFieldContents(), ",") L95: .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(contentFieldNameSet::add)); L96: split(fessConfig.getSuggestFieldTags(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(tagFieldNameSet::add)); L97: split(fessConfig.getSuggestFieldRoles(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(roleFieldNameSet::add)); L98: contentFieldList = Arrays.asList(stream(fessConfig.getSuggestField...

{ L62: opLambda.callback(builder); L63: } L64: if (aggsLambda != null) { L65: DuplicateHostCA ca = new DuplicateHostCA(); L66: aggsLambda.callback(ca); L67: ca.getAggregationBuilderList().forEach(builder::subAggregation); L68: } L69: } L70: L71: public void global(String name, ConditionOptionCall<GlobalAggregationBuilder> opLambda, OperatorCall<BsDuplicateHostCA> aggsLambda) { L72: GlobalAggregationBuilder builder = regGlobalA(name);...

(opLambda != null) { L62: opLambda.callback(builder); L63: } L64: if (aggsLambda != null) { L65: RoleTypeCA ca = new RoleTypeCA(); L66: aggsLambda.callback(ca); L67: ca.getAggregationBuilderList().forEach(builder::subAggregation); L68: } L69: } L70: L71: public void global(String name, ConditionOptionCall<GlobalAggregationBuilder> opLambda, OperatorCall<BsRoleTypeCA> aggsLambda) { L72: GlobalAggregationBuilder builder = regGlobalA(name);...

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

} 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)...

fessConfig.invalidIndexRequiredFields(doc).stream().map(s -> "doc." + s) L343: .forEach(s -> messages.addErrorsPropertyRequired(s, s))); L344: } L345: L346: if (!fessConfig.validateIndexArrayFields(doc)) { L347: throwError.accept(messages -> fessConfig.invalidIndexArrayFields(doc).stream().map(s -> "doc." + s) L348: .forEach(s -> messages.addErrorsPropertyRequired(s, s))); L349: } L350: if (!fessCo...