final AtomicInteger counter = new AtomicInteger(0); L165: final ForkJoinPool pool = new ForkJoinPool(10); L166: for (int i = 0; i < 1000; i++) { L167: pool.execute(() -> { L168: assertEquals(result, crawlingInfoHelper.generateId(dataMap)); L169: counter.incrementAndGet(); L170: }); L171: } L172: pool.shutdown(); L173: pool.awaitTermination(10, TimeUnit.SECONDS); L174: assertEquals(1000, counter.get());...

maxRedirectCount = fessConfig.getIndexerDataMaxRedirectCountAsInteger(); L88: } L89: L90: protected ExecutorService newFixedThreadPool(final int nThreads) { L91: if (logger.isDebugEnabled()) { L92: logger.debug("Executor Thread Pool: {}", nThreads); L93: } L94: return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(nThreads), L95: new ThreadPoolExecutor.CallerRunsPolicy()); L96: } L97: L98: @Override...

t), opLambda); L99: } L100: L101: public void bool(BoolCall<RoleCQ> boolLambda) { L102: bool(boolLambda, null); L103: } L104: L105: public void bool(BoolCall<RoleCQ> boolLambda, ConditionOptionCall<BoolQueryBuilder> opLambda) { L106: RoleCQ mustQuery = new RoleCQ(); L107: RoleCQ shouldQuery = new RoleCQ(); L108: RoleCQ mustNotQuery = new RoleCQ(); L109: RoleCQ filterQuery = new RoleCQ(); L110: boolLambda.callback(mustQuery, shouldQuery, mustNotQuery,...

// L180: Set.of("QUERY1", "QUERY2"), // L181: buildQuery("QUERY1 OR QUERY2")); L182: L183: } L184: L185: public void test_build_boost() { L186: setQueryType("bool"); L187: assertQueryContext( L188: "{\"function_score\":{\"query\":{\"bool\":{\"should\":[{\"match_phrase\":{\"title\":{\"query\":\"QUERY1\",\"slop\":0,\"zero_terms_query\":\"NONE\",\"boost\":5.0}}},{\"match_phrase\":{\"content\":{\"query\":\"QUERY1\",\"slop\":0,\"zero_term...

ot), opLambda); L99: } L100: L101: public void bool(BoolCall<GroupCQ> boolLambda) { L102: bool(boolLambda, null); L103: } L104: L105: public void bool(BoolCall<GroupCQ> boolLambda, ConditionOptionCall<BoolQueryBuilder> opLambda) { L106: GroupCQ mustQuery = new GroupCQ(); L107: GroupCQ shouldQuery = new GroupCQ(); L108: GroupCQ mustNotQuery = new GroupCQ(); L109: GroupCQ filterQuery = new GroupCQ(); L110: boolLambda.callback(mustQuery, shouldQuery,...

Core L6:# ====== L7:# The mode of Lasta Di's smart-deploy, should be cool in production (e.g. hot, cool, warm) L8:lasta_di.smart.deploy.mode = warm L9: L10:# Is development environment here? (used for various purpose, you should set false if unknown) L11:development.here = false L12: L13:# The title of environment (e.g. local or integration...

Core L6:# ====== L7:# The mode of Lasta Di's smart-deploy, should be cool in production (e.g. hot, cool, warm) L8:lasta_di.smart.deploy.mode = warm L9: L10:# Is development environment here? (used for various purpose, you should set false if unknown) L11:development.here = false L12: L13:# The title of environment (e.g. local or integration...

Core L6:# ====== L7:# The mode of Lasta Di's smart-deploy, should be cool in production (e.g. hot, cool, warm) L8:lasta_di.smart.deploy.mode = cool L9: L10:# Is development environment here? (used for various purpose, you should set false if unknown) L11:development.here = false L12: L13:# The title of environment (e.g. local or integration or production) ...

notLambda.callback(mustNot), opLambda); L100: } L101: L102: public void bool(BoolCall<CrawlingInfoCQ> boolLambda) { L103: bool(boolLambda, null); L104: } L105: L106: public void bool(BoolCall<CrawlingInfoCQ> boolLambda, ConditionOptionCall<BoolQueryBuilder> opLambda) { L107: CrawlingInfoCQ mustQuery = new CrawlingInfoCQ(); L108: CrawlingInfoCQ shouldQuery = new CrawlingInfoCQ(); L109: CrawlingInfoCQ mustNotQuery = new CrawlingInfoCQ(); L110: CrawlingInfoCQ filterQuery...

Core L6:# ====== L7:# The mode of Lasta Di's smart-deploy, should be cool in production (e.g. hot, cool, warm) L8:lasta_di.smart.deploy.mode = warm L9: L10:# Is development environment here? (used for various purpose, you should set false if unknown) L11:development.here = true L12: L13:# The title of environment (e.g. local or integration...