parquet

Documentation

Index

• func NewOptimizedReader(r phlareobjstore.ReaderAtCloser, meta block.File) phlareobjstore.ReaderAtCloser
• func OptimizedBucketReaderAt(bucketReader phlareobjstore.BucketReader, ctx context.Context, meta block.File) (phlareobjstore.ReaderAtCloser, error)
• type File
  • func (f *File) Close() (err error)
  • func (f *File) Open(ctx context.Context, b objstore.BucketReader, meta block.File, ...) error
  • func (f *File) Path() string

Functions

func NewOptimizedReader

func NewOptimizedReader(r phlareobjstore.ReaderAtCloser, meta block.File) phlareobjstore.ReaderAtCloser

NewOptimizedReader returns a reader that optimizes the reading of the parquet file.

func OptimizedBucketReaderAt

func OptimizedBucketReaderAt(bucketReader phlareobjstore.BucketReader, ctx context.Context, meta block.File) (phlareobjstore.ReaderAtCloser, error)

OptimizedBucketReaderAt uses a bucket reader and wraps the optimized reader. Must not be used with non-parquet files.

Types

type File

type File struct {
	*parquet.File
	// contains filtered or unexported fields
}

func (*File) Close

func (f *File) Close() (err error)

func (*File) Open

func (f *File) Open(ctx context.Context, b objstore.BucketReader, meta block.File, options ...parquet.FileOption) error

func (*File) Path

func (f *File) Path() string