processing

Jul 10, 2026

Changes in this version

+ type IncludeOrdered interface

+ IncludeFilter func() *includeFilter

Jun 23, 2026

Changes in this version

type CrosstabHostView

+ func NewCrosstabHostViewWithComponents(payload *types.MatrixPayload, comps *types.CrosstabComponents) *CrosstabHostView

+ func (h *CrosstabHostView) CellComponentFloat(rowIdx, colIdx int, key string) (float64, bool)

+ func (h *CrosstabHostView) CellN(rowIdx, colIdx int) (int, bool)

+ func (h *CrosstabHostView) CellWeightSum(rowIdx, colIdx int) (float64, bool)

+ func (h *CrosstabHostView) ColumnMarginN(colIdx int) (int, bool)

+ func (h *CrosstabHostView) ColumnSlabN(rowIdx, colIdx, prefix int) (int, bool)

+ func (h *CrosstabHostView) Components() *types.CrosstabComponents

+ func (h *CrosstabHostView) HasComponents() bool

+ func (h *CrosstabHostView) HasWelfordCells() bool

+ func (h *CrosstabHostView) RowMarginN(rowIdx int) (int, bool)

+ func (h *CrosstabHostView) RowSlabN(rowIdx, colIdx, prefix int) (int, bool)

+ func (h *CrosstabHostView) WelfordTriple(rowIdx, colIdx int) (mean, variance float64, n int, ok bool)

Jun 17, 2026

Changes in this version

type Processor

+ func (p *Processor) DisableComponents() bool

+ func (p *Processor) SetDisableComponents(disabled bool)

Jun 15, 2026

Changes in this version

+ type MetaAggregator interface

+ Components func() (map[string]any, error)

+ type MetaFilterer interface

+ Components func() (map[string]any, error)

+ type MetaGrouper interface

+ Components func() (map[string]any, error)

type Record

+ func (r *Record) IsNull(name string) bool

+ type RunCountersInput struct

+ FilteredRecords int64

+ NullRecords int64

+ PartialCohortReason string

+ ShardCount int

+ TotalRecords int64

Jun 13, 2026

Changes in this version

+ type WelfordTriple struct

+ Mean float64

+ N uint64

+ Variance float64

Jun 13, 2026

Changes in this version

+ func AxisKeyPrefix(key types.AxisKey, depth int) string

+ func ComposeDefaultLabel(index int) string

+ func EffectiveAxisDepth(axisDepth, level int) int

+ func KindRequiresMatrix(kind types.OverlayKind) bool

+ func LookupReference(byLabel map[string]*types.Response, label string, specIdx int) (*types.Response, error)

+ func LookupTarget(byLabel map[string]*types.Response, label string, specIdx, targetIdx int) (*types.Response, error)

+ func OppositeAxisPrefixDepth(oppositeDepth, within int) int

+ func OverlayLevelEnabled(spec *types.OverlaySpec) bool

+ func ResolveBaselineIndex(host *SeriesHostView, ref *types.OverlayBaselineIndexRef) (float64, error)

+ func ResolveComposeSlots(req *types.ComposedRequest, responses []*types.Response) (map[string]*types.Response, map[string]int, error)

+ func SameAxisPrefixDepth(axisDepth, level int) int

+ func WelfordStdDev(values []float64) float64

+ type CrosstabHostView struct

+ func NewCrosstabHostView(payload *types.MatrixPayload) *CrosstabHostView

+ func (h *CrosstabHostView) CellAt(rowIdx, colIdx int) (float64, bool)

+ func (h *CrosstabHostView) ColumnAxisDepth() int

+ func (h *CrosstabHostView) ColumnCount() int

+ func (h *CrosstabHostView) MarginFor(axis types.MarginAxis, rowIdx, colIdx int) (float64, bool)

+ func (h *CrosstabHostView) Payload() *types.MatrixPayload

+ func (h *CrosstabHostView) RowAxisDepth() int

+ func (h *CrosstabHostView) RowCount() int

+ type FacetPopulationView struct

+ func ResolveFacetPopulation(result *types.FacetResult, field string) (*FacetPopulationView, error)

+ func (v *FacetPopulationView) DiscreteCount(value string) (int64, bool)

+ func (v *FacetPopulationView) DiscreteCounts() ([]types.FacetValueCount, bool)

+ func (v *FacetPopulationView) DiscreteFrequency(value string) (float64, bool)

+ func (v *FacetPopulationView) DiscreteFrequencyStdev() (float64, bool)

