Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for oneByte (0.04 sec)

  1. internal/s3select/csv/recordtransform.go

    type recordTransform struct {
    	reader io.Reader
    	// recordDelimiter can be up to 2 characters.
    	recordDelimiter []byte
    	oneByte         []byte
    	useOneByte      bool
    }
    
    func (rr *recordTransform) Read(p []byte) (n int, err error) {
    	if rr.useOneByte {
    		p[0] = rr.oneByte[0]
    		rr.useOneByte = false
    		n, err = rr.reader.Read(p[1:])
    		n++
    	} else {
    		n, err = rr.reader.Read(p)
    	}
    
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader.go

    	}
    	csvIn := io.Reader(readCloser)
    	if args.RecordDelimiter != "\n" {
    		csvIn = &recordTransform{
    			reader:          readCloser,
    			recordDelimiter: []byte(args.RecordDelimiter),
    			oneByte:         make([]byte, len(args.RecordDelimiter)-1),
    		}
    	}
    
    	r := &Reader{
    		args:       args,
    		buf:        bufio.NewReaderSize(csvIn, csvSplitSize*2),
    		readCloser: readCloser,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
Back to top