parquet

package

v2.0.2 Latest Latest Go to latest Published: May 7, 2026 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

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.

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

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

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

func (f *File) Path() string