L117: } L118: } L119: L120: @Override L121: public boolean add(final Map<String, Object> e) { L122: return parent.add(e); L123: } L124: L125: @Override L126: public void add(final int index, final Map<String, Object> element) { L127: parent.add(index, element); L128: } L129: L130: @Override L131: public boolean addAll(final Collection<? extends Map<String, Object>> c) { L132: return parent.addAll(c); L133: } L134: L135: @Override L136: public...

tList(getResponsePath(namePrefix) + ".id"); L153: return idList; L154: } L155: L156: protected static List<Map<String, Object>> readJobLog(final String namePrefix) { L157: final List<Map<String, Object>> logList = readLogItems("joblog"); L158: final List<Map<String, Object>> resList = new ArrayList<>(); L159: for (Map<String, Object> elem : logList) { L160: if (elem.containsKey("job_name") && elem.get("job_name").equals(namePrefix + "Scheduler")) { L161:...

Long version) { L51: asDocMeta().version(version); L52: } L53: L54: public void addField(final String key, final Object value) { L55: fields.put(key, value); L56: } L57: L58: public String getLogMessage() { L59: return getUrl(); L60: } L61: L62: @Override L63: public Map<String, Object> toSource() { L64: final Map<String, Object> sourceMap = super.toSource(); L65: if (fields != null) { L66: sourceMap.putAll(fields); L67: } L68:...

ion); L52: } L53: L54: public void addField(final String key, final Object value) { L55: fields.put(key, value); L56: } L57: L58: public String getLogMessage() { L59: return getUrl(); L60: } L61: L62: public LocalDateTime getRequestedAt() { L63: return getCreatedAt(); L64: } L65: L66: @Override L67: public Map<String, Object> toSource() { L68: final Map<String, Object> sourceMap = super.toSource(); L69: if (fields != null) { L70: ...

ComponentUtil.getFessConfig(); L118: L119: final List<String> docIdList = new ArrayList<>(); L120: for (final Map<String, Object> inputDoc : docList) { L121: final Object idValue = inputDoc.get(fessConfig.getIndexFieldId()); L122: if (idValue == null) { L123: continue; L124: } L125: L126: final Object configIdValue = inputDoc.get(fessConfig.getIndexFieldConfigId()); L127: if (configIdValue == null) { L128: ...

@AfterEach L91: void deleteWebConfig() { L92: final Map<String, Object> searchBody = new HashMap<>(); L93: searchBody.put("size", NUM * 2); L94: final String webConfigId = getWebConfigId(); L95: checkMethodBase(searchBody).delete("/api/admin/webconfig/setting/" + webConfigId).then().body("response.status", equalTo(0)); L96: } L97: L98: @Override L99: protected Map<String, Object> createTestParam(int id) { L100: final Map<String, Object> requestBody...

getRequestHeaderList() { L115: return headerList; L116: } L117: L118: public void addField(final String key, final Object value) { L119: fields.put(key, value); L120: } L121: L122: public String getLogMessage() { L123: return getSearchWord(); L124: } L125: L126: @Override L127: public Map<String, Object> toSource() { L128: final Map<String, Object> sourceMap = super.toSource(); L129: if (fields != null) { L130: sourceMap.putAll(fields); L131:...

final AtomicReference<String> sentIndex = new AtomicReference<>(); L89: final List<Map<String, Object>> sentDocList = new ArrayList<>(); L90: final SearchEngineClient client = new SearchEngineClient() { L91: @Override L92: public BulkResponse addAll(final String index, final List<Map<String, Object>> docList, L93: final BiConsumer<Map<String, Object>, IndexRequestBuilder> options) { L94: sentIndex.set(index); L95: docList.forEach(x...

@AfterAll L88: protected static void tearDownAll() { L89: final List<Map<String, Object>> jobLogList = readJobLog(NAME_PREFIX); L90: for (Map<String, Object> elem : jobLogList) { L91: deleteMethod("/api/admin/joblog/log/" + elem.get("id")); L92: } L93: L94: final List<Map<String, Object>> crawlingInfoList = readCrawlingInfo(webConfigId); L95: for (Map<String, Object> elem : crawlingInfoList) { L96: deleteMethod("/api/admin/crawlinginfo/log/"...

setAvailable_GreaterThan(Boolean available) { L288: setAvailable_GreaterThan(available, null); L289: } L290: L291: public void setAvailable_GreaterThan(Boolean available, ConditionOptionCall<RangeQueryBuilder> opLambda) { L292: final Object _value = available; L293: RangeQueryBuilder builder = regRangeQ("available", ConditionKey.CK_GREATER_THAN, _value); L294: if (opLambda != null) { L295: opLambda.callback(builder); L296: } L297: } L298: L299: public...