Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for fr (0.15 sec)

  1. internal/s3select/parquet/reader.go

    }
    
    // NewParquetReader creates a Reader2 from a io.ReadSeekCloser.
    func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) {
    	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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  2. src/archive/tar/reader.go

    	nb int64     // Number of remaining bytes to read
    }
    
    func (fr *regFileReader) Read(b []byte) (n int, err error) {
    	if int64(len(b)) > fr.nb {
    		b = b[:fr.nb]
    	}
    	if len(b) > 0 {
    		n, err = fr.r.Read(b)
    		fr.nb -= int64(n)
    	}
    	switch {
    	case err == io.EOF && fr.nb > 0:
    		return n, io.ErrUnexpectedEOF
    	case err == nil && fr.nb == 0:
    		return n, io.EOF
    	default:
    		return n, err
    	}
    }
    
    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)
Back to top