L508: stream(user.getGroupNames()).of(stream -> stream.forEach(name -> { L509: if (oldGroupList.contains(name)) { L510: oldGroupList.remove(name); L511: newGroupList.remove(name); L512: } L513: })); L514: oldGroupList.stream().forEach(name -> { L515: search(fessConfig.getLdapAdminGroupBaseDn(),...

(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);...

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

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

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

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

final DuplicateHostHelper duplicateHostHelper = ComponentUtil.getDuplicateHostHelper(); L154: L155: // set urls L156: split(urlsStr, "[\r\n]").of(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim).distinct().forEach(urlValue -> { L157: if (!urlValue.startsWith("#") && protocolHelper.isValidWebProtocol(urlValue)) { L158: final String u = duplicateHostHelper.convert(urlValue); L159: crawler.addUrl(u); L160: ...

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

Fields(final String... fields) { L1630: final List<String> list = new ArrayList<>(fields.length + 10); L1631: stream(fields).of(stream -> stream.forEach(list::add)); L1632: split(getQueryAdditionalResponseFields(), ",") L1633: .of(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim).forEach(list::add)); L1634: return list.toArray(new String[list.size()]); L1635: } L1636: L1637: String getQueryAdditionalScrollResponseFields(); L1638: L1639:...

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