executor

package

Go to main page

Versions in this module

v3

v3.7.1

Mar 26, 2026

v3.7.0

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

v3.6.10

Apr 2, 2026

v3.6.9

Apr 1, 2026

v3.6.8

Mar 25, 2026

v3.6.7

Feb 23, 2026

v3.6.6

Feb 18, 2026

v3.6.5

Feb 6, 2026

v3.6.4

Jan 21, 2026

v3.6.3

Dec 11, 2025

v3.6.2

Nov 25, 2025

v3.6.1

Nov 21, 2025

v3.6.0

Nov 17, 2025

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)

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