batch

README

batch

Documentation

Index

• Constants
• type Batch
  • func New() *Batch
  • func (b *Batch) Add(id uint64, ts time.Time, labels [][]byte, value float64)
  • func (b *Batch) Build() (Fragments, error)
  • func (b *Batch) Reset()
  • func (b *Batch) WithTranslator(t Translator) *Batch
• type FragmentKey
  • func (f *FragmentKey) Compare(o *FragmentKey) int
• type Fragments
  • func (f Fragments) DeleteView(shard uint64, field uint64, view string)
  • func (f Fragments) GetOrCreate(shard uint64, field uint64, view string) *roaring.Bitmap
  • func (f Fragments) GetViewMap(shard uint64, field uint64) map[string]*roaring.Bitmap
  • func (f Fragments) String() string
• type QuantizedTime
  • func NeqQuantumTime() *QuantizedTime
  • func (q *QuantizedTime) Clone() *QuantizedTime
  • func (q *QuantizedTime) Release()
  • func (q *QuantizedTime) Reset()
  • func (qt *QuantizedTime) Set(t time.Time)
  • func (qt *QuantizedTime) SetDay(day string)
  • func (qt *QuantizedTime) SetHour(hour string)
  • func (qt *QuantizedTime) SetMonth(month string)
  • func (qt *QuantizedTime) SetYear(year string)
  • func (qt *QuantizedTime) Time() (time.Time, error)
  • func (qt *QuantizedTime) Views(q quantum.TimeQuantum) ([]string, error)
• type Translator

Constants

const (
	Timestamp uint64 = iota
	Labels
	Value
)

const (
	Quantum = quantum.TimeQuantum("YMDH")
)

Types

type Batch

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

func New

func New() *Batch

func (*Batch) Add

func (b *Batch) Add(id uint64, ts time.Time, labels [][]byte, value float64)

func (*Batch) Build

func (b *Batch) Build() (Fragments, error)

func (*Batch) Reset

func (b *Batch) Reset()

func (*Batch) WithTranslator

func (b *Batch) WithTranslator(t Translator) *Batch

type FragmentKey

type FragmentKey struct {
	Shard uint64
	Field uint64
}

func (*FragmentKey) Compare

func (f *FragmentKey) Compare(o *FragmentKey) int

type Fragments

type Fragments map[FragmentKey]map[string]*roaring.Bitmap

func (Fragments) DeleteView

func (f Fragments) DeleteView(shard uint64, field uint64, view string)

func (Fragments) GetOrCreate

func (f Fragments) GetOrCreate(shard uint64, field uint64, view string) *roaring.Bitmap

func (Fragments) GetViewMap

func (f Fragments) GetViewMap(shard uint64, field uint64) map[string]*roaring.Bitmap

func (Fragments) String

func (f Fragments) String() string

type QuantizedTime

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

QuantizedTime represents a moment in time down to some granularity (year, month, day, or hour).

func NeqQuantumTime

func NeqQuantumTime() *QuantizedTime

func (*QuantizedTime) Clone

func (q *QuantizedTime) Clone() *QuantizedTime

func (*QuantizedTime) Release

func (q *QuantizedTime) Release()

func (*QuantizedTime) Reset

func (q *QuantizedTime) Reset()

func (*QuantizedTime) Set

func (qt *QuantizedTime) Set(t time.Time)

Set sets the Quantized time to the given timestamp (down to hour granularity).

func (*QuantizedTime) SetDay

func (qt *QuantizedTime) SetDay(day string)

SetDay sets the QuantizedTime's day, but leaves year, month, and hour untouched.

func (*QuantizedTime) SetHour

func (qt *QuantizedTime) SetHour(hour string)

SetHour sets the QuantizedTime's hour, but leaves year, month, and day untouched.

func (*QuantizedTime) SetMonth

func (qt *QuantizedTime) SetMonth(month string)

SetMonth sets the QuantizedTime's month, but leaves year, day, and hour untouched.

func (*QuantizedTime) SetYear

func (qt *QuantizedTime) SetYear(year string)

SetYear sets the quantized time's year, but leaves month, day, and hour untouched.

func (*QuantizedTime) Time

func (qt *QuantizedTime) Time() (time.Time, error)

func (*QuantizedTime) Views

func (qt *QuantizedTime) Views(q quantum.TimeQuantum) ([]string, error)

Views builds the list of Pilosa Views for this particular time, given a quantum.

type Translator

type Translator interface {
	Translate(column uint64, value []byte) uint64
}