- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 400 for Rollback (0.04 sec)
-
src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsRelatedContentCQ.java
RelatedContentCQ cq = new RelatedContentCQ(); queryLambda.callback(cq); final Collection<FilterFunctionBuilder> list = new ArrayList<>(); if (functionsLambda != null) { functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> { RelatedContentCQ cf = new RelatedContentCQ(); cqLambda.callback(cf);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 63.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaProviderFactoryTest.java
assertFalse(providers.isEmpty(), "Should have at least one available provider"); assertTrue(providers.contains("TCP Fallback"), "Should include TCP fallback"); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsCrawlingInfoCQ.java
CrawlingInfoCQ cq = new CrawlingInfoCQ(); queryLambda.callback(cq); final Collection<FilterFunctionBuilder> list = new ArrayList<>(); if (functionsLambda != null) { functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> { CrawlingInfoCQ cf = new CrawlingInfoCQ(); cqLambda.callback(cf);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 34.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/cbean/cq/bs/BsFavoriteLogCQ.java
FavoriteLogCQ cq = new FavoriteLogCQ(); queryLambda.callback(cq); final Collection<FilterFunctionBuilder> list = new ArrayList<>(); if (functionsLambda != null) { functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> { FavoriteLogCQ cf = new FavoriteLogCQ(); cqLambda.callback(cf);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 42.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ds/DataStoreTest.java
DataStoreParams params = new DataStoreParams(); // Execute store dataStore.store(config, callback, params); // Verify callback was used correctly assertEquals(2, callback.getDocumentSize()); assertTrue(callback.isCommitted()); } public void test_multiple_datastore_instances() { // Test multiple DataStore instances working independently
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 13K bytes - Viewed (0) -
compat/maven-artifact/src/main/java/org/apache/maven/artifact/versioning/DefaultArtifactVersion.java
} else { boolean fallback = false; String[] tok = part1.split("\\."); int idx = 0; if (idx < tok.length) { majorVersion = getNextIntegerToken(tok[idx++]); if (majorVersion == null) { fallback = true; } } else { fallback = true; }
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 6.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsElevateWordToLabelCA.java
if (queryLambda != null) { queryLambda.callback(cq); } FilterAggregationBuilder builder = regFilterA(name, cq.getQuery()); if (opLambda != null) { opLambda.callback(builder); } if (aggsLambda != null) { ElevateWordToLabelCA ca = new ElevateWordToLabelCA(); aggsLambda.callback(ca);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 15.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsElevateWordToLabelCQ.java
ElevateWordToLabelCQ cq = new ElevateWordToLabelCQ(); queryLambda.callback(cq); final Collection<FilterFunctionBuilder> list = new ArrayList<>(); if (functionsLambda != null) { functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> { ElevateWordToLabelCQ cf = new ElevateWordToLabelCQ(); cqLambda.callback(cf);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 23.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
MockCallback callback = new MockCallback("foo"); addCallback(f, callback, directExecutor()); f.set("foo"); } public void testExecutorSuccess() { CountingSameThreadExecutor ex = new CountingSameThreadExecutor(); SettableFuture<String> f = SettableFuture.create(); MockCallback callback = new MockCallback("foo"); Futures.addCallback(f, callback, ex); f.set("foo");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 6.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/cbean/ca/bs/BsUserInfoCA.java
if (queryLambda != null) { queryLambda.callback(cq); } FilterAggregationBuilder builder = regFilterA(name, cq.getQuery()); if (opLambda != null) { opLambda.callback(builder); } if (aggsLambda != null) { UserInfoCA ca = new UserInfoCA(); aggsLambda.callback(ca); ca.getAggregationBuilderList().forEach(builder::subAggregation);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 12.4K bytes - Viewed (0)