- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 497 for spreading (0.05 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
carrier.cancel() } /** * Prepares the HTTP headers and sends them to the server. * * For streaming requests with a body, headers must be prepared **before** the output stream has * been written to. Otherwise the body would need to be buffered! * * For non-streaming requests with a body, headers must be prepared **after** the output stream
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 17.5K bytes - Click Count (7) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsElevateWordBhv.java
result.setCreatedTime(DfTypeUtil.toLong(source.get("createdTime"))); result.setPermissions(toStringArray(source.get("permissions"))); result.setReading(DfTypeUtil.toString(source.get("reading"))); result.setSuggestWord(DfTypeUtil.toString(source.get("suggestWord"))); result.setUpdatedBy(DfTypeUtil.toString(source.get("updatedBy")));
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 9.8K bytes - Click Count (0) -
docs/select/README.md
- Objects must be in CSV, JSON, or Parquet(*) format. - UTF-8 is the only encoding type the Select API supports. - GZIP or BZIP2 - CSV and JSON files can be compressed using GZIP, BZIP2, [ZSTD](https://facebook.github.io/zstd/), and streaming formats of [LZ4](https://lz4.github.io/lz4/), [S2](https://github.com/klauspost/compress/tree/master/s2#s2-compression) and [SNAPPY](http://google.github.io/snappy/).
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 6.6K bytes - Click Count (0) -
internal/event/target/nats.go
connOpts := []stan.Option{stan.NatsURL(addressURL)} if n.Streaming.MaxPubAcksInflight > 0 { connOpts = append(connOpts, stan.MaxPubAcksInflight(n.Streaming.MaxPubAcksInflight)) } if n.UserCredentials != "" { connOpts = append(connOpts, stan.NatsOptions(nats.UserCredentials(n.UserCredentials))) } return stan.Connect(n.Streaming.ClusterID, clientID, connOpts...) } // NATSTarget - NATS target.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiItem.java
* @param segmentation The segmentation. * @param reading The reading. * @param pos The part of speech. */ public KuromojiItem(final long id, final String token, final String segmentation, final String reading, final String pos) { this.id = id; this.token = token; this.segmentation = segmentation; this.reading = reading; this.pos = pos; if (id == 0) {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 6.3K bytes - Click Count (0) -
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) -
cmd/xl-storage-format-v1.go
const ( // SHA256 represents the SHA-256 hash function SHA256 BitrotAlgorithm = 1 + iota // HighwayHash256 represents the HighwayHash-256 hash function HighwayHash256 // HighwayHash256S represents the Streaming HighwayHash-256 hash function HighwayHash256S // BLAKE2b512 represents the BLAKE2b-512 hash function BLAKE2b512 ) // DefaultBitrotAlgorithm is the default algorithm used for bitrot protection. const (
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 22 15:30:50 GMT 2024 - 8.4K 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)