Map<String, Object> doc = new HashMap<>(); L47: doc.put("key1", new String[] { "aaa", "bbb" }); L48: assertArrayEquals(new String[] { "aaa", "bbb" }, DocumentUtil.getValue(doc, "key1", String[].class)); L49: assertEquals(Arrays.asList("aaa", "bbb"), (List<String>) DocumentUtil.getValue(doc, "key1", List.class)); L50: } L51: L52: public void test_list() { L53: Map<String, Object> doc = new HashMap<>(); L54: doc.put("key1", Arrays.asList("aaa", "bbb")); L55: ...

.getIndexFieldSegment()); L194: for (final Bucket bucket : terms.getBuckets()) { L195: final Map<String, String> map = new HashMap<>(2); L196: map.put(fessConfig.getIndexFieldSegment(), bucket.getKey().toString()); L197: map.put(FACET_COUNT_KEY, Long.toString(bucket.getDocCount())); L198: sessionIdList.add(map); L199: } L200: }); L201: return sessionIdList; L202: ...

Map<String, Object> map = new HashMap<>(); L96: final String name = filePath.getFileName().toString(); L97: map.put("id", Base64.getUrlEncoder().encodeToString(name.getBytes(StandardCharsets.UTF_8))); L98: map.put("name", name); L99: try { L100: map.put("lastModified", new Date(Files.getLastModifiedTime(filePath).toMillis())); L101: } catch (final IOException e) { L102: ...

L221: @Override L222: public boolean update(final String index, final String id, final String field, final Object value) { L223: resultMap.put("index", index); L224: resultMap.put("id", id); L225: resultMap.put("field", field); L226: resultMap.put("value", value.toString()); L227: return true; L228: } L229: }; L230: ComponentUtil.register(client, "searchEngineClient"); L231: L232:...

&& StringUtil.isNotBlank(proxyPort)) { L58: paramMap.put(Param.Client.PROXY_HOST, proxyHost); L59: paramMap.put(Param.Client.PROXY_PORT, proxyPort); L60: final String proxyUsername = fessConfig.getHttpProxyUsername(); L61: final String proxyPassword = fessConfig.getHttpProxyPassword(); L62: if (proxyUsername != null && proxyPassword != null) { L63: paramMap.put(HcHttpClient.PROXY_CREDENTIALS_PROPERTY, new UsernamePasswordCred...

builder = Settings.builder().putList("http.hosts", hosts).put("processors", fessConfig.getCrawlerHttpProcessors()) L37: .put("http.heartbeat_interval", fessConfig.getFesenHeartbeatInterval()); L38: final String username = fessConfig.getFesenUsername(); L39: final String password = fessConfig.getFesenPassword(); L40: if (StringUtil.isNotBlank(username) && StringUtil.isNotBlank(password)) { L41: builder.put(Constants.FESEN_USERNAME, username); L42: ...

String configId = config.getConfigId(); L87: if (configId != null) { L88: defaultDataMap.put(fessConfig.getIndexFieldConfigId(), configId); L89: } L90: // expires L91: if (documentExpires != null) { L92: defaultDataMap.put(fessConfig.getIndexFieldExpires(), documentExpires); L93: } L94: // segment L95: defaultDataMap.put(fessConfig.getIndexFieldSegment(), initParamMap.getAsString(Constants.SESSION_ID)); L96: // created...

createTestParam(int id) { L68: final Map<String, Object> requestBody = new HashMap<>(); L69: final String keyProp = NAME_PREFIX + id; L70: requestBody.put(KEY_PROPERTY, keyProp); L71: final Map<String, String> attributes = new HashMap<>(); L72: attributes.put("gidNumber", new Integer(id).toString()); L73: requestBody.put("attributes", attributes); L74: L75: return requestBody; L76: } L77: L78: @Override L79: protected Map<String, Object> getUpdateMap() { L80:...

L166: } L167: final String template = replacement.substring(GROOVY_MATCHER.length()); L168: return (u, m) -> { L169: final Map<String, Object> paramMap = new HashMap<>(); L170: paramMap.put("url", u); L171: paramMap.put("matcher", m); L172: final Object value = L173: ComponentUtil.getScriptEngineFactory().getScriptEngine(Constants.DEFAULT_SCRIPT).evaluate(template, paramMap); L174: if (value == null) { L175:...

String keyProp = NAME_PREFIX + id; L69: requestBody.put(KEY_PROPERTY, keyProp); L70: requestBody.put("segmentation", "segment"); L71: requestBody.put("reading", "reading"); L72: requestBody.put("pos", "pos"); L73: return requestBody; L74: } L75: L76: @Override L77: protected Map<String, Object> getUpdateMap() { L78: final Map<String, Object> updateMap = new HashMap<>(); L79: updateMap.put("segmentation", "new_segment"); L80: return updateMap;...