Versions in this module Expand all Collapse all v0 v0.11.0 Aug 24, 2026 Changes in this version + const DefaultBatchSize + var ErrLimitExhausted = errors.New("vectorized: limit exhausted") + func AppendActiveRows(dst, src *RecordBatch) error + func AppendColumnRange(dst, src Column, srcPos, n int) error + func ReleaseColumn(c Column) + type BatchOperator interface + Close func() error + Init func(ctx context.Context) error + OutputSchema func() *BatchSchema + type BatchPool struct + func NewBatchPool(schema *BatchSchema, capacity int) *BatchPool + func (p *BatchPool) Get() *RecordBatch + func (p *BatchPool) Put(b *RecordBatch) + type BatchSchema struct + Columns []ColumnDef + FieldColumns []int + TagFamilyGroups []TagFamilyGroup + func NewBatchSchema(cols []ColumnDef) *BatchSchema + func (s *BatchSchema) ElementIDIndex() int + func (s *BatchSchema) FieldIndex(name string) (int, bool) + func (s *BatchSchema) OrderKeyIndex() int + func (s *BatchSchema) SeriesIDIndex() int + func (s *BatchSchema) ShardIDIndex() int + func (s *BatchSchema) TagIndex(family, name string) (int, bool) + func (s *BatchSchema) TimestampIndex() int + func (s *BatchSchema) VersionIndex() int + type BreakerOperator interface + Consume func(ctx context.Context, b *RecordBatch) error + Finalize func(ctx context.Context) error + NextBatch func(ctx context.Context) (*RecordBatch, error) + type Column interface + AppendNull func() + IsNull func(i int) bool + Len func() int + MarkNullAt func(i int) + Reset func() + Type func() ColumnType + func AcquireColumn(t ColumnType, capacity int) Column + func NewColumnForType(t ColumnType, capacity int) Column + type ColumnDef struct + Name string + Role ColumnRole + TagFamily string + Type ColumnType + type ColumnRole int + const RoleElementID + const RoleField + const RoleOrderKey + const RoleSeriesID + const RoleShardID + const RoleTag + const RoleTimestamp + const RoleVersion + type ColumnType int + const ColumnTypeBytes + const ColumnTypeFieldValue + const ColumnTypeFloat64 + const ColumnTypeInt64 + const ColumnTypeInt64Array + const ColumnTypeStrArray + const ColumnTypeString + const ColumnTypeTagValue + func (c ColumnType) String() string + type FusibleOperator interface + Process func(ctx context.Context, b *RecordBatch) error + type MemoryTracker struct + func NewMemoryTracker(limit int64) *MemoryTracker + func (m *MemoryTracker) Release(bytes int64) + func (m *MemoryTracker) Reserve(bytes int64) error + func (m *MemoryTracker) Used() int64 + type Pipeline struct + func (p *Pipeline) Close() error + func (p *Pipeline) Init(ctx context.Context) error + func (p *Pipeline) Next(ctx context.Context) (*RecordBatch, error) + func (p *Pipeline) Tracker() *MemoryTracker + type PipelineBuilder struct + func NewPipelineBuilder() *PipelineBuilder + func (b *PipelineBuilder) Apply(f FusibleOperator) *PipelineBuilder + func (b *PipelineBuilder) Break(br BreakerOperator) *PipelineBuilder + func (b *PipelineBuilder) Build() (*Pipeline, error) + func (b *PipelineBuilder) From(p PullOperator) *PipelineBuilder + func (b *PipelineBuilder) WithMemoryTracker(t *MemoryTracker) *PipelineBuilder + type PullOperator interface + NextBatch func(ctx context.Context) (*RecordBatch, error) + type RecordBatch struct + Columns []Column + Len int + Schema *BatchSchema + Selection []uint16 + func NewRecordBatch(schema *BatchSchema, capacity int) *RecordBatch + func (b *RecordBatch) ActiveLen() int + func (b *RecordBatch) Reset() + type TagFamilyGroup struct + Columns []int + Family string + type TypedColumn struct + func NewBytesColumn(capacity int) *TypedColumn[[]byte] + func NewFieldValueColumn(capacity int) *TypedColumn[*modelv1.FieldValue] + func NewFloat64Column(capacity int) *TypedColumn[float64] + func NewInt64ArrayColumn(capacity int) *TypedColumn[[]int64] + func NewInt64Column(capacity int) *TypedColumn[int64] + func NewStrArrayColumn(capacity int) *TypedColumn[[]string] + func NewStringColumn(capacity int) *TypedColumn[string] + func NewTagValueColumn(capacity int) *TypedColumn[*modelv1.TagValue] + func (c *TypedColumn[T]) Append(v T) + func (c *TypedColumn[T]) AppendNull() + func (c *TypedColumn[T]) Data() []T + func (c *TypedColumn[T]) IsNull(i int) bool + func (c *TypedColumn[T]) Len() int + func (c *TypedColumn[T]) MarkNullAt(i int) + func (c *TypedColumn[T]) Reset() + func (c *TypedColumn[T]) SetAt(i int, v T) + func (c *TypedColumn[T]) Type() ColumnType
Go to main page