Versions in this module Expand all Collapse all v0 v0.2.0 Mar 28, 2026 Changes in this version + func Filter(rec arrow.Record, filter arrow.Array) (arrow.Record, error) + func Select(rec arrow.Record, cols ...string) arrow.Record + type Aggregation string + const Count + const Mean + const Sum + type AlignedAllocator struct + func NewAlignedAllocator(pool memory.Allocator, alignment int) *AlignedAllocator + func (a *AlignedAllocator) Allocate(size int) []byte + func (a *AlignedAllocator) Free(b []byte) + func (a *AlignedAllocator) Reallocate(size int, b []byte) []byte + type DataType interface + ID func() arrow.Type + type Hook interface + Execute func(context.Context, interface{}) error + type Pipeline struct + func NewPipeline() *Pipeline + func (p *Pipeline) AddStage(s Stage) + func (p *Pipeline) Execute(ctx context.Context, in <-chan arrow.Record) <-chan arrow.Record + type Predicate interface + Eval func(rec arrow.Record) (arrow.Array, error) + func NewPredicate(expression string) (Predicate, error) + type Reader interface + Read func() (arrow.Record, error) + Release func() + type Record struct + func NewRecord(rec arrow.Record) *Record + func (r *Record) Release() + type Stage func(ctx context.Context, in <-chan arrow.Record) <-chan arrow.Record + type Stream interface + type StreamingPipeline struct + func NewStreamingPipeline(in <-chan arrow.Record) *StreamingPipeline + func (sp *StreamingPipeline) Aggregate(agg Aggregation, column string) *StreamingPipeline + func (sp *StreamingPipeline) Execute(ctx context.Context) <-chan arrow.Record + func (sp *StreamingPipeline) Filter(expression string) *StreamingPipeline + func (sp *StreamingPipeline) Project(columns []string) *StreamingPipeline + type Writer interface + Close func() error + Write func(arrow.Record) error
Go to main page