neo

Documentation

Index

• func FindRowGroups(idx *v1.Block_Index, lo, hi int64, columns, values []string) (o []int)
• func Transform(ctx context.Context, r arrow.Record, step, truncate time.Duration, ...) arrow.Record
• type ActiveBlock
  • func NewBlock(dir string) *ActiveBlock
  • func (a *ActiveBlock) Close() error
  • func (a *ActiveBlock) Save(ctx context.Context)
  • func (a *ActiveBlock) Shutdown(ctx context.Context)
  • func (a *ActiveBlock) WriteEntry(e *entry.Entry)
• type Analysis
• type Base
  • func NewBase(pick []string, filters ...*v1.Filter) *Base
  • func (b *Base) Analyze(ctx context.Context, r arrow.Record)
  • func (b *Base) ColumnIndices() []int
  • func (b *Base) Init(pick []string, filters ...*v1.Filter) *Base
  • func (b *Base) Record() arrow.Record
  • func (b *Base) Release()
  • func (b *Base) Select() []string
• type Metrics
  • func (m *Metrics) Compute(ctx context.Context, r arrow.Record)
  • func (m *Metrics) Record(b *array.StructBuilder)
• type Sys

Functions

func FindRowGroups

func FindRowGroups(idx *v1.Block_Index, lo, hi int64, columns, values []string) (o []int)

FindRowGroups returns a list of row groups containing indexed column values

func Transform

func Transform(ctx context.Context, r arrow.Record, step, truncate time.Duration, partitions ...string) arrow.Record

Types

type ActiveBlock

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

func NewBlock

func NewBlock(dir string) *ActiveBlock

func (*ActiveBlock) Close

func (a *ActiveBlock) Close() error

func (*ActiveBlock) Save

func (a *ActiveBlock) Save(ctx context.Context)

func (*ActiveBlock) Shutdown

func (a *ActiveBlock) Shutdown(ctx context.Context)

func (*ActiveBlock) WriteEntry

func (a *ActiveBlock) WriteEntry(e *entry.Entry)

type Analysis

type Analysis interface {
	ColumnIndices() []int
	Analyze(context.Context, arrow.Record)
}

type Base

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

func NewBase

func NewBase(pick []string, filters ...*v1.Filter) *Base

func (*Base) Analyze

func (b *Base) Analyze(ctx context.Context, r arrow.Record)

func (*Base) ColumnIndices

func (b *Base) ColumnIndices() []int

func (*Base) Init

func (b *Base) Init(pick []string, filters ...*v1.Filter) *Base

func (*Base) Record

func (b *Base) Record() arrow.Record

func (*Base) Release

func (b *Base) Release()

func (*Base) Select

func (b *Base) Select() []string

type Metrics

type Metrics struct {
	Visitors        float64
	PageViews       float64
	Sessions        float64
	BounceRate      float64
	SessionDuration float64
}

func (*Metrics) Compute

func (m *Metrics) Compute(ctx context.Context, r arrow.Record)

func (*Metrics) Record

func (m *Metrics) Record(b *array.StructBuilder)

type Sys

type Sys struct {
	Timestamp time.Time
	Labels    map[string]string
	Name      string
	Value     float64
}