} L733: } L734: L735: final StringBuilder buf = new StringBuilder(255); L736: buf.append("\"record_count\":").append(docIdList.size()); L737: buf.append(", \"data\":["); L738: if (!docIdList.isEmpty()) { L739: for (int i = 0; i < docIdList.size(); i++) { L740: if (i > 0) { L741: buf.append(','); L742: } L743: buf.append('{').append(esc...

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: default String[] getQueryAdditionalScrollResponseFields(final String... fields) { L1640: final List<String> list = new ArrayList<>(fields.length...

} L1295: L1296: public SearchConditionBuilder offset(final int offset) { L1297: this.offset = offset; L1298: return this; L1299: } L1300: L1301: public SearchConditionBuilder size(final int size) { L1302: this.size = size; L1303: return this; L1304: } L1305: L1306: public SearchConditionBuilder geoInfo(final GeoInfo geoInfo) { L1307: this.geoInfo = geoInfo; L1308: return this; L1309: } L1310:...

ToString(name.getBytes(Constants.CHARSET_UTF_8))); L462: } L463: }); L464: user.setGroups(groupList.toArray(new String[groupList.size()])); L465: user.setRoles(roleList.toArray(new String[roleList.size()])); L466: } L467: }); L468: L469: } L470: L471: public void insert(final User user) { L472: if (!fessConfig.isLdapAdminEnabled(user.getName())) { L473: ...

L1438: L1439: private void upgradeFrom14_16() { L1440: // nothing L1441: } L1442: L1443: private String[] getDictionaryPaths() { L1444: try (CurlResponse response = ComponentUtil.getCurlHelper().get("/_configsync/file").param("size", "1000").execute()) { L1445: if (response.getHttpStatusCode() == 200) { L1446: final Map<String, Object> contentMap = response.getContent(OpenSearchCurl.jsonParser()); L1447: if (contentMap.get("path") instanceof...