executor

Mar 26, 2026

Changes in this version

+ var ErrSeriesLimitExceeded = errors.New("maximum number of series limit exceeded")

+ func NewCoalesce(columns []*columnWithType) arrow.Array

+ func NewScalar(value types.Literal, rows int) arrow.Array

type BufferedPipeline

+ func (p *BufferedPipeline) Open(_ context.Context) error

type Config

+ GetExternalInputs func(ctx context.Context, node physical.Node) []Pipeline

+ Metastore metastore.Metastore

+ PrefetchBytes int64

+ StreamFilterer RequestStreamFilterer

+ type ContributingTimeRangeChangedHandler = func(ts time.Time, lessThan bool)

+ type ContributingTimeRangeChangedNotifier interface

+ SubscribeToTimeRangeChanges func(callback ContributingTimeRangeChangedHandler)

type GenericPipeline

+ func (p *GenericPipeline) Open(ctx context.Context) error

type Merge

+ func (m *Merge) Open(ctx context.Context) error

type Pipeline

+ func NewBatchingPipeline(inner Pipeline, batchSize int64) Pipeline

+ func NewObservedPipeline(name string, attrs []attribute.KeyValue, inner Pipeline) Pipeline

+ func TranslateEOF(pipeline Pipeline) Pipeline

+ func Unwrap(p Pipeline) Pipeline

+ Open func(context.Context) error

+ type RequestStreamFilterer interface

+ ForRequest func(ctx context.Context) StreamFilterer

+ type StreamFilterer interface

+ ShouldFilter func(labels labels.Labels) bool

+ type VariadicFunction interface

+ Evaluate func(args ...arrow.Array) (arrow.Array, error)

+ type VariadicFunctionFunc func(args ...arrow.Array) (arrow.Array, error)

+ func (f VariadicFunctionFunc) Evaluate(args ...arrow.Array) (arrow.Array, error)

+ type VariadicFunctionRegistry interface

+ GetForSignature func(types.VariadicOp) (VariadicFunction, error)

+ type WrappedPipeline interface

+ Unwrap func() Pipeline

Dec 11, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Nov 25, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Nov 21, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Nov 17, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Changes in this version

+ var EOF = errors.New("pipeline exhausted")

+ type Array struct

+ func (a *Array) ColumnType() types.ColumnType

+ func (a *Array) Len() int64

+ func (a *Array) Release()

+ func (a *Array) ToArray() arrow.Array

+ func (a *Array) Type() types.DataType

+ func (a *Array) Value(i int) any

+ type ArrayStruct struct

+ func NewArrayStruct(arr *array.Struct, ct types.ColumnType) *ArrayStruct

+ func (a *ArrayStruct) ColumnType() types.ColumnType

+ func (a *ArrayStruct) Len() int64

+ func (a *ArrayStruct) Release()

+ func (a *ArrayStruct) ToArray() arrow.Array

+ func (a *ArrayStruct) Type() types.DataType

+ func (a *ArrayStruct) Value(i int) any

+ type BinaryFunction interface

+ Evaluate func(lhs, rhs ColumnVector) (ColumnVector, error)

+ type BinaryFunctionRegistry interface

+ GetForSignature func(types.BinaryOp, arrow.DataType) (BinaryFunction, error)

+ type BufferedPipeline struct

+ func NewBufferedPipeline(records ...arrow.Record) *BufferedPipeline

+ func (p *BufferedPipeline) Close()

+ func (p *BufferedPipeline) Read(_ context.Context) (arrow.Record, error)

+ type CoalesceVector struct

+ func (m *CoalesceVector) ColumnType() types.ColumnType

+ func (m *CoalesceVector) Len() int64

+ func (m *CoalesceVector) Release()

+ func (m *CoalesceVector) ToArray() arrow.Array

+ func (m *CoalesceVector) Type() types.DataType

+ func (m *CoalesceVector) Value(i int) any

+ type ColumnVector interface

+ ColumnType func() types.ColumnType

+ Len func() int64

+ Release func()

+ ToArray func() arrow.Array

+ Type func() types.DataType

+ Value func(i int) any

+ type Config struct

+ BatchSize int64

+ Bucket objstore.Bucket

+ MergePrefetchCount int

+ type Context struct

+ type GenericPipeline struct

+ func NewFilterPipeline(filter *physical.Filter, input Pipeline, evaluator expressionEvaluator, ...) *GenericPipeline

+ func NewLimitPipeline(input Pipeline, skip, fetch uint32) *GenericPipeline

+ func NewParsePipeline(parse *physical.ParseNode, input Pipeline, allocator memory.Allocator) *GenericPipeline

+ func (p *GenericPipeline) Close()

+ func (p *GenericPipeline) Read(ctx context.Context) (arrow.Record, error)

+ type Merge struct

+ func (m *Merge) Close()

+ func (m *Merge) Read(ctx context.Context) (arrow.Record, error)

+ type Pipeline interface

+ Close func()

+ Read func(context.Context) (arrow.Record, error)

+ func NewProjectPipeline(input Pipeline, proj *physical.Projection, evaluator *expressionEvaluator) (Pipeline, error)

+ func Run(ctx context.Context, cfg Config, plan *physical.Plan, logger log.Logger) Pipeline

+ type Scalar struct

+ func (v *Scalar) ColumnType() types.ColumnType

+ func (v *Scalar) Len() int64

+ func (v *Scalar) Release()

+ func (v *Scalar) ToArray() arrow.Array

+ func (v *Scalar) Type() types.DataType

+ func (v *Scalar) Value(_ int) any

+ type UnaryFunc func(ColumnVector, memory.Allocator) (ColumnVector, error)

+ func (f UnaryFunc) Evaluate(lhs ColumnVector, allocator memory.Allocator) (ColumnVector, error)

+ type UnaryFunction interface

+ Evaluate func(lhs ColumnVector, allocator memory.Allocator) (ColumnVector, error)

+ type UnaryFunctionRegistry interface

+ GetForSignature func(types.UnaryOp, arrow.DataType) (UnaryFunction, error)