+ func (v *FacetPopulationView) FacetField() *types.FacetField

+ func (v *FacetPopulationView) Field() string

+ func (v *FacetPopulationView) IsDiscrete() bool

+ func (v *FacetPopulationView) IsNumeric() bool

+ func (v *FacetPopulationView) Kind() string

+ func (v *FacetPopulationView) NullCount() int64

+ func (v *FacetPopulationView) NumericHistogram() (*types.FacetHistogram, bool)

+ func (v *FacetPopulationView) NumericPercentiles() (map[string]float64, bool)

+ func (v *FacetPopulationView) NumericSummary() (*types.FacetNumeric, bool)

+ func (v *FacetPopulationView) TotalRecords() int64

+ type FormulaContext struct

+ BaselineValue float64

+ BaselineValuePresent bool

+ ColumnSDs []float64

+ GrandSD float64

+ MatrixHost *CrosstabHostView

+ RefMatrix [][]float64

+ RefMatrixPresent [][]bool

+ RefScalar float64

+ RefScalarPresent bool

+ RefSeries []float64

+ RefSeriesPresent []bool

+ RowSDs []float64

+ ScalarPresent bool

+ ScalarValue float64

+ SeriesHost *SeriesHostView

+ SeriesTotal float64

+ Shape types.OverlayShape

+ Slots []formulaSlotBinding

+ type OverlayWarning struct

+ Code string

+ Details map[string]any

+ Message string

+ func ApplyChainOverlays(specs []*types.ChainOverlaySpec, stages []*types.Response, stageNames []string) ([]*types.OverlayLayer, []OverlayWarning, error)

+ func ApplyComposeOverlays(specs []types.ComposeOverlaySpec, responses []*types.Response, labels []string) ([]types.OverlayLayer, []OverlayWarning, error)

+ func ApplyOverlays(specs []types.OverlaySpec, host *CrosstabHostView) ([]types.OverlayLayer, []OverlayWarning, error)

+ func ApplyOverlaysFacet(specs []types.OverlaySpec, host *types.FacetField, pop *FacetPopulationView) ([]types.OverlayLayer, []OverlayWarning, error)

+ func ApplyOverlaysSeries(specs []types.OverlaySpec, host *SeriesHostView) ([]types.OverlayLayer, []OverlayWarning, error)

+ func ApplyOverlaysWithExtensions(specs []types.OverlaySpec, host *CrosstabHostView, exts *ExtensionRegistry) ([]types.OverlayLayer, []OverlayWarning, error)

+ type SeriesHostView struct

+ func NewSeriesHostView(groupKeys []types.AxisKey, resolver func(i int) (float64, bool)) *SeriesHostView

+ func NewSeriesHostViewWithFields(groupKeys []types.AxisKey, resolver func(i int) (float64, bool), ...) *SeriesHostView

+ func NewSeriesHostViewWithGrouper(groupKeys []types.AxisKey, resolver func(i int) (float64, bool), ...) *SeriesHostView

+ func (h *SeriesHostView) GroupCount() int

+ func (h *SeriesHostView) GroupFields() []string

+ func (h *SeriesHostView) GroupKey(i int) (types.AxisKey, bool)

+ func (h *SeriesHostView) GroupKeys() []types.AxisKey

+ func (h *SeriesHostView) GrouperKinds() []types.GroupType

+ func (h *SeriesHostView) ValueAt(i int) (float64, bool)

Jun 11, 2026

Changes in this version

+ var ErrGrouperKeyNull = stderrors.New("processing: grouper key null")

+ func CanFuseCrosstab(req *types.Request, schema *encoding.Schema, ext *ExtensionRegistry) (bool, string)

+ type FusedCrosstabState struct

+ func NewFusedCrosstabState(spec *types.CrosstabSpec, schema *encoding.Schema, ext *ExtensionRegistry) (*FusedCrosstabState, error)

+ func (s *FusedCrosstabState) AddTotalRow()

+ func (s *FusedCrosstabState) AssertCanFuse(req *types.Request) error

+ func (s *FusedCrosstabState) FilteredRows() int64

+ func (s *FusedCrosstabState) Finalize() (*types.Response, error)

+ func (s *FusedCrosstabState) SetTotalRows(n int64)

+ func (s *FusedCrosstabState) TotalRows() int64

+ func (s *FusedCrosstabState) Update(rec *Record) error

type Processor

+ func (p *Processor) RunCrosstabFused(_ context.Context, req *types.Request, iter RecordIterator) (*types.Response, error)

