- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Var (0.17 sec)
-
internal/s3select/json/reader.go
func (r *Reader) Read(dst sql.Record) (sql.Record, error) { v, ok := <-r.valueCh if !ok { if err := r.decoder.Err(); err != nil { return nil, errJSONParsingError(err) } return nil, io.EOF } var kvs jstream.KVS if v.ValueType == jstream.Object { // This is a JSON object type (that preserves key // order) kvs = v.Value.(jstream.KVS) } else { // To be AWS S3 compatible Select for JSON needs to
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
nextRow, err := pr.r.NextRow() if err != nil { if err == io.EOF { return nil, err } return nil, errParquetParsingError(err) } kvs := jstream.KVS{} for _, col := range pr.r.Columns() { var value interface{} if v, ok := nextRow[col.FlatName()]; ok { value, err = convertFromAnnotation(col.Element(), v) if err != nil { return nil, errParquetParsingError(err) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
src/bytes/reader.go
} r.i = int64(r.prevRune) r.prevRune = -1 return nil } // Seek implements the [io.Seeker] interface. func (r *Reader) Seek(offset int64, whence int) (int64, error) { r.prevRune = -1 var abs int64 switch whence { case io.SeekStart: abs = offset case io.SeekCurrent: abs = r.i + offset case io.SeekEnd: abs = int64(len(r.s)) + offset default:
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 3.9K bytes - Viewed (0) -
src/archive/tar/reader.go
if tarinsecurepath.Value() == "0" { tarinsecurepath.IncNonDefault() err = ErrInsecurePath } } return hdr, err } func (tr *Reader) next() (*Header, error) { var paxHdrs map[string]string var gnuLongName, gnuLongLink string // Externally, Next iterates through the tar archive as if it is a series of // files. Internally, the tar format often uses fake "files" to add meta
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
// On errors, r.err will be set. This should only be accessed after r.decoded has been closed. func (r *Reader) startReader() { defer r.onReaderExit() var tmpObj simdjson.Object for { var in simdjson.Stream select { case in = <-r.input: case <-r.exitReader: return } if in.Error != nil && in.Error != io.EOF { r.err = &in.Error return }
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) -
src/archive/zip/reader.go
"errors" "hash" "hash/crc32" "internal/godebug" "io" "io/fs" "os" "path" "path/filepath" "sort" "strings" "sync" "time" ) var zipinsecurepath = godebug.New("zipinsecurepath") var ( ErrFormat = errors.New("zip: not a valid zip file") ErrAlgorithm = errors.New("zip: unsupported compression algorithm") ErrChecksum = errors.New("zip: checksum error")
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
internal/etag/reader.go
"fmt" "hash" "io" ) // Tagger is the interface that wraps the basic ETag method. type Tagger interface { ETag() ETag } type wrapReader struct { io.Reader Tagger } var _ Tagger = wrapReader{} // compiler check // ETag returns the ETag of the underlying Tagger. func (r wrapReader) ETag() ETag { if r.Tagger == nil { return nil } return r.Tagger.ETag() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/hash/reader.go
} else { src = etag.Wrap(r, src) } } else { src = r } } else if _, ok := src.(etag.Tagger); !ok { if !disableMD5 { src = etag.NewReader(ctx, src, MD5, forceMD5) } } var h hash.Hash if len(SHA256) != 0 { h = sha256.New() } return &Reader{ src: src, size: size, actualSize: actualSize, checksum: MD5, contentSHA256: SHA256,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens need := len(buf) // number of bytes requested by caller hdr := r.opts.HeaderSize // remaining header bytes var tokens int // number of tokens to request if hdr > 0 { // available tokens go towards header first if hdr < b { // all of header can be accommodated r.opts.HeaderSize = 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
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)