Constants.SEARCH_LOG_ACCESS_TYPE_JSON); L228: final JsonRequestParams params = new JsonRequestParams(request, fessConfig); L229: try { L230: response.setContentType("application/x-ndjson; charset=UTF-8"); L231: final long count = searchHelper.scrollSearch(params, doc -> { L232: buf.setLength(0); L233: buf.append('{'); L234: boolean first2 = true; L235: for (final Map.Entry<String, Object> entry : doc.entrySet())...

tName())).append("\":{"); L99: append(b, "count", () -> c.getCollectionCount()).append(','); L100: append(b, "time", () -> c.getCollectionTime().getMillis()).append('}'); L101: return b.toString(); L102: }).collect(Collectors.joining(","))); L103: buf.append("},"); L104: final Threads threads = jvmStats.getThreads(); L105: buf.append("\"threads\":{"); L106: append(buf, "count", () -> threads.getCount()).append(','); L107: ...

null) { L84: final long totalHits = innerSearchHits.getTotalHits().value; L85: if (totalHits > 1) { L86: docMap.put(fessConfig.getQueryCollapseInnerHitsName() + "_count", totalHits); L87: final DocumentField bitsField = searchHit.getFields().get(fessConfig.getIndexFieldContentMinhashBits()); L88: if (bitsField != null && !bitsField.getValues().isEmpty())...

if ("term".equals(values[0]) || "key".equals(values[0])) { L77: return BucketOrder.key(asc); L78: } L79: if ("count".equals(values[0])) { L80: return BucketOrder.count(asc); L81: } L82: } L83: } L84: return BucketOrder.count(false); L85: } L86: L87: public void addQuery(final String s) { L88: if (query == null) { L89: query = new String[] { s }; L90: } else...

logger = LogManager.getLogger(PurgeThumbnailJob.class); L24: L25: private long expiry = 30 * 24 * 60 * 60 * 1000L; L26: L27: public String execute() { L28: try { L29: final long count = ComponentUtil.getThumbnailManager().purge(getExpiry()); L30: return "Deleted " + count + " thumbnail files."; L31: } catch (final Exception e) { L32: logger.error("Failed to purge thumbnails.", e); L33: return e.getMessage(); L34: } L35: } L36: L37:...

ComponentUtil.getSystemProperties().getProperty(OIC_CLIENT_SECRET, StringUtil.EMPTY); L265: } L266: L267: protected String getOicTokenServerUrl() { L268: return ComponentUtil.getSystemProperties().getProperty(OIC_TOKEN_SERVER_URL, "https://accounts.google.com/o/oauth2/token"); L269: } L270: L271: protected String getOicRedirectUrl() { L272: return ComponentUtil.getSystemProperties().getProperty(OIC_REDIRECT_URL, "http://localhost:8080/sso/"); L273: } L274: L275: protected...

(StringUtil.isBlank(body.q)) { L209: throwValidationErrorApi(messages -> messages.addErrorsInvalidQueryUnknown(GLOBAL)); L210: } L211: try { L212: final long count = searchHelper.deleteByQuery(request, body); L213: return asJson(new ApiDeleteResponse().count(count).status(Status.OK).result()); L214: } catch (final InvalidQueryException e) { L215: if (logger.isDebugEnabled()) { L216: logger.debug(e.getMessage(), e); L217:...

L643: return true; L644: } L645: L646: public void waitForNoWaitingThreads() { L647: int count = waitingThreadNames.size(); L648: while (count > 0) { L649: if (logger.isInfoEnabled()) { L650: logger.info("{} waiting thread(s).", count); L651: } L652: ThreadUtil.sleep(systemCpuCheckInterval); L653: count = waitingThreadNames.size(); L654: } L655: } L656: L657: protected short getSystemCpuPercent() {...

facetFields) { L294: if (field.equals(f)) { L295: flag = true; L296: } L297: } L298: return flag; L299: } L300: L301: public boolean isFacetSortValue(final String sort) { L302: return "count".equals(sort) || "index".equals(sort); L303: } L304: L305: public void setApiResponseFields(final String[] fields) { L306: apiResponseFieldSet = new HashSet<>(); L307: Collections.addAll(apiResponseFieldSet, fields); L308: }...

.aggregations.bucket.terms.TermsAggregationBuilder; L49: L50:public class CrawlingInfoHelper { L51: private static final Logger logger = LogManager.getLogger(CrawlingInfoHelper.class); L52: L53: public static final String FACET_COUNT_KEY = "count"; L54: L55: protected Map<String, String> infoMap; L56: L57: protected Long documentExpires; L58: L59: protected int maxSessionIdsInList; L60: L61: protected CrawlingInfoService getCrawlingInfoService() { L62: return ComponentUt...