+ type StreamableGrouper interface

+ KeyFor func(record *Record) (string, error)

Jun 10, 2026

Changes in this version

+ type MultiKeyStreamingGrouper interface

+ KeysForRow func(record *Record, field string) (keys []string, ok bool, err error)

type Record

+ func (r *Record) SetLabels(name string) ([]string, bool)

+ func (r *Record) SetValue(name string) (uint64, bool)

+ type RichAggregator interface

+ Rich func() (any, error)

Jun 3, 2026

Changes in this version

+ func CompositeAxisKey(parts []string) string

+ type CrosstabAxisPartition struct

+ Keys []string

+ Records map[string][]*Record

+ Tuples []types.AxisKey

+ type CrosstabValidationError = errors.CodedError

type Processor

+ func (p *Processor) PartitionByAxis(axis []*types.Group, records []*Record) (*CrosstabAxisPartition, error)

+ func (p *Processor) RunCrosstab(_ context.Context, req *types.Request, records []*Record) (*types.Response, error)

May 20, 2026

Changes in this version

type ExtensionRegistry

+ LabelTables map[string]LabelTable

+ type LabelResolver struct

+ func BuildLabelResolver(bindings []*types.LabelBinding, registry *ExtensionRegistry) (*LabelResolver, error)

+ func (r *LabelResolver) Apply(field, raw string) (out string, sibling string, ok bool)

+ func (r *LabelResolver) AugmentField(field string) string

+ func (r *LabelResolver) FieldsWithAugment() []string

+ func (r *LabelResolver) Has(field string) bool

+ func (r *LabelResolver) Mode(field string) types.LabelMode

+ func (r *LabelResolver) Warnings() []ResolverWarning

+ type LabelTable struct

+ Lookup func(key string) (string, bool, error)

+ Rows map[string]string

+ type ResolverWarning struct

+ Code errors.Code

+ Details map[string]any

+ Message string

May 20, 2026

Changes in this version

+ func AggregationLabel(agg *types.Aggregation) string

+ func CanChainRequest(req *types.Request, schema *encoding.Schema) bool

+ func ChainOutputSchema(req *types.Request) (*encoding.Schema, error)

+ func FormatJoinKindError(kind string) string

+ func JoinedSchema(left, right *encoding.Schema, spec *types.JoinSpec) (*encoding.Schema, error)

+ type HashJoinIterator struct

+ func NewHashJoinIterator(left RecordIterator, right []*Record, leftSchema, rightSchema *encoding.Schema, ...) (*HashJoinIterator, *encoding.Schema, error)

+ func (h *HashJoinIterator) Next() bool

+ func (h *HashJoinIterator) Record() *Record

+ func (h *HashJoinIterator) Reset()

type Record

+ func RecordsFromChainRows(rows []map[string]any, schema *encoding.Schema) ([]*Record, error)

May 18, 2026

Changes in this version

+ type BitsetSet struct

+ func (b *BitsetSet) Add(id uint32)

+ func (b *BitsetSet) Contains(id uint32) bool

+ func (b *BitsetSet) Kind() string

+ func (b *BitsetSet) Len() int

type FilterFunc

+ func BuildMemberSetPredicate(set MemberSet, schema *encoding.Schema, fieldName string) (FilterFunc, error)

+ type LoadMemberSetResult struct

+ Invalid int

+ Lines int

+ NotInDictionary int

+ Set MemberSet

+ func LoadMemberSetFromReader(r io.Reader, schema *encoding.Schema, fieldName string) (LoadMemberSetResult, error)

+ type MemberSet interface

+ Kind func() string

+ Len func() int

+ type StringSet struct

+ func (s *StringSet) Add(v string)

+ func (s *StringSet) Contains(v string) bool

+ func (s *StringSet) Kind() string

+ func (s *StringSet) Len() int

+ type Uint64Set struct

+ func (s *Uint64Set) Add(v uint64)

+ func (s *Uint64Set) Contains(v uint64) bool

+ func (s *Uint64Set) Kind() string

+ func (s *Uint64Set) Len() int

May 18, 2026

Changes in this version

+ func CanMergeRequest(req *types.Request, schema *encoding.Schema) bool

type ExtensionRegistry

+ FieldInputs map[string]FieldInputsFunc

+ func (r *ExtensionRegistry) FieldInputsFor(category, name string, raw json.RawMessage) ([]string, bool)

+ type FieldInputsFunc func(raw json.RawMessage) []string

