Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 394 for spreading (0.09 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. ci/official/utilities/cleanup_summary.sh

    can view more detailed results that are probably easier to read than this log.
    Try the links below:
    EOF
      # Find any "Streaming build results to" lines,
      # de-duplicate,
      # and print the last word from each
      awk '/Streaming build results to/ {print $NF}' "$TFCI_OUTPUT_DIR/script.log" | uniq
    }
    
    # Print out any ResultStore URLs for Bazel invocations' results.
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Thu Jan 09 18:37:25 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsElevateWordCQ.java

            if (opLambda != null) {
                opLambda.callback(builder);
            }
        }
    
        public void setReading_SpanTerm(String reading) {
            setReading_SpanTerm("reading", null);
        }
    
        public void setReading_SpanTerm(String reading, ConditionOptionCall<SpanTermQueryBuilder> opLambda) {
            SpanTermQueryBuilder builder = regSpanTermQ("reading", reading);
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 64.2K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/suggest/constants/FieldNames.java

     * <li>{@link #ANALYZER_SETTINGS_FIELD_NAME} - The analyzer settings field name.</li>
     * <li>{@link #ANALYZER_SETTINGS_READING_ANALYZER} - The reading analyzer settings field.</li>
     * <li>{@link #ANALYZER_SETTINGS_READING_TERM_ANALYZER} - The reading term analyzer settings field.</li>
     * <li>{@link #ANALYZER_SETTINGS_NORMALIZE_ANALYZER} - The normalize analyzer settings field.</li>
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Fri Jul 04 14:00:23 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  4. internal/s3select/jstream/decoder.go

    // containing those values is emitted.
    func (d *Decoder) Recursive() *Decoder {
    	d.emitRecursive = true
    	return d
    }
    
    // Stream begins decoding from the underlying reader and returns a
    // streaming MetaValue channel for JSON values at the configured emitDepth.
    func (d *Decoder) Stream() chan *MetaValue {
    	go d.decode()
    	return d.metaCh
    }
    
    // Pos returns the number of bytes consumed from the underlying reader
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  5. cmd/auth-handler.go

    }
    
    // Verify if the request has AWS Streaming Signature Version '4'. This is only valid for 'PUT' operation.
    func isRequestSignStreamingV4(r *http.Request) bool {
    	return r.Header.Get(xhttp.AmzContentSha256) == streamingContentSHA256 &&
    		r.Method == http.MethodPut
    }
    
    // Verify if the request has AWS Streaming Signature Version '4'. This is only valid for 'PUT' operation.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  6. README.md

    ### Key Features
    
    - **Multi-Protocol Support**: HTTP/HTTPS, File System, FTP, SMB/CIFS, Cloud Storage (MinIO, S3)
    - **Comprehensive Content Extraction**: Office documents, PDFs, archives, images, audio/video files
    - **Multi-Threading**: Configurable thread pools for high-performance crawling
    - **Fault Tolerance**: Built-in retry mechanisms and error handling
    - **Flexible Configuration**: XML-based dependency injection with LastaFlute DI
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Aug 31 05:32:52 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  7. internal/grid/manager.go

    		return ErrHandlerAlreadyExists
    	}
    
    	m.handlers.stateless[id] = &h
    	return nil
    }
    */
    
    // RegisterStreamingHandler will register a stateless handler that serves
    // two-way streaming requests.
    func (m *Manager) RegisterStreamingHandler(id HandlerID, h StreamHandler) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	if debugPrint {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Nov 12 20:41:41 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/suggest/converter/AnalyzerConverter.java

                        final String term = termTokenList.get(i).getTerm();
                        String reading = readingTokenList.get(i).getTerm();
                        if (Strings.isNullOrEmpty(reading)) {
                            reading = term;
                        }
                        reading = transliterator.transliterate(reading);
    
                        final int pos = text.indexOf(term, offset);
                        if (pos > 0) {
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Mon Nov 17 14:28:21 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  10. guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.3K bytes
    - Click Count (0)
Back to Top