(logger.isDebugEnabled()) { L58: logger.debug("updated query map: {}", queryMap); L59: } L60: } L61: L62: final FacetInfo facetInfo = ComponentUtil.getComponent("facetInfo"); L63: queryMap.values().stream().distinct().forEach(facetInfo::addQuery); L64: } L65: L66: public String getTitle() { L67: return title; L68: } L69: L70: public void setTitle(final String title) { L71: this.title = title; L72: } L73: L74: public Map<String, String> getQueryMap()...

contentType = request.getHeader("Content-Type"); L128: if (StringUtil.isNotEmpty(contentType)) { L129: curlRequest.header("Content-Type", contentType); L130: } L131: L132: request.getParameterMap().entrySet().stream().forEach(entry -> { L133: if (entry.getValue().length > 1) { L134: curlRequest.param(entry.getKey(), String.join(",", entry.getValue())); L135: } else if (entry.getValue().length == 1) { L136: curlReques...

FacetResponse { L32: protected Map<String, Long> queryCountMap = new LinkedHashMap<>(); L33: L34: protected List<Field> fieldList = new ArrayList<>(); L35: L36: public FacetResponse(final Aggregations aggregations) { L37: aggregations.forEach(aggregation -> { L38: if (aggregation.getName().startsWith(Constants.FACET_FIELD_PREFIX)) { L39: final Terms termFacet = (Terms) aggregation; L40: fieldList.add(new Field(termFacet)); L41: } else...

L192: L193: public static void updateObjectTags(final String objectName, final Map<String, String> tagItems) { L194: final Map<String, String> tags = new HashMap<>(); L195: tagItems.keySet().stream().filter(s -> s.startsWith("name")).forEach(nameKey -> { L196: final String valueKey = nameKey.replace("name", "value"); L197: final String name = tagItems.get(nameKey); L198: if (StringUtil.isNotBlank(name)) { L199: tags.put(name, tagItems.get(valueKey));...

L82: logger.debug("Updating scheduled jobs. time:{}", schedulerTime); L83: } L84: final long now = systemHelper.getCurrentTimeAsLong(); L85: scheduledJobService.getScheduledJobListAfter(schedulerTime).forEach(scheduledJob -> { L86: if (logger.isDebugEnabled()) { L87: logger.debug("Updating job schedule:{}", scheduledJob.getName()); L88: } L89: try { L90: jobHelper.register(scheduledJob);...

Map<String, List<String>> headers) { L111: if (headers != null) { L112: final Map<String, List<String>> map = new HashMap<>(); L113: headers.entrySet().stream().filter(e -> e.getKey() != null) L114: .forEach(e -> map.put(e.getKey().toLowerCase(Locale.ROOT), e.getValue())); L115: this.headers = map; L116: } L117: } L118: L119: public Map<String, List<String>> getHeaders() { L120: return headers; L121: } L122: L123: ...

TypeError("Third argument must be a Function");if(d.node(t))return s=e,f=n,(l=t).addEventListener(s,f),{destroy:function(){l.removeEventListener(s,f)}};if(d.nodeList(t))return a=t,c=e,u=n,Array.prototype.forEach.call(a,function(t){t.addEventListener(c,u)}),{destroy:function(){Array.prototype.forEach.call(a,function(t){t.removeEventListener(c,u)})}};if(d.string(t))return o=t,r=e,i=n,h(document.body,o,r,i);throw new TypeError("First argument must be a String, HTMLElement, HTMLCollection, or NodeList");var...

cb.query().bool((must, should, mustNot, filter) -> { L111: must.setLastUpdated_LessEqual(expiry); L112: mustNot.setEndTime_Exists(); L113: }); L114: }); L115: if (!list.isEmpty()) { L116: list.forEach(jobLog -> { L117: jobLog.setJobStatus(Constants.FAIL); L118: jobLog.setScriptResult("No response from Job."); L119: jobLog.setEndTime(ComponentUtil.getSystemHelper().getCurrentTimeAsLong()); L120: ...

response = esCb.build(builder).execute().actionGet(searchTimeout); L146: L147: final EsPagingResultBean<RESULT> list = new EsPagingResultBean<>(builder); L148: final SearchHits searchHits = getSearchHits(response); L149: searchHits.forEach(hit -> { L150: final Map<String, Object> source = hit.getSourceAsMap(); L151: final RESULT entity = createEntity(source, entityType); L152: final DocMeta docMeta = ((EsAbstractEntity) entity).asDocMeta(); L153: ...

creatorList = new ArrayList<>(); L41: L42: @PostConstruct L43: public void init() { L44: if (logger.isDebugEnabled()) { L45: logger.debug("Initialize {}", this.getClass().getSimpleName()); L46: } L47: creatorList.forEach(creator -> { L48: creator.setDictionaryManager(this); L49: }); L50: } L51: L52: public DictionaryFile<? extends DictionaryItem>[] getDictionaryFiles() { L53: try (CurlResponse response = ComponentUtil.getCurlHelper(...