staples

Documentation

Index

• func NewRecordBuilder(mem memory.Allocator, as *arrow.Schema) (*array.RecordBuilder, func(reflect.Value))
• func NewTaker(mem memory.Allocator, projected []string) (*array.RecordBuilder, func(arrow.Record, []uint32))
• func Schema[T any]() *arrow.Schema
• type Arrow
  • func NewArrow[T any](mem memory.Allocator) *Arrow[T]
  • func (a *Arrow[T]) Append(v *T)
  • func (a *Arrow[T]) NewRecord() arrow.Record
  • func (a *Arrow[T]) Release()
• type Merger
  • func NewMerger(mem memory.Allocator, as *arrow.Schema) *Merger
  • func (m *Merger) Add(record arrow.Record)
  • func (m *Merger) Merge(record arrow.Record)
  • func (m *Merger) NewRecord(meta arrow.Metadata) arrow.Record
  • func (m *Merger) Release()

Functions

func NewRecordBuilder

func NewRecordBuilder(mem memory.Allocator, as *arrow.Schema) (*array.RecordBuilder, func(reflect.Value))

func NewTaker

func NewTaker(mem memory.Allocator, projected []string) (*array.RecordBuilder, func(arrow.Record, []uint32))

func Schema

func Schema[T any]() *arrow.Schema

Types

type Arrow

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

func NewArrow

func NewArrow[T any](mem memory.Allocator) *Arrow[T]

func (*Arrow[T]) Append

func (a *Arrow[T]) Append(v *T)

func (*Arrow[T]) NewRecord

func (a *Arrow[T]) NewRecord() arrow.Record

func (*Arrow[T]) Release

func (a *Arrow[T]) Release()

type Merger

type Merger struct {
	// contains filtered or unexported fields
}

func NewMerger

func NewMerger(mem memory.Allocator, as *arrow.Schema) *Merger

func (*Merger) Add

func (m *Merger) Add(record arrow.Record)

func (*Merger) Merge

func (m *Merger) Merge(record arrow.Record)

func (*Merger) NewRecord

func (m *Merger) NewRecord(meta arrow.Metadata) arrow.Record

func (*Merger) Release

func (m *Merger) Release()