Versions in this module Expand all Collapse all v0 v0.11.0 Aug 24, 2026 Changes in this version + const StreamColumnNameElementID + const StreamColumnNameOrderKey + const StreamColumnNameSeriesID + const StreamColumnNameTimestamp + func BuildElementsFromBatch(batch *vectorized.RecordBatch, projectionTags []model.TagProjection) ([]*streamv1.Element, error) + func BuildElementsFromBatches(batches []*vectorized.RecordBatch, projectionTags []model.TagProjection) ([]*streamv1.Element, error) + func BuildStreamBatchSchema(tagProjection []model.TagProjection, orderTagFamily, orderTagName string) *vectorized.BatchSchema + func BuildStreamMergePipeline(source vectorized.PullOperator, schema *vectorized.BatchSchema, desc bool, ...) (*vectorized.Pipeline, error) + func ColumnToElementID(v int64) uint64 + func ColumnToSeriesID(v int64) uint64 + func ElementIDToColumn(id uint64) int64 + func IncrQueryCount() + func QueryCount() int64 + func SeriesIDToColumn(id uint64) int64 + type Distinct struct + func NewDistinct(schema *vectorized.BatchSchema) *Distinct + func (d *Distinct) Close() error + func (d *Distinct) Init(context.Context) error + func (d *Distinct) OutputSchema() *vectorized.BatchSchema + func (d *Distinct) Process(_ context.Context, batch *vectorized.RecordBatch) error + type Limit struct + func NewLimit(schema *vectorized.BatchSchema, offset, limit uint32) *Limit + func (l *Limit) Close() error + func (l *Limit) Init(context.Context) error + func (l *Limit) OutputSchema() *vectorized.BatchSchema + func (l *Limit) Process(_ context.Context, batch *vectorized.RecordBatch) error + type SortedMerge struct + func NewSortedMerge(schema *vectorized.BatchSchema, desc bool, batchSize int) *SortedMerge + func NewSortedMergeWithCap(schema *vectorized.BatchSchema, desc bool, batchSize, maxRows int) *SortedMerge + func (s *SortedMerge) Close() error + func (s *SortedMerge) Consume(_ context.Context, batch *vectorized.RecordBatch) error + func (s *SortedMerge) Finalize(context.Context) error + func (s *SortedMerge) Init(context.Context) error + func (s *SortedMerge) NextBatch(ctx context.Context) (*vectorized.RecordBatch, error) + func (s *SortedMerge) OutputSchema() *vectorized.BatchSchema + type VectorizedConfig struct + BatchSize int + Enabled bool + QueryMemoryMiB int + func DefaultConfig() VectorizedConfig + func (c VectorizedConfig) Validate() error
Go to main page