parquetutil

package
v1.21.0-rc.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 13, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CacheConfig

type CacheConfig struct {
	ParquetShardCacheSize int           `yaml:"parquet_shard_cache_size"`
	ParquetShardCacheTTL  time.Duration `yaml:"parquet_shard_cache_ttl"`
	MaintenanceInterval   time.Duration `yaml:"-"`
}

func (*CacheConfig) RegisterFlagsWithPrefix

func (cfg *CacheConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

type CacheInterface

type CacheInterface[T any] interface {
	Get(path string) T
	Set(path string, reader T)
	Close()
}

func NewParquetShardCache

func NewParquetShardCache[T any](cfg *CacheConfig, name string, reg prometheus.Registerer) (CacheInterface[T], error)

type ParquetShardCache

type ParquetShardCache[T any] struct {
	// contains filtered or unexported fields
}

func (*ParquetShardCache[T]) Close

func (c *ParquetShardCache[T]) Close()

func (*ParquetShardCache[T]) Get

func (c *ParquetShardCache[T]) Get(path string) (r T)

func (*ParquetShardCache[T]) Set

func (c *ParquetShardCache[T]) Set(path string, reader T)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL