Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 878 for Stream (0.24 sec)

  1. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LayeredOptions.java

            return collectMapIfPresentOrEmpty(Options::userProperties);
        }
    
        @Override
        public String source() {
            return String.format(
                    "layered(%s)", options.stream().map(Options::source).toList());
        }
    
        @Override
        public Optional<Boolean> showVersionAndExit() {
            return returnFirstPresentOrEmpty(Options::showVersionAndExit);
        }
    
        @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. internal/config/compress/compress.go

    	EnvCompressMimeTypes       = "MINIO_COMPRESSION_MIME_TYPES"
    
    	// Include-list for compression.
    	DefaultExtensions = ".txt,.log,.csv,.json,.tar,.xml,.bin"
    	DefaultMimeTypes  = "text/*,application/json,application/xml,binary/octet-stream"
    )
    
    // DefaultKVS - default KV config for compression settings
    var (
    	DefaultKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. internal/s3select/genmessage.go

    	buf.WriteByte(7)
    	buf.Write([]byte{0, 5})
    	buf.WriteString("event")
    
    	buf.WriteByte(13)
    	buf.WriteString(":content-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 24})
    	buf.WriteString("application/octet-stream")
    
    	buf.WriteByte(11)
    	buf.WriteString(":event-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 7})
    	buf.WriteString("Records")
    
    	fmt.Println(buf.Bytes())
    }
    
    // Continuation Message
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/Multisets.java

       * will be added more than once, with the count summed over all appearances of the element.
       *
       * <p>Note that {@code stream.collect(toMultiset(function, e -> 1, supplier))} is equivalent to
       * {@code stream.map(function).collect(Collectors.toCollection(supplier))}.
       *
       * <p>To collect to an {@link ImmutableMultiset}, use {@link
       * ImmutableMultiset#toImmutableMultiset}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 41.7K bytes
    - Viewed (0)
  5. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/logging/SystemStreamLog.java

     * under the License.
     */
    package org.apache.maven.plugin.logging;
    
    import java.io.PrintWriter;
    import java.io.StringWriter;
    
    /**
     * Logger with "standard" output and error output stream.
     *
     *
     * @deprecated Use SLF4J directly
     */
    @Deprecated
    public class SystemStreamLog implements Log {
        /**
         * @see org.apache.maven.plugin.logging.Log#debug(java.lang.CharSequence)
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/lex/lex.go

    // the text of the most recently returned token is, and where it was found.
    // The underlying scanner elides all spaces except newline, so the input looks like a stream of
    // Tokens; original spacing is lost but we don't need it.
    type TokenReader interface {
    	// Next returns the next token.
    	Next() ScanToken
    	// The following methods all refer to the most recent token returned by Next.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/helper/QueryHelperTest.java

            if (highlightedQuerySet != null) {
                assertEquals(highlightedQuerySet.stream().sorted().collect(Collectors.joining("\n")),
                        set.stream().sorted().collect(Collectors.joining("\n")));
            }
            set.clear();
        }
    
        private void assertFieldLogs(Map<String, List<String>> fieldLogMap) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Jul 11 08:26:36 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  8. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/SourceMetaDataVisitor.java

        @Override
        public void visit(CompilationUnit compilationUnit, ClassMetaDataRepository<ClassMetaData> repository) {
            super.visit(compilationUnit, repository);
            compilationUnit.getImports().stream()
                .filter(anImport -> !anImport.isStatic())
                .map(anImport -> anImport.getNameAsString() + (anImport.isAsterisk() ? ".*" : ""))
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

                    responseData.addMetaData(FILE_ATTRIBUTE_VIEW, aclFileAttributeView);
                    responseData.addMetaData(FS_FILE_GROUPS,
                            aclFileAttributeView.getAcl().stream().map(acl -> acl.principal().getName()).toArray(n -> new String[n]));
                    return aclFileAttributeView;
                }
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/esreq/AdminEsreqAction.java

                        }
                        throw e1;
                    }
                    return asStream("es_" + ComponentUtil.getSystemHelper().getCurrentTimeAsLong() + ".json").contentTypeOctetStream()
                            .stream(out -> {
                                try (final InputStream in = new FileInputStream(tempFile)) {
                                    out.write(in);
                                } finally {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 6.2K bytes
    - Viewed (0)
Back to top