Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 749 for channels (0.18 seconds)

  1. 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)
  2. 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.
    
    ![hdfs-services](https://github.com/minio/minio/blob/master/docs/bigdata/images/image7.png?raw=true "hdfs restart 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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 used
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Jan 20 17:52:26 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top