Versions in this module Expand all Collapse all v0 v0.0.1 Mar 23, 2024 Changes in this version + const PanicMemoryLimit + type AllocatorOption func(*LimitAllocator) + func WithRegistry(reg prometheus.Registerer) AllocatorOption + type Builder interface + Aggregate func(aggExpr []*logicalplan.AggregationFunction, groupExprs []logicalplan.Expr) Builder + Distinct func(expr ...logicalplan.Expr) Builder + Execute func(ctx context.Context, callback func(ctx context.Context, r arrow.Record) error) error + Explain func(ctx context.Context) (string, error) + Filter func(expr logicalplan.Expr) Builder + Limit func(expr logicalplan.Expr) Builder + Project func(projections ...logicalplan.Expr) Builder + type FakeTableProvider struct + Tables map[string]logicalplan.TableReader + func (f *FakeTableProvider) GetTable(name string) (logicalplan.TableReader, error) + type FakeTableReader struct + FrostdbSchema *dynparquet.Schema + Records []arrow.Record + func (r *FakeTableReader) Iterator(ctx context.Context, _ uint64, _ memory.Allocator, ...) error + func (r *FakeTableReader) Schema() *dynparquet.Schema + func (r *FakeTableReader) SchemaIterator(_ context.Context, _ uint64, _ memory.Allocator, _ []logicalplan.Callback, ...) error + func (r *FakeTableReader) View(ctx context.Context, fn func(ctx context.Context, tx uint64) error) error + type LimitAllocator struct + func NewLimitAllocator(limit int64, allocator memory.Allocator, options ...AllocatorOption) *LimitAllocator + func (a *LimitAllocator) Allocate(size int) []byte + func (a *LimitAllocator) Allocated() int + func (a *LimitAllocator) Free(b []byte) + func (a *LimitAllocator) Reallocate(size int, b []byte) []byte + type LocalEngine struct + func NewEngine(pool memory.Allocator, tableProvider logicalplan.TableProvider, ...) *LocalEngine + func (e *LocalEngine) ScanSchema(name string) Builder + func (e *LocalEngine) ScanTable(name string) Builder + type LocalQueryBuilder struct + func (b LocalQueryBuilder) Aggregate(aggExpr []*logicalplan.AggregationFunction, groupExprs []logicalplan.Expr) Builder + func (b LocalQueryBuilder) Distinct(expr ...logicalplan.Expr) Builder + func (b LocalQueryBuilder) Execute(ctx context.Context, callback func(ctx context.Context, r arrow.Record) error) error + func (b LocalQueryBuilder) Explain(ctx context.Context) (string, error) + func (b LocalQueryBuilder) Filter(expr logicalplan.Expr) Builder + func (b LocalQueryBuilder) Limit(expr logicalplan.Expr) Builder + func (b LocalQueryBuilder) Project(projections ...logicalplan.Expr) Builder + type Option func(*LocalEngine) + func WithPhysicalplanOptions(opts ...physicalplan.Option) Option + func WithTracer(tracer trace.Tracer) Option