Search Options

Results per page
Sort
Preferred Languages
Advance

Results 811 - 820 of 2,153 for only2 (0.04 sec)

  1. internal/s3select/simdj/reader.go

    	"github.com/minio/simdjson-go"
    )
    
    // Reader - JSON record reader for S3Select.
    type Reader struct {
    	args    *json.ReaderArgs
    	input   chan simdjson.Stream
    	decoded chan simdjson.Object
    
    	// err will only be returned after decoded has been closed.
    	err          *error
    	readCloser   io.ReadCloser
    	onReaderExit func()
    
    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/hash/LongAdder.java

        }
        return sum;
      }
    
      /**
       * Resets variables maintaining the sum to zero. This method may be a useful alternative to
       * creating a new adder, but is only effective if there are no concurrent updates. Because this
       * method is intrinsically racy, it should only be used when it is known that no threads are
       * concurrently updating.
       */
      public void reset() {
        internalReset(0L);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/AbstractTableTest.java

          assertEquals(ImmutableMap.of(5, 'x'), row);
        }
      }
    
      @SuppressWarnings("unchecked") // C can only be @Nullable Character or Character
      protected @NonNull C cellValue(Character character) {
        return (C) character;
      }
    
      // Only safe wrt. ClassCastException. Not null-safe (can be used to test expected Table NPEs)
      @SuppressWarnings("unchecked")
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/hash/LongAdder.java

        }
        return sum;
      }
    
      /**
       * Resets variables maintaining the sum to zero. This method may be a useful alternative to
       * creating a new adder, but is only effective if there are no concurrent updates. Because this
       * method is intrinsically racy, it should only be used when it is known that no threads are
       * concurrently updating.
       */
      public void reset() {
        internalReset(0L);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  5. CONTRIBUTING.md

    + Make commits of logical units.
    + Respect the original code style: by using the same [codestyle][code-style],
      patches should only highlight the actual difference, not being disturbed by any formatting issues:
      + Only use spaces for indentation.
      + Create minimal diffs - disable on save actions like reformat source code or organize imports.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Sun Oct 10 09:48:27 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  6. ci/official/containers/linux_arm64/devel.usertools/aarch64_clang.bazelrc

    # Convenient cache configurations
    # Use a cache directory mounted to /tf/cache. Very useful!
    build:sigbuild_local_cache --disk_cache=/tf/cache
    # Use the public-access TF DevInfra cache (read only)
    build:sigbuild_remote_cache --remote_cache="https://storage.googleapis.com/tensorflow-devinfra-bazel-cache/manylinux2014" --remote_upload_local_results=false
    # Change the value of CACHEBUSTER when upgrading the toolchain, or when testing
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Jul 12 20:16:57 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbFile.java

     * exists and is not marked read-only. By default, resources are
     * considered to be read-only and therefore for <code>smb1://</code>,
     * <code>smb1://workgroup/</code>, and <code>smb1://server/</code> resources
     * will be read-only.
     *
     * @return  <code>true</code> if the resource exists is not marked
     *          read-only
     */
    
        public boolean canWrite() throws SmbException {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Mar 13 12:00:57 UTC 2023
    - 107.9K bytes
    - Viewed (0)
  8. internal/config/notify/help.go

    		},
    		config.HelpKV{
    			Key:         target.KafkaBatchSize,
    			Description: "batch size of the events; used only when queue_dir is set",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         target.KafkaBatchCommitTimeout,
    			Description: "commit timeout set for the batch; used only when batch_size > 1",
    			Optional:    true,
    			Type:        "duration",
    		},
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  9. internal/grid/benchmark_test.go

    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    				return nil
    			},
    
    			Subroute:    "some-subroute",
    			OutCapacity: 1, // Only one message buffered.
    			InCapacity:  0,
    		}))
    		errFatal(err)
    	}
    	const payloadSize = 512
    	rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    	payload := make([]byte, payloadSize)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/cache/Cache.java

       * for an RPC may wait for a similar call that requests a long timeout, or a call by an
       * unprivileged user may return a resource accessible only to a privileged user making a similar
       * call. To prevent this problem, create a key object that includes all values that affect the
       * result of the query. Or use {@code LoadingCache.get(K)}, which lacks the ability to refer to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Aug 07 02:38:22 UTC 2022
    - 8.3K bytes
    - Viewed (0)
Back to top