- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for erro (0.12 sec)
-
internal/s3select/json/reader.go
valueCh chan *jstream.MetaValue readCloser io.ReadCloser } // Read - reads single record. 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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
src/bytes/reader.go
func (r *Reader) WriteTo(w io.Writer) (n int64, err error) { r.prevRune = -1 if r.i >= int64(len(r.s)) { return 0, nil } b := r.s[r.i:] m, err := w.Write(b) if m > len(b) { panic("bytes.Reader.WriteTo: invalid Write count") } r.i += int64(m) n = int64(m) if m != len(b) && err == nil { err = io.ErrShortWrite } return }
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) -
internal/s3select/parquet/reader.go
fr, err := parquetgo.NewFileReader(rsc) if err != nil { return nil, errParquetParsingError(err) } return &Reader{Closer: rsc, r: fr}, nil } func (pr *Reader) Read(dst sql.Record) (rec sql.Record, rerr error) { nextRow, err := pr.r.NextRow() if err != nil { if err == io.EOF { return nil, err } 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/archive/tar/reader.go
if err := discard(tr.r, tr.curr.physicalRemaining()); err != nil { return nil, err } if _, err := tryReadFull(tr.r, tr.blk[:tr.pad]); err != nil { return nil, err } tr.pad = 0 hdr, rawHdr, err := tr.readHeader() if err != nil { return nil, err } if err := tr.handleRegularFile(hdr); err != nil { return nil, err } format.mayOnlyBe(hdr.Format)
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
return } continue } i := in.Value.Iter() readloop: for { var next simdjson.Iter typ, err := i.AdvanceIter(&next) if err != nil { r.err = &err return } switch typ { case simdjson.TypeNone: break readloop case simdjson.TypeRoot: typ, obj, err := next.Root(nil) if err != nil { r.err = &err 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) -
internal/etag/reader.go
func (r *Reader) Read(p []byte) (int, error) { n, err := r.src.Read(p) r.readN += int64(n) r.md5.Write(p[:n]) if err == io.EOF && len(r.checksum) != 0 { if etag := r.ETag(); !Equal(etag, r.checksum) { return n, VerifyError{ Expected: r.checksum, Computed: etag, } } } return n, err } // ETag returns the ETag of all the content read
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) -
src/archive/zip/reader.go
f *File desr io.Reader // if non-nil, where to read the data descriptor err error // sticky error } func (r *checksumReader) Stat() (fs.FileInfo, error) { return headerFileInfo{&r.f.FileHeader}, nil } func (r *checksumReader) Read(b []byte) (n int, err error) { if r.err != nil { return 0, r.err } n, err = r.rc.Read(b) r.hash.Write(b[:n]) r.nread += uint64(n)
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/s3select/csv/reader.go
record, err := reader.Read() if err != nil { r.err = err if err != io.EOF { r.err = errCSVParsingError(err) return errCSVParsingError(err) } return err } if r.args.FileHeaderInfo == use { // Copy column names since records will be reused. columns := append(make([]string, 0, len(record)), record...) r.columnNames = columns } }
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/hash/reader.go
err := ChecksumMismatch{ Want: r.contentHash.Encoded, Got: base64.StdEncoding.EncodeToString(sum), } return n, err } } } if err != nil && err != io.EOF { if v, ok := err.(etag.VerifyError); ok { return n, BadDigest{ ExpectedMD5: v.Expected.String(), CalculatedMD5: v.Computed.String(), } } } return n, err }
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
tokens = b } } else { // all tokens go towards payload need = int(math.Min(float64(b), float64(need))) tokens = need } err = r.throttle.WaitN(r.ctx, tokens) if err != nil { return } n, err = r.r.Read(buf[:need]) if err != nil { r.lastErr = err return } r.m.updateMeasurement(r.opts.BucketOptions, uint64(tokens)) return }
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)