Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewParquetReader (0.06 sec)

  1. internal/s3select/parquet/reader.go

    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // Reader implements reading records from parquet input.
    type Reader struct {
    	io.Closer
    	r *parquetgo.FileReader
    }
    
    // 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)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  2. internal/s3select/select.go

    		}
    		if offset != 0 || length != -1 {
    			// Offsets do not make sense in parquet files.
    			return errors.New("parquet format does not support offsets")
    		}
    		var err error
    		s3Select.recordReader, err = parquet.NewParquetReader(rsc, &s3Select.Input.ParquetArgs)
    		return err
    	}
    
    	return fmt.Errorf("unknown input format '%v'", s3Select.Input.format)
    }
    
    func (s3Select *S3Select) marshal(buf *bytes.Buffer, record sql.Record) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top