- Sort Score
- Num 10 results
- Language All
Results 371 - 380 of 749 for channels (0.07 seconds)
-
guava/src/com/google/common/collect/LinkedHashMultimap.java
* added to the multimap. * * <p>Changes to the returned set will update the underlying multimap, and vice versa. However, * <i>adding</i> to the returned set is not possible. */ @Override public Set<K> keySet() { return super.keySet(); } /** * Returns a collection of all values in the multimap. Changes to the returned collection will
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 20K bytes - Click Count (0) -
docs/bigdata/README.md
- [https://hadoop.apache.org/docs/r3.1.1/hadoop-aws/tools/hadoop-aws/committers.html](https://hadoop.apache.org/docs/r3.1.1/hadoop-aws/tools/hadoop-aws/committers.html) Once the config changes are applied, proceed to restart **Hadoop** services.  ### **3.2 Configure Spark2**
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 14.7K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/release/ReleaseToolsPlugin.java
task.setReleaseHighlightsFile(projectDirectory.file("docs/reference/release-notes/highlights.asciidoc")); task.setBreakingChangesTemplate(projectDirectory.file(RESOURCES + "templates/breaking-changes.asciidoc")); task.setBreakingChangesFile( projectDirectory.file( String.format("docs/reference/migration/migrate_%d_%d.asciidoc", version.getMajor(), version.getMinor())
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Fri Sep 24 10:57:02 GMT 2021 - 4.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* hold the synchronizer. This synchronizer is used to implement the blocking and waiting calls * as well as to handle state changes in a thread-safe manner. The current state of the future * is held in the Sync state, and the lock is released whenever the state changes to {@link * #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED} *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/general/ApiAdminGeneralAction.java
} // PUT /api/admin/general /** * Updates the general system settings. * Merges the provided settings with existing configuration and applies changes. * * @param body the general settings data to update * @return JSON response with update status */ @Execute public JsonResponse<ApiResult> put$index(final EditBody body) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 3.7K bytes - Click Count (0) -
src/bootstrap.bash
# combination, leaving the resulting tree in ../../go-${GOOS}-${GOARCH}-bootstrap. # That tree can be copied to a machine of the given target type # and used as $GOROOT_BOOTSTRAP to bootstrap a local build. # # Only changes that have been committed to Git (at least locally, # not necessary reviewed and submitted to master) are included in the tree. # # See also golang.org/x/build/cmd/genbootstrap, which is usedCreated: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Jan 20 17:52:26 GMT 2023 - 2.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java
} /** * An updater for Kuromoji files. */ protected class KuromojiUpdater implements Closeable { /** True if the changes have been committed. */ protected boolean isCommit = false; /** The new file. */ protected File newFile; /** The writer for the new file. */ protected Writer writer;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 20 07:09:00 GMT 2025 - 11.7K bytes - Click Count (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (0) -
internal/event/target/nsq.go
} _, err := target.isActive() if err != nil { return err } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/collect/testing/OpenJdk6MapTests.java
* The entrySet() of ConcurrentHashMap, unlike that of other Map * implementations, supports add() under JDK8. This seems problematic, but I * didn't see that discussed in the review, which included many other * changes: https://mail.openjdk.org/pipermail/core-libs-dev/2013-May/thread.html#17367 * * TODO(cpovirk): decide what the best long-term action here is: force users
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 3.9K bytes - Click Count (0)