sb.append(dm).append(updatedTime); L129: sb.append(dm).append(virtualHost); L130: if (sb.length() > dm.length()) { L131: sb.delete(0, dm.length()); L132: } L133: sb.insert(0, "{").append("}"); L134: return sb.toString(); L135: } L136: L137: // =================================================================================== L138: // Accessor L139: // ...

sb.append(dm).append(userSessionId); L206: sb.append(dm).append(virtualHost); L207: if (sb.length() > dm.length()) { L208: sb.delete(0, dm.length()); L209: } L210: sb.insert(0, "{").append("}"); L211: return sb.toString(); L212: } L213: L214: // =================================================================================== L215: // Accessor L216: // ...

synchronized void update(final InputStream in) throws IOException { L204: try (MappingUpdater updater = new MappingUpdater(null)) { L205: reload(updater, in); L206: } L207: } L208: L209: @Override L210: public String toString() { L211: return "MappingFile [path=" + path + ", mappingItemList=" + mappingItemList + ", id=" + id + "]"; L212: } L213: L214: protected class MappingUpdater implements Closeable { L215: L216: protected boolean isCommit = false;...

InterruptedException e) { L456: logger.warn("Interrupted index update.", e); L457: } L458: L459: crawlingInfoHelper.putToInfoMap(Constants.WEB_FS_INDEX_EXEC_TIME, Long.toString(indexUpdater.getExecuteTime())); L460: crawlingInfoHelper.putToInfoMap(Constants.WEB_FS_INDEX_SIZE, Long.toString(indexUpdater.getDocumentSize())); L461: L462: if (systemHelper.isForceStop()) { L463: return; L464: } L465: L466: for (final String sid : sessionIdList) {...

L82: public Long getVersionNo() { L83: return asDocMeta().version(); L84: } L85: L86: public void setVersionNo(final Long version) { L87: asDocMeta().version(version); L88: } L89: L90: @Override L91: public String toString() { L92: return "ScheduledJob [available=" + available + ", crawler=" + crawler + ", createdBy=" + createdBy + ", createdTime=" + createdTime L93: + ", cronExpression=" + cronExpression + ", jobLogging=" + jobLogging + ", name="...

Float) { L69: return (Float) value; L70: } L71: if (value instanceof Double) { L72: return ((Double) value).floatValue(); L73: } L74: if (value != null) { L75: return Float.parseFloat(value.toString()); L76: } L77: L78: return 0.0f; L79: } L80: L81: public String getBoostExpression() { L82: return boostExpression; L83: } L84: L85: public void setBoostExpression(final String expression) { L86: boostExpression...

sb.append(dm).append(updatedBy); L136: sb.append(dm).append(updatedTime); L137: if (sb.length() > dm.length()) { L138: sb.delete(0, dm.length()); L139: } L140: sb.insert(0, "{").append("}"); L141: return sb.toString(); L142: } L143: L144: // =================================================================================== L145: // Accessor L146: // ...

header; L95: throwValidationError(messages -> messages.addErrorsInvalidHeaderForRequestFile(GLOBAL, msg), () -> asListHtml(this::saveToken)); L96: } else { L97: try (final CurlResponse response = curlRequest.body(buf.toString()).execute()) { L98: final File tempFile = ComponentUtil.getSystemHelper().createTempFile("esreq_", ".json"); L99: try (final InputStream in = response.getContentAsStream()) { L100: CopyUtil.copy(in,...

stream.sorted().reduce((l, r) -> l + r).ifPresent(v -> buf.append(v))); L108: buf.append(CACHE_KEY_SPLITTER); L109: stream(excludes).of(stream -> stream.sorted().reduce((l, r) -> l + r).ifPresent(v -> buf.append(v))); L110: return buf.toString(); L111: } L112: L113:}...

ComponentUtil.register(new SystemHelper(), "systemHelper"); L36: crawlerStatsHelper = new CrawlerStatsHelper() { L37: @Override L38: protected void log(final StringBuilder buf) { L39: localLogMsg.set(buf.toString()); L40: } L41: }; L42: crawlerStatsHelper.init(); L43: } L44: L45: public void test_beginDone() { L46: String key = "test"; L47: crawlerStatsHelper.begin(key); L48: crawlerStatsHelper.done(key);...