tFirst, Collectors.mapping(Pair::getSecond, Collectors.toList()))); L134: sourceMap.put("searchField", searchFieldMap); L135: final Map<String, List<String>> headerMap = headerList.stream() L136: .collect(Collectors.groupingBy(Pair::getFirst, Collectors.mapping(Pair::getSecond, Collectors.toList()))); L137: sourceMap.put("headers", headerMap); L138: sourceMap.put("documents", documentList); L139: return sourceMap; L140: } L141: L142: @Override...

String[] encodingPairs = value.split(","); L65: for (final String pair : encodingPairs) { L66: final String[] encInfos = pair.trim().split(":"); L67: if (encInfos.length == 2) { L68: encodingMap.put("/" + encInfos[0] + "/", encInfos[1]); L69: } L70: } L71: } L72: } L73: L74: @Override L75: public void doFilter(final ServletRequest request, final ServletResponse response, final FilterChain chain) L76: ...

String keyProp = NAME_PREFIX + id; L64: requestBody.put(KEY_PROPERTY, keyProp); L65: requestBody.put("duplicate_host_name", "duplicate_" + new Integer(id).toString()); L66: requestBody.put("sort_order", id); L67: return requestBody; L68: } L69: L70: @Override L71: protected Map<String, Object> getUpdateMap() { L72: final Map<String, Object> updateMap = new HashMap<>(); L73: updateMap.put("duplicate_host_name", "new_duplicate_host"); L74: return...

Map<String, Object> params = new HashMap<>(); L1270: params.put("query", query); L1271: params.put("responseFields", responseFields); L1272: params.put("offset", offset); L1273: params.put("size", size); L1274: // TODO support rescorer(convert to map) L1275: // params.put("geoInfo", geoInfo); L1276: // params.put("facetInfo", facetInfo); L1277: params.put("similarDocHash", similarDocHash); L1278: return params;...

if (resultIds.size() == 0) { L188: break; L189: } L190: docIds.addAll(resultIds); L191: Map<String, Object> scrollBody = new HashMap<>(); L192: scrollBody.put("scroll", "1m"); L193: scrollBody.put("scroll_id", scrollId); L194: response = given().contentType("application/json").body(scrollBody).get(getEsUrl() + "/_search/scroll"); L195: jsonPath = JsonPath.from(response.asString()); L196: }...

4j/actions/workflows/maven.yml) L3:===================== L4: L5:curl4j is a simple cUrl-like Java client. L6: L7:## Version L8: L9:[Versions in Maven Repository](https://repo1.maven.org/maven2/org/codelibs/curl4j/) L10: L11:## Using Maven L12: L13:Put the following block into pom.xml if using Maven: L14: L15: <dependency> L16: <groupId>org.codelibs</groupId> L17: <artifactId>curl4j</artifactId> L18: <version>1.0.0</version> L19: </dependency>...

if (baseSearchers != null) { L240: baseDoc.put(Constants.SEARCHER, ArrayUtil.addAll(baseSearchers, searcherNames)); L241: } else { L242: baseDoc.put(Constants.SEARCHER, searcherNames); L243: } L244: } L245: } else { L246: doc.put(scoreField, Float.valueOf(score)); L247: scoreDocMap.put(id,...

nts.FACET_QUERY_PREFIX)) { L42: final Filter queryFacet = (Filter) aggregation; L43: final String encodedQuery = queryFacet.getName().substring(Constants.FACET_QUERY_PREFIX.length()); L44: queryCountMap.put(new String(BaseEncoding.base64().decode(encodedQuery), StandardCharsets.UTF_8), queryFacet.getDocCount()); L45: } L46: L47: }); L48: } L49: L50: public boolean hasFacetResponse() { L51: return queryCountMap != null ||...

fessConfig = ComponentUtil.getFessConfig(); L606: return stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.map(name -> { L607: final Map<String, String> map = new HashMap<>(); L608: map.put("id", name); L609: map.put("name", name); L610: return map; L611: }).collect(Collectors.toList())); L612: } L613: L614: private HtmlResponse asListHtml() { L615: return asHtml(path_AdminBackup_AdminBackupJsp).useForm(UploadForm.class)...

final Map<String, Object> requestBody = new HashMap<>(); L63: final String keyProp = NAME_PREFIX + id; L64: requestBody.put(KEY_PROPERTY, keyProp); L65: return requestBody; L66: } L67: L68: @Override L69: protected Map<String, Object> getUpdateMap() { L70: final Map<String, Object> updateMap = new HashMap<>(); L71: updateMap.put(KEY_PROPERTY, NAME_PREFIX + "new"); L72: return updateMap; L73: } L74: L75: @Test L76: void crudTest() { L77: ...