groupLocally

Documentation

Overview

Package groupLocally is the implementation of the group stage that runs locally.

Index

• func NewStage(groupOptions *group.Options) *analysis.Stage
• type Accumulator
• type GroupId
• type GroupResults

Functions

func NewStage

func NewStage(groupOptions *group.Options) *analysis.Stage

NewStage - GroupLocally stage factory.

Types

type Accumulator

type Accumulator struct {
	Count uint64

	ConvertObjectIdToDate bool

	StoreMinMaxValue bool
	MinValue         interface{}
	MaxValue         interface{}

	StoreAvgValue bool
	ValuesSum     float64

	StoreMinMaxAvgLength bool
	MinLength            uint
	MaxLength            uint
	LengthSum            uint64

	StoreValueDistribution       bool
	StoreLengthDistribution      bool
	StoreDateWeekdayDistribution bool
	StoreDateHourDistribution    bool
}

Accumulator represents aggregation in one group worker.

type GroupId

type GroupId struct {
	Name string
	Type string
}

GroupId - values are grouped by field name and type.

type GroupResults

type GroupResults map[GroupId]*Accumulator

GroupResults are partial results from one go routine.