Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 737 for iostream (0.12 sec)

  1. android/guava/src/com/google/common/primitives/ImmutableIntArray.java

        }
      }
    
      /**
       * Returns a stream over the values in this array, in order.
       *
       * @since NEXT (but since 22.0 in the JRE flavor)
       */
      @SuppressWarnings("Java7ApiChecker")
      // If users use this when they shouldn't, we hope that NewApi will catch subsequent stream calls
      @IgnoreJRERequirement
      public IntStream stream() {
        return Arrays.stream(array, start, end);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/helper/OsddHelperTest.java

            osddHelper.setContentType("application/opensearchdescription+xml");
            osddHelper.init();
            assertFalse(osddHelper.hasOpenSearchFile());
    
            try {
                osddHelper.asStream();
                fail();
            } catch (final Exception e) {
                assertEquals("Unsupported Open Search Description Document response.", e.getMessage());
            }
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. internal/s3select/jstream/README.md

    ```go
    decoder := jstream.NewDecoder(f, 2).EmitKV() // enable KV streaming at a depth level of 2
    ```
    
    ```
    jstream.KV{desc RGB}
    jstream.KV{colors [red green blue]}
    jstream.KV{desc CMYK}
    jstream.KV{colors [cyan magenta yellow black]}
    ```
    
    ## Installing 
    
    ```bash
    go get github.com/bcicen/jstream
    ```
    
    ## Commandline
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/primitives/ImmutableIntArray.java

     * <Integer>}:
     *
     * <ul>
     *   <li>Improved memory compactness and locality.
     *   <li>Can be queried without allocating garbage.
     *   <li>Access to {@code IntStream} features (like {@link IntStream#sum}) using {@code stream()}
     *       instead of the awkward {@code stream().mapToInt(v -> v)}.
     * </ul>
     *
     * <p>Disadvantages compared to {@code ImmutableList<Integer>}:
     *
     * <ul>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  5. docs/orchestration/docker-compose/nginx.conf

        sendfile        on;
        keepalive_timeout  65;
    
        # include /etc/nginx/conf.d/*.conf;
    
        upstream minio {
            server minio1:9000;
            server minio2:9000;
            server minio3:9000;
            server minio4:9000;
        }
    
        upstream console {
            ip_hash;
            server minio1:9001;
            server minio2:9001;
            server minio3:9001;
            server minio4:9001;
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 05 06:32:39 UTC 2022
    - 3K bytes
    - Viewed (0)
  6. cmd/postpolicyform.go

    	var buf bytes.Buffer
    	e := json.NewEncoder(&buf)
    	d := jstream.NewDecoder(r, 0).ObjectAsKVS().MaxDepth(10)
    	sset := set.NewStringSet()
    	for mv := range d.Stream() {
    		var kvs jstream.KVS
    		if mv.ValueType == jstream.Object {
    			// This is a JSON object type (that preserves key order)
    			kvs = mv.Value.(jstream.KVS)
    			for _, kv := range kvs {
    				if sset.Contains(kv.Key) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. internal/s3select/simdj/record.go

    		return nil, err
    	}
    	if cap(dst.KVS) < len(elems.Elements) {
    		dst.KVS = make(jstream.KVS, 0, len(elems.Elements))
    	}
    	for _, elem := range elems.Elements {
    		v, err := sql.IterToValue(elem.Iter)
    		if err != nil {
    			v, err = elem.Iter.Interface()
    			if err != nil {
    				panic(err)
    			}
    		}
    		dst.KVS = append(dst.KVS, jstream.KV{
    			Key:   elem.Name,
    			Value: v,
    		})
    	}
    	return dst, nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public ActionResponse download(final String id) {
            if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) {
                if ("system.properties".equals(id)) {
                    return asStream(id).contentTypeOctetStream().stream(out -> {
                        try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  9. internal/s3select/json/reader.go

    		}
    		return nil, io.EOF
    	}
    
    	var kvs jstream.KVS
    	if v.ValueType == jstream.Object {
    		// This is a JSON object type (that preserves key
    		// order)
    		kvs = v.Value.(jstream.KVS)
    	} else {
    		// To be AWS S3 compatible Select for JSON needs to
    		// output non-object JSON as single column value
    		// i.e. a map with `_1` as key and value as the
    		// non-object.
    		kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v.Value}}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. .github/workflows/mint/nginx-1-node.conf

        sendfile        on;
        keepalive_timeout  65;
    
        # include /etc/nginx/conf.d/*.conf;
    
        upstream minio {
            server minio1:9000;
        }
    
        upstream console {
            ip_hash;
            server minio1:9001;
        }
    
        server {
            listen       9000;
            listen  [::]:9000;
            server_name  localhost;
    
            # To allow special characters in headers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 31 21:38:10 UTC 2023
    - 2.8K bytes
    - Viewed (0)
Back to top