Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ReadSeekCloser (0.14 sec)

  1. internal/s3select/parquet/reader.go

    )
    
    // 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)
    	}
    
    	return &Reader{Closer: rsc, r: fr}, nil
    }
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  2. internal/s3select/select.go

    	}
    
    	return -1, -1
    }
    
    // Open - opens S3 object by using callback for SQL selection query.
    // Currently CSV, JSON and Apache Parquet formats are supported.
    func (s3Select *S3Select) Open(rsc io.ReadSeekCloser) error {
    	offset, length, err := s3Select.ScanRange.StartLen()
    	if err != nil {
    		return err
    	}
    	seekDirection := io.SeekStart
    	if offset < 0 {
    		seekDirection = io.SeekEnd
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 21K bytes
    - Viewed (0)
  3. src/io/io.go

    	Closer
    }
    
    // ReadSeeker is the interface that groups the basic Read and Seek methods.
    type ReadSeeker interface {
    	Reader
    	Seeker
    }
    
    // ReadSeekCloser is the interface that groups the basic Read, Seek and Close
    // methods.
    type ReadSeekCloser interface {
    	Reader
    	Seeker
    	Closer
    }
    
    // WriteSeeker is the interface that groups the basic Write and Seek methods.
    type WriteSeeker interface {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:34:10 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  4. internal/s3select/select_test.go

    	"strings"
    	"testing"
    
    	"github.com/klauspost/cpuid/v2"
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/simdjson-go"
    )
    
    func newStringRSC(s string) io.ReadSeekCloser {
    	return newBytesRSC([]byte(s))
    }
    
    func newBytesRSC(b []byte) io.ReadSeekCloser {
    	r := bytes.NewReader(b)
    	segmentReader := func(offset int64) (io.ReadCloser, error) {
    		_, err := r.Seek(offset, io.SeekStart)
    		if err != nil {
    			return nil, err
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  5. api/go1.16.txt

    pkg io, func NopCloser(Reader) ReadCloser
    pkg io, func ReadAll(Reader) ([]uint8, error)
    pkg io, type ReadSeekCloser interface { Close, Read, Seek }
    pkg io, type ReadSeekCloser interface, Close() error
    pkg io, type ReadSeekCloser interface, Read([]uint8) (int, error)
    pkg io, type ReadSeekCloser interface, Seek(int64, int) (int64, error)
    pkg io, var Discard Writer
    pkg io/fs, const ModeAppend = 1073741824
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Dec 02 16:30:41 UTC 2022
    - 479.2K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go

    		{"Pipe", Func, 0},
    		{"PipeReader", Type, 0},
    		{"PipeWriter", Type, 0},
    		{"ReadAll", Func, 16},
    		{"ReadAtLeast", Func, 0},
    		{"ReadCloser", Type, 0},
    		{"ReadFull", Func, 0},
    		{"ReadSeekCloser", Type, 16},
    		{"ReadSeeker", Type, 0},
    		{"ReadWriteCloser", Type, 0},
    		{"ReadWriteSeeker", Type, 0},
    		{"ReadWriter", Type, 0},
    		{"Reader", Type, 0},
    		{"ReaderAt", Type, 0},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 534.2K bytes
    - Viewed (0)
Back to top