+ type FieldSet map[string]struct

+ func NeededFields(req *types.Request, schema *encoding.Schema, ext *ExtensionRegistry) FieldSet

+ func NewFieldSet(hint int) FieldSet

+ func (s FieldSet) Add(name string)

+ func (s FieldSet) Has(name string) bool

+ func (s FieldSet) IsWide() bool

+ func (s FieldSet) Len() int

+ func (s FieldSet) Widen()

+ type MergeableAggregator interface

+ MergeOnline func(other OnlineAggregator) error

May 15, 2026

Changes in this version

+ func StreamabilityKey(category, name string) string

+ type ExprFunction struct

+ Fn any

+ Name string

+ type ExtensionAware interface

+ SetExtensions func(r *ExtensionRegistry)

+ type ExtensionRegistry struct

+ Aggregators map[types.AggregationType]AggregatorFactory

+ Attributes map[types.AttributeType]AttributeFactory

+ ExprFunctions []ExprFunction

+ Features map[types.FeatureType]feature.Factory

+ Filterers map[types.FiltererType]FiltererFactory

+ Groupers map[types.GroupType]GrouperFactory

+ LookupTables map[string]LookupTable

+ PostTests map[types.TestType]PostTestFactory

+ RowTests map[types.TestType]RowTestFactory

+ Streamable map[string]bool

+ Windows map[types.WindowType]window.WindowFactory

+ func (r *ExtensionRegistry) CustomAggregatorNames() []types.AggregationType

+ func (r *ExtensionRegistry) CustomAttributeNames() []types.AttributeType

+ func (r *ExtensionRegistry) CustomFeatureNames() []types.FeatureType

+ func (r *ExtensionRegistry) CustomFiltererNames() []types.FiltererType

+ func (r *ExtensionRegistry) CustomGrouperNames() []types.GroupType

+ func (r *ExtensionRegistry) CustomPostTestNames() []types.TestType

+ func (r *ExtensionRegistry) CustomRowTestNames() []types.TestType

+ func (r *ExtensionRegistry) CustomWindowNames() []types.WindowType

+ func (r *ExtensionRegistry) ExprOptions() []expr.Option

+ func (r *ExtensionRegistry) FeatureFactories() map[types.FeatureType]feature.Factory

+ func (r *ExtensionRegistry) HasAggregator(t types.AggregationType) bool

+ func (r *ExtensionRegistry) HasAttribute(t types.AttributeType) bool

+ func (r *ExtensionRegistry) HasFeature(t types.FeatureType) bool

+ func (r *ExtensionRegistry) HasFilterer(t types.FiltererType) bool

+ func (r *ExtensionRegistry) HasGrouper(t types.GroupType) bool

+ func (r *ExtensionRegistry) HasPostTest(t types.TestType) bool

+ func (r *ExtensionRegistry) HasRowTest(t types.TestType) bool

+ func (r *ExtensionRegistry) HasWindow(t types.WindowType) bool

+ func (r *ExtensionRegistry) IsStreamable(category, name string) bool

+ func (r *ExtensionRegistry) LookupAggregator(t types.AggregationType) (AggregatorFactory, bool)

+ func (r *ExtensionRegistry) LookupAttribute(t types.AttributeType) (AttributeFactory, bool)

+ func (r *ExtensionRegistry) LookupFeature(t types.FeatureType) (feature.Factory, bool)

+ func (r *ExtensionRegistry) LookupFilterer(t types.FiltererType) (FiltererFactory, bool)

+ func (r *ExtensionRegistry) LookupGrouper(t types.GroupType) (GrouperFactory, bool)

+ func (r *ExtensionRegistry) LookupPostTest(t types.TestType) (PostTestFactory, bool)

+ func (r *ExtensionRegistry) LookupRowTest(t types.TestType) (RowTestFactory, bool)

+ func (r *ExtensionRegistry) LookupWindow(t types.WindowType) (window.WindowFactory, bool)

+ func (r *ExtensionRegistry) WindowFactories() map[types.WindowType]window.WindowFactory

type FilterFunc

+ func BuildFilters(filterers []*types.Filterer, schema *encoding.Schema, exts *ExtensionRegistry) ([]FilterFunc, error)

+ type LookupTable struct

+ Lookup func(keys ...string) (float64, bool, error)

+ Rows map[string]float64

type Processor

+ func NewProcessorWithExtensions(schema *encoding.Schema, exts *ExtensionRegistry) *Processor

May 11, 2026

Changes in this version

+ type PostTest interface

