- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 394 for spreading (0.09 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)