- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for Larsen (0.13 sec)
-
internal/s3select/csv/reader.go
// Blocks will read this much and find the first following newline. // 128KB appears to be a very reasonable default. const csvSplitSize = 128 << 10 // startReaders will read the header if needed and spin up a parser // and a number of workers based on GOMAXPROCS. // If an error is returned no goroutines have been started and r.err will have been set. func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
readCloser.Close() for range r.input { // Read until EOF trickles through. // Otherwise, we risk the decoder hanging. } r.readerWg.Done() } // We cannot reuse as we are sending parsed objects elsewhere. simdjson.ParseNDStream(readCloser, r.input, nil) r.readerWg.Add(1) go r.startReader() return &r } // NewElementReader - creates new JSON reader using readCloser.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0)