ue(e.getLocalizedMessage()).replaceAll("\\s", " ")); L92: log(buf); L93: } L94: }); L95: } L96: L97: public void record(final Object keyObj, final StatsAction action) { L98: record(keyObj, action.name().toLowerCase(Locale.ENGLISH)); L99: } L100: L101: public void record(final Object keyObj, final String action) { L102: getCacheKey(keyObj).ifPresent(key -> { L103: try { L104: final StatsObject data = statsCache.getIfPresent(key);...

public void invokeQuery(String columnFlexibleName, String conditionKeyName, Object conditionValue) { L457: // nothing L458: } L459: L460: @Override L461: public void invokeQuery(String columnFlexibleName, String conditionKeyName, Object conditionValue, ConditionOption conditionOption) { L462: // nothing L463: } L464: L465: @Override L466: public void invokeQueryEqual(String columnFlexibleName, Object conditionValue) { L467: // nothing L468: } L469: L470: @Override...

public void invokeQuery(String columnFlexibleName, String conditionKeyName, Object conditionValue) { L457: // nothing L458: } L459: L460: @Override L461: public void invokeQuery(String columnFlexibleName, String conditionKeyName, Object conditionValue, ConditionOption conditionOption) { L462: // nothing L463: } L464: L465: @Override L466: public void invokeQueryEqual(String columnFlexibleName, Object conditionValue) { L467: // nothing L468: } L469: L470: @Override...

L219: final String scoreField = fessConfig.getRankFusionScoreField(); L220: final Map<String, Map<String, Object>> scoreDocMap = new HashMap<>(); L221: final String idField = fessConfig.getIndexFieldId(); L222: final Set<Object> mainIdSet = new HashSet<>(); L223: for (int i = 0; i < results.length; i++) { L224: final List<Map<String, Object>> docList = results[i].getDocumentList(); L225: if (logger.isDebugEnabled()) { L226: logger.debug("[{}]...

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

Source L72: // ====== L73: @Override L74: public Map<String, Object> toSource() { L75: Map<String, Object> sourceMap = new HashMap<>(); L76: if (createdAt != null) { L77: addFieldToSource(sourceMap, "createdAt", createdAt); L78: } L79: if (docId != null) { L80: addFieldToSource(sourceMap,...

setCreatedBy_GreaterThan(String createdBy) { L332: setCreatedBy_GreaterThan(createdBy, null); L333: } L334: L335: public void setCreatedBy_GreaterThan(String createdBy, ConditionOptionCall<RangeQueryBuilder> opLambda) { L336: final Object _value = createdBy; L337: RangeQueryBuilder builder = regRangeQ("createdBy", ConditionKey.CK_GREATER_THAN, _value); L338: if (opLambda != null) { L339: opLambda.callback(builder); L340: } L341: } L342: L343: public...

ScriptEngineFactory(); L39: ComponentUtil.register(scriptEngineFactory, "scriptEngineFactory"); L40: new AbstractScriptEngine() { L41: L42: @Override L43: public Object evaluate(String template, Map<String, Object> paramMap) { L44: final Map<String, Object> bindingMap = new HashMap<>(paramMap); L45: bindingMap.put("container", SingletonLaContainerFactory.getContainer()); L46: final GroovyShell groovyShell = new GroovyShell(new...

void setConfigId_GreaterThan(String configId) { L332: setConfigId_GreaterThan(configId, null); L333: } L334: L335: public void setConfigId_GreaterThan(String configId, ConditionOptionCall<RangeQueryBuilder> opLambda) { L336: final Object _value = configId; L337: RangeQueryBuilder builder = regRangeQ("configId", ConditionKey.CK_GREATER_THAN, _value); L338: if (opLambda != null) { L339: opLambda.callback(builder); L340: } L341: } L342: L343: public...

logger.debug("The number of an added document is {}.", documentSize.get()); L142: } L143: L144: } L145: L146: protected Map<String, Object> ingest(final DataStoreParams paramMap, final Map<String, Object> dataMap) { L147: if (ingestFactory == null) { L148: return dataMap; L149: } L150: Map<String, Object> target = dataMap; L151: for (final Ingester ingester : ingestFactory.getIngesters()) { L152: try { L153: target =...