+ Run func(rows []map[string]any) (*types.TestResult, error)

+ type PostTestFactory func(spec *types.Test, schema *encoding.Schema) (PostTest, error)

+ type RowTest interface

+ Finalize func() (*types.TestResult, error)

+ UpdateRow func(record *Record) error

+ type RowTestFactory func(spec *types.Test, schema *encoding.Schema) (RowTest, error)

May 11, 2026

Changes in this version

+ func AggregateDecimalField(agg types.AggregationType, records []*Record, field string, scale uint8) (decimalAggResult, error)

+ func AggregateGeoField(agg types.AggregationType, records []*Record, field string) (any, error)

+ func CanStreamRequest(req *types.Request, schema *encoding.Schema) bool

+ func EnableReuse(iter RecordIterator)

+ func IsDecimalAggregationSupported(agg types.AggregationType) bool

+ func IsGeoAggregation(agg types.AggregationType) bool

+ type BBoxResult struct

+ MaxLat float64

+ MaxLon float64

+ MinLat float64

+ MinLon float64

+ type CentroidResult struct

+ Lat float64

+ Lon float64

+ type OnlineAggregator interface

+ Finalize func() (float64, error)

+ UpdateRow func(record *Record, field string) error

+ type ProcessPath int

+ const PathBuffered

+ const PathStreaming

+ const PathUnknown

+ func (p ProcessPath) String() string

type Processor

+ func (p *Processor) LastPath() ProcessPath

type Record

+ func NewRecordWithWide(schema *encoding.Schema, values map[string]float64, nulls map[string]bool, ...) *Record

+ func NewReusableRecord(schema *encoding.Schema) *Record

+ func (r *Record) ClearForRow()

+ func (r *Record) Set(name string, value float64)

+ func (r *Record) SetNull(name string)

+ func (r *Record) SetNullField(name string)

+ func (r *Record) SetNumeric(name string, value float64)

+ func (r *Record) SetWide(name string, v any)

+ func (r *Record) SetWideField(name string, v any)

+ func (r *Record) WideValue(name string) (any, bool)

+ type ReusableIterator interface

+ SetReuse func(bool)

+ type RowLocalAttribute interface

+ Row func(record *Record, field string) (float64, error)

+ type StreamingGrouper interface

+ KeyForRow func(record *Record, field string) (key string, ok bool, err error)

+ type TwoPassAttribute interface

+ Finalize func() error

+ PrePass func(record *Record, field string) error

Apr 27, 2026

Changes in this version

+ type Aggregator interface

+ Aggregate func(records []*Record, field string) (float64, error)

+ type AggregatorFactory func(agg *types.Aggregation, schema *encoding.Schema) (Aggregator, error)

+ type AttributeComputer interface

+ Compute func(records []*Record, field string) ([]float64, error)

+ type AttributeFactory func(attr *types.Attribute, schema *encoding.Schema) (AttributeComputer, error)

+ type FilterFunc func(record *Record) (bool, error)

+ type FiltererBuilder interface

+ Build func(filter *types.Filterer, schema *encoding.Schema) (FilterFunc, error)

+ type FiltererFactory func() FiltererBuilder

+ type Grouper interface

+ Group func(records []*Record, field string) (map[string][]*Record, error)

+ type GrouperFactory func(grp *types.Group, schema *encoding.Schema) (Grouper, error)

+ type Processor struct

+ func NewProcessor(schema *encoding.Schema) *Processor

+ func (p *Processor) Process(ctx context.Context, req *types.Request, iter RecordIterator) (*types.Response, error)

+ func (p *Processor) ProcessComposed(ctx context.Context, composed *types.ComposedRequest, records []*Record) ([]*types.Response, error)

+ type Record struct

+ func NewRecord(schema *encoding.Schema, values map[string]float64) *Record

+ func NewRecordWithNulls(schema *encoding.Schema, values map[string]float64, nulls map[string]bool) *Record

+ func (r *Record) AllValues() map[string]any

+ func (r *Record) NumericValue(name string) (float64, bool)

+ func (r *Record) Schema() *encoding.Schema

+ func (r *Record) StringValue(name string) (string, bool)

+ type RecordIterator interface

+ Next func() bool

+ Record func() *Record

+ Reset func()

+ type SliceIterator struct

+ func NewSliceIterator(records []*Record) *SliceIterator

+ func (it *SliceIterator) Next() bool

+ func (it *SliceIterator) Record() *Record

+ func (it *SliceIterator) Reset()