Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 671 for area (0.18 sec)

  1. internal/s3select/select.go

    		return s3Select.progressReader.Stats()
    	}
    
    	return -1, -1
    }
    
    // Open - opens S3 object by using callback for SQL selection query.
    // Currently CSV, JSON and Apache Parquet formats are supported.
    func (s3Select *S3Select) Open(rsc io.ReadSeekCloser) error {
    	offset, length, err := s3Select.ScanRange.StartLen()
    	if err != nil {
    		return err
    	}
    	seekDirection := io.SeekStart
    	if offset < 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  2. istioctl/pkg/waypoint/waypoint.go

    		if trafficType != "" {
    			if !validTrafficTypes.Contains(trafficType) {
    				return nil, fmt.Errorf("invalid traffic type: %s. Valid options are: %v", trafficType, sets.SortedList(validTrafficTypes))
    			}
    
    			if gw.Labels == nil {
    				gw.Labels = map[string]string{}
    			}
    
    			gw.Labels[label.IoIstioWaypointFor.Name] = trafficType
    		}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/collect/testing/MapTestSuiteBuilder.java

              parentBuilder) {
        // TODO: Once invariant support is added, supply invariants to each of the
        // derived suites, to check that mutations to the derived collections are
        // reflected in the underlying map.
    
        List<TestSuite> derivedSuites = super.createDerivedSuites(parentBuilder);
    
        if (parentBuilder.getFeatures().contains(CollectionFeature.SERIALIZABLE)) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. impl/maven-core/src/main/java/org/apache/maven/exception/DefaultExceptionHandler.java

    - asking to use a plugin for which you do not have a version defined - tools to easily select versions
    - goal not found in a plugin (probably could list the ones that are)
    
     */
    
    // PluginNotFoundException, PluginResolutionException, PluginDescriptorParsingException,
    // CycleDetectedInPluginGraphException;
    
    /**
     * Transform an exception into useful end-user message.
     */
    @Named
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  5. impl/maven-core/src/main/java/org/apache/maven/internal/impl/SisuDiBridgeModule.java

                Key<?> keyType = key.getTypeParameter(0);
                Key<Object> valueType = key.getTypeParameter(1);
                if (keyType.getRawType() != String.class) {
                    throw new DIException("Only String keys are supported for maps: " + key);
                }
                return () -> {
                    var comparator = getBindingComparator();
                    Map<String, Binding<?>> map = new HashMap<>();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. src/archive/tar/reader_test.go

    			},
    			Format: FormatPAX,
    		}},
    	}, {
    		// Both BSD and GNU tar truncate long names at first NUL even
    		// if there is data following that NUL character.
    		// This is reasonable as GNU long names are C-strings.
    		file: "testdata/gnu-long-nul.tar",
    		headers: []*Header{{
    			Name:     "0123456789",
    			Mode:     0644,
    			Uid:      1000,
    			Gid:      1000,
    			ModTime:  time.Unix(1486082191, 0),
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

     * `::1` will reach the IPv6 server.
     *
     * By orchestrating two different servers with the same port but different IP addresses, we can
     * test what OkHttp does when both are reachable, or if only one is reachable.
     *
     * This test only runs on host machines that have both IPv4 and IPv6 addresses for localhost.
     */
    @Timeout(30)
    class FastFallbackTest {
      @RegisterExtension
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt

            BasicConstraints(
              ca = it[0] as Boolean,
              maxIntermediateCas = it[1] as Long?,
            )
          },
        )
    
      /**
       * Note that only a subset of available choices are implemented.
       *
       * ```
       * GeneralName ::= CHOICE {
       *   otherName                       [0]     OtherName,
       *   rfc822Name                      [1]     IA5String,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/CharSourceTest.java

      private static final ImmutableSet<CharSink> BROKEN_SINKS =
          ImmutableSet.of(BROKEN_CLOSE_SINK, BROKEN_OPEN_SINK, BROKEN_WRITE_SINK);
    
      public void testCopyExceptions() {
        // test that exceptions are suppressed
    
        for (CharSource in : BROKEN_SOURCES) {
          int suppressed = runSuppressionFailureTest(in, newNormalCharSink());
          assertEquals(0, suppressed);
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        Runnable intCounter =
            new Runnable() {
              @Override
              public void run() {
                totalCalls.incrementAndGet();
                // Make sure that no other tasks are scheduled to run while this is running.
                assertFalse(fakePool.hasNext());
              }
            };
    
        assertFalse(fakePool.hasNext());
        e.execute(intCounter);
        // A task should have been scheduled
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top