execute

package

Go to main page

Versions in this module

v0

v0.0.6

Mar 22, 2018

v0.0.5

Feb 9, 2018

Changes in this version

+ func AppendRowForCols(i int, rr RowReader, builder BlockBuilder, cols []ColMeta, colMap []int)

+ func AppendValue(builder BlockBuilder, j int, v compiler.Value)

+ func ConvertToKind(t DataType) semantic.Kind

type ColKind

+ func (k ColKind) String() string

type DataType

+ func ConvertFromKind(k semantic.Kind) DataType

type ReadSpec

+ AggregateMethod string

type RowMapFn

+ func (f *RowMapFn) Type() semantic.Type

v0.0.4

Jan 12, 2018

Changes in this version

+ const DefaultValueColLabel

+ const InvalidColKind

+ const TagColKind

+ const TimeColKind

+ const ValueColKind

+ var NoDefaultValueColumn = fmt.Errorf("no default value column %q found.", DefaultValueColLabel)

+ func ColIdx(label string, cols []ColMeta) int

+ func FindValueKeys(f *ast.ArrowFunctionExpression) ([]string, error)

+ func ToStoragePredicate(f *ast.ArrowFunctionExpression) (*storage.Predicate, error)

+ type Administration interface

+ Allocator func() *Allocator

+ Bounds func() Bounds

+ ConvertID func(plan.ProcedureID) DatasetID

+ Parents func() []DatasetID

+ ResolveTime func(qt query.Time) Time

type Bounds

+ func (b Bounds) Shift(d Duration) Bounds

+ type ColKind int

type ColMeta

+ Common bool

+ Kind ColKind

+ func (c ColMeta) IsTime() bool

+ func (c ColMeta) IsValue() bool

+ type CompilationCache struct

+ func NewCompilationCache(fn *ast.ArrowFunctionExpression, referencePaths []ReferencePath) *CompilationCache

+ func (c *CompilationCache) Compile(types map[ReferencePath]DataType) (CompiledFn, error)

+ type CompiledFn interface

+ Eval func(scope Scope) (Value, error)

+ EvalBool func(scope Scope) (bool, error)

+ EvalFloat func(scope Scope) (float64, error)

+ EvalInt func(scope Scope) (int64, error)

+ EvalMap func(scope Scope) (Map, error)

+ EvalString func(scope Scope) (string, error)

+ EvalTime func(scope Scope) (Time, error)

+ EvalUInt func(scope Scope) (uint64, error)

+ MapMeta func() MapMeta

+ Type func() DataType

+ func CompileFn(f *ast.ArrowFunctionExpression, types map[ReferencePath]DataType) (CompiledFn, error)

type DataType

+ const TMap

type DataTypeEvaluator

+ EvalMap func(scope Scope) Map

+ MapMeta func() MapMeta

+ type Map struct

+ Meta MapMeta

+ Values map[string]Value

+ type MapMeta struct

+ Properties []MapPropertyMeta

+ type MapPropertyMeta struct

+ Key string

+ Type DataType

+ type Reference []string

+ func FindReferences(f *ast.ArrowFunctionExpression) ([]Reference, error)

+ func (r Reference) Path() ReferencePath

+ func (r Reference) String() string

+ type ReferencePath string

+ type RowMapFn struct

+ func NewRowMapFn(fn *ast.ArrowFunctionExpression) (*RowMapFn, error)

+ func (f *RowMapFn) Eval(row int, rr RowReader) (Map, error)

+ func (f *RowMapFn) MapMeta() MapMeta

+ func (f *RowMapFn) Prepare(cols []ColMeta) error

+ type RowPredicateFn struct

+ func NewRowPredicateFn(fn *ast.ArrowFunctionExpression) (*RowPredicateFn, error)

+ func (f *RowPredicateFn) Eval(row int, rr RowReader) (bool, error)

+ func (f *RowPredicateFn) Prepare(cols []ColMeta) error

type Scope

+ func (s Scope) GetMap(rp ReferencePath) Map

+ func (s Scope) Set(rp ReferencePath, v Value)

type Time

+ func (t Time) Add(d Duration) Time

type Value

+ func (v Value) Map() Map

v0.0.3

Dec 8, 2017

Changes in this version

+ type AllocError struct

+ Allocated int64

+ Limit int64

+ Wanted int64

+ func (a AllocError) Error() string

+ type Allocator struct

+ Limit int64

+ func (a *Allocator) AppendBools(slice []bool, vs ...bool) []bool

+ func (a *Allocator) AppendFloats(slice []float64, vs ...float64) []float64

+ func (a *Allocator) AppendInts(slice []int64, vs ...int64) []int64

+ func (a *Allocator) AppendStrings(slice []string, vs ...string) []string

+ func (a *Allocator) AppendTimes(slice []Time, vs ...Time) []Time

+ func (a *Allocator) AppendUInts(slice []uint64, vs ...uint64) []uint64

+ func (a *Allocator) Bools(l, c int) []bool

+ func (a *Allocator) Floats(l, c int) []float64

+ func (a *Allocator) Free(n, size int)

+ func (a *Allocator) Ints(l, c int) []int64

+ func (a *Allocator) Max() int64

+ func (a *Allocator) Strings(l, c int) []string

+ func (a *Allocator) Times(l, c int) []Time

+ func (a *Allocator) UInts(l, c int) []uint64

type Block

+ RefCount func(n int)

type ColListBlock

+ func (b *ColListBlock) RefCount(n int)

type Context

+ Allocator func() *Allocator

+ type Dispatcher interface

+ Schedule func(fn ScheduleFunc)

+ type MessageQueue interface

+ Pop func() Message

+ Push func(Message)

+ type ScheduleFunc func(throughput int)

type Source

+ Run func(ctx context.Context)

+ type Transport interface

+ Finished func() <-chan struct{}

v0.0.2

Nov 21, 2017

Changes in this version

type ReadSpec

+ GroupExcept []string

v0.0.1

Nov 14, 2017

Changes in this version

+ const MaxTime

+ const MinTime

+ const TimeColLabel

+ const ValueColLabel

+ var AllTime = Bounds

+ var DefaultTriggerSpec = query.AfterWatermarkTriggerSpec

+ var TimeCol = ColMeta

+ var ValueDataTypes = [...]DataType

+ func AddBlockCols(b Block, builder BlockBuilder)

+ func AddNewCols(b Block, builder BlockBuilder) []int

+ func AddTags(t Tags, b BlockBuilder)

+ func AppendBlock(b Block, builder BlockBuilder, colMap []int)

+ func AppendRow(i int, rr RowReader, builder BlockBuilder, colMap []int)

+ func ExpressionNames(n expression.Node) []string

+ func ExpressionToStoragePredicate(e expression.Node) (*storage.Predicate, error)

+ func NewAggregateTransformation(d Dataset, c BlockBuilderCache, bounds Bounds, agg Aggregate) *aggregateTransformation

+ func NewBlockBuilderCache() *blockBuilderCache

+ func NewDataset(id DatasetID, accMode AccumulationMode, cache DataCache) *dataset

+ func NewIndexSelectorTransformation(d Dataset, c BlockBuilderCache, bounds Bounds, selector IndexSelector, ...) *indexSelectorTransformation

+ func NewRowSelectorTransformation(d Dataset, c BlockBuilderCache, bounds Bounds, selector RowSelector, ...) *rowSelectorTransformation

+ func PanicUnknownType(typ DataType)

+ func RegisterSource(k plan.ProcedureKind, c CreateSource)

+ func RegisterTransformation(k plan.ProcedureKind, c CreateTransformation)

+ func TimeIdx(cols []ColMeta) int

+ func ValueIdx(cols []ColMeta) int

+ type AccumulationMode int

+ const AccumulatingMode

+ const AccumulatingRetractingMode

+ const DiscardingMode

+ type Aggregate interface

+ NewBoolAgg func() DoBoolAgg

+ NewFloatAgg func() DoFloatAgg

+ NewIntAgg func() DoIntAgg

+ NewStringAgg func() DoStringAgg

+ NewUIntAgg func() DoUIntAgg

+ type Block interface

+ Col func(c int) ValueIterator

+ Cols func() []ColMeta

+ Times func() ValueIterator

+ Values func() ValueIterator

+ func CacheOneTimeBlock(b Block) Block

+ func CopyBlock(b Block) Block

+ type BlockBuilder interface

+ AddCol func(ColMeta) int

+ AppendBool func(j int, value bool)

+ AppendFloat func(j int, value float64)

+ AppendFloats func(j int, values []float64)

+ AppendInt func(j int, value int64)

+ AppendString func(j int, value string)

+ AppendStrings func(j int, values []string)

+ AppendTime func(j int, value Time)

+ AppendTimes func(j int, values []Time)

+ AppendUInt func(j int, value uint64)

+ Block func() Block

+ ClearData func()

+ Cols func() []ColMeta

+ NCols func() int

+ NRows func() int

+ SetBool func(i, j int, value bool)

+ SetBounds func(Bounds)

+ SetCommonString func(j int, value string)

+ SetFloat func(i, j int, value float64)

+ SetInt func(i, j int, value int64)

+ SetString func(i, j int, value string)

+ SetTime func(i, j int, value Time)

+ SetUInt func(i, j int, value uint64)

+ Sort func(cols []string, desc bool)

+ type BlockBuilderCache interface

+ BlockBuilder func(meta BlockMetadata) (BlockBuilder, bool)

+ ForEachBuilder func(f func(BlockKey, BlockBuilder))

+ type BlockContext struct

+ Bounds Bounds

+ Count int

+ type BlockIterator interface

+ Do func(f func(Block)) error

+ type BlockKey string

+ func ToBlockKey(meta BlockMetadata) BlockKey

+ type BlockMetadata interface

+ Bounds func() Bounds

+ Tags func() Tags

+ type BoolValueFunc interface

+ ValueBool func() bool

+ type Bounds struct

+ Start Time

+ Stop Time

+ func (b Bounds) Contains(t Time) bool

+ func (b Bounds) Equal(o Bounds) bool

+ func (b Bounds) Overlaps(o Bounds) bool

+ func (b Bounds) String() string

+ type ColListBlock struct

+ func (b *ColListBlock) AtBool(i, j int) bool

+ func (b *ColListBlock) AtFloat(i, j int) float64

+ func (b *ColListBlock) AtInt(i, j int) int64

+ func (b *ColListBlock) AtString(i, j int) string

+ func (b *ColListBlock) AtTime(i, j int) Time

+ func (b *ColListBlock) AtUInt(i, j int) uint64

+ func (b *ColListBlock) Bounds() Bounds

+ func (b *ColListBlock) Col(c int) ValueIterator

+ func (b *ColListBlock) Cols() []ColMeta

+ func (b *ColListBlock) Copy() *ColListBlock

+ func (b *ColListBlock) Tags() Tags

+ func (b *ColListBlock) Times() ValueIterator

+ func (b *ColListBlock) Values() ValueIterator

+ func (b ColListBlock) NRows() int

+ type ColListBlockBuilder struct

+ func NewColListBlockBuilder() *ColListBlockBuilder

+ func (b ColListBlockBuilder) AddCol(c ColMeta) int

+ func (b ColListBlockBuilder) AppendBool(j int, value bool)

+ func (b ColListBlockBuilder) AppendBools(j int, values []bool)

+ func (b ColListBlockBuilder) AppendFloat(j int, value float64)

+ func (b ColListBlockBuilder) AppendFloats(j int, values []float64)

+ func (b ColListBlockBuilder) AppendInt(j int, value int64)

+ func (b ColListBlockBuilder) AppendInts(j int, values []int64)

+ func (b ColListBlockBuilder) AppendString(j int, value string)

+ func (b ColListBlockBuilder) AppendStrings(j int, values []string)

+ func (b ColListBlockBuilder) AppendTime(j int, value Time)

+ func (b ColListBlockBuilder) AppendTimes(j int, values []Time)

+ func (b ColListBlockBuilder) AppendUInt(j int, value uint64)

+ func (b ColListBlockBuilder) AppendUInts(j int, values []uint64)

+ func (b ColListBlockBuilder) Block() Block

+ func (b ColListBlockBuilder) Bounds() Bounds

+ func (b ColListBlockBuilder) ClearData()

+ func (b ColListBlockBuilder) Cols() []ColMeta

+ func (b ColListBlockBuilder) NCols() int

+ func (b ColListBlockBuilder) NRows() int

+ func (b ColListBlockBuilder) RawBlock() *ColListBlock

+ func (b ColListBlockBuilder) SetBool(i int, j int, value bool)

+ func (b ColListBlockBuilder) SetBounds(bounds Bounds)

+ func (b ColListBlockBuilder) SetCommonString(j int, value string)

+ func (b ColListBlockBuilder) SetFloat(i int, j int, value float64)

+ func (b ColListBlockBuilder) SetInt(i int, j int, value int64)

+ func (b ColListBlockBuilder) SetString(i int, j int, value string)

+ func (b ColListBlockBuilder) SetTime(i int, j int, value Time)

+ func (b ColListBlockBuilder) SetUInt(i int, j int, value uint64)

+ func (b ColListBlockBuilder) Sort(cols []string, desc bool)

+ func (b ColListBlockBuilder) Tags() Tags

+ type ColMeta struct

+ IsCommon bool

+ IsTag bool

+ Label string

+ Type DataType

+ func ValueCol(cols []ColMeta) ColMeta

+ type CompiledExpression interface

+ Eval func(scope Scope) (Value, error)

+ EvalBool func(scope Scope) (bool, error)

+ EvalFloat func(scope Scope) (float64, error)

+ EvalInt func(scope Scope) (int64, error)

+ EvalString func(scope Scope) (string, error)

+ EvalTime func(scope Scope) (Time, error)

+ EvalUInt func(scope Scope) (uint64, error)

+ Type func() DataType

+ func CompileExpression(e expression.Expression, types map[string]DataType) (CompiledExpression, error)

+ type Config struct

+ StorageReader StorageReader

+ Trace bool

+ type Context interface

+ Bounds func() Bounds

+ ResolveTime func(qt query.Time) Time

+ type CreateSource func(spec plan.ProcedureSpec, id DatasetID, sr StorageReader, ctx Context) Source

+ type CreateTransformation func(id DatasetID, mode AccumulationMode, spec plan.ProcedureSpec, ctx Context) (Transformation, Dataset, error)

+ type DataCache interface

+ Block func(BlockKey) Block

+ BlockMetadata func(BlockKey) BlockMetadata

+ DiscardBlock func(BlockKey)

+ ExpireBlock func(BlockKey)

+ ForEach func(func(BlockKey))

+ ForEachWithContext func(func(BlockKey, Trigger, BlockContext))

+ SetTriggerSpec func(t query.TriggerSpec)

+ type DataType int

+ const TBool

+ const TFloat

+ const TInt

+ const TInvalid

+ const TString

+ const TTime

+ const TUInt

+ func (t DataType) String() string

+ type DataTypeEvaluator interface

+ EvalBool func(scope Scope) bool

+ EvalFloat func(scope Scope) float64

+ EvalInt func(scope Scope) int64

+ EvalString func(scope Scope) string

+ EvalTime func(scope Scope) Time

+ EvalUInt func(scope Scope) uint64

+ Type func() DataType

+ type Dataset interface

+ Finish func(error)

+ RetractBlock func(key BlockKey)

+ SetTriggerSpec func(t query.TriggerSpec)

+ UpdateProcessingTime func(t Time)

+ UpdateWatermark func(mark Time)

+ func NewAggregateTransformationAndDataset(id DatasetID, mode AccumulationMode, bounds Bounds, agg Aggregate) (*aggregateTransformation, Dataset)

+ func NewIndexSelectorTransformationAndDataset(id DatasetID, mode AccumulationMode, bounds Bounds, selector IndexSelector, ...) (*indexSelectorTransformation, Dataset)

+ func NewRowSelectorTransformationAndDataset(id DatasetID, mode AccumulationMode, bounds Bounds, selector RowSelector, ...) (*rowSelectorTransformation, Dataset)

+ type DatasetID uuid.UUID

+ var ZeroDatasetID DatasetID

+ func (id DatasetID) IsZero() bool

+ func (id DatasetID) String() string

+ type DoBoolAgg interface

+ DoBool func([]bool)

+ type DoBoolIndexSelector interface

+ DoBool func([]bool) []int

+ type DoBoolRowSelector interface

+ DoBool func(vs []bool, rr RowReader)

+ type DoFloatAgg interface

+ DoFloat func([]float64)

+ type DoFloatIndexSelector interface

+ DoFloat func([]float64) []int

+ type DoFloatRowSelector interface

+ DoFloat func(vs []float64, rr RowReader)

+ type DoIntAgg interface

+ DoInt func([]int64)

+ type DoIntIndexSelector interface

+ DoInt func([]int64) []int

+ type DoIntRowSelector interface

+ DoInt func(vs []int64, rr RowReader)

+ type DoStringAgg interface

+ DoString func([]string)

+ type DoStringIndexSelector interface

+ DoString func([]string) []int

+ type DoStringRowSelector interface

+ DoString func(vs []string, rr RowReader)

+ type DoUIntAgg interface

+ DoUInt func([]uint64)

+ type DoUIntIndexSelector interface

+ DoUInt func([]uint64) []int

+ type DoUIntRowSelector interface

+ DoUInt func(vs []uint64, rr RowReader)

+ type Duration int64

+ func (d Duration) String() string

+ type Executor interface

+ Execute func(context.Context, *plan.PlanSpec) ([]Result, error)

+ func NewExecutor(c Config) Executor

+ type FinishMsg interface

+ Error func() error

+ type FloatValueFunc interface

+ ValueFloat func() float64

+ type FormatOptions struct

+ RepeatHeaderCount int

+ func DefaultFormatOptions() *FormatOptions

+ type Formatter struct

+ func NewFormatter(b Block, opts *FormatOptions) *Formatter

+ func (f *Formatter) WriteTo(out io.Writer) (int64, error)

+ type IndexSelector interface

+ NewBoolSelector func() DoBoolIndexSelector

+ NewFloatSelector func() DoFloatIndexSelector

+ NewIntSelector func() DoIntIndexSelector

+ NewStringSelector func() DoStringIndexSelector

+ NewUIntSelector func() DoUIntIndexSelector

+ type IntValueFunc interface

+ ValueInt func() int64

+ type Message interface

+ SrcDatasetID func() DatasetID

+ Type func() MessageType

+ type MessageType int

+ const FinishType

+ const ProcessType

+ const RetractBlockType

+ const UpdateProcessingTimeType

+ const UpdateWatermarkType

+ type Node interface

+ AddTransformation func(t Transformation)

+ type OneTimeBlock interface

+ type ProcessMsg interface

+ Block func() Block

+ type ReadSpec struct

+ AggregateType string

+ Database string

+ Descending bool

+ GroupIgnore []string

+ GroupKeep []string

+ GroupKeys []string

+ Hosts []string

+ MergeAll bool

+ OrderByTime bool

+ PointsLimit int64

+ Predicate expression.Expression

+ RAMLimit uint64

+ SeriesLimit int64

+ SeriesOffset int64

+ type Result interface

+ Blocks func() BlockIterator

+ type RetractBlockMsg interface

+ BlockMetadata func() BlockMetadata

+ type Row struct

+ Values []interface{}

+ func ReadRow(i int, rr RowReader) (row Row)

+ type RowReader interface

+ AtBool func(i, j int) bool

+ AtFloat func(i, j int) float64

+ AtInt func(i, j int) int64

+ AtString func(i, j int) string

+ AtTime func(i, j int) Time

+ AtUInt func(i, j int) uint64

+ Cols func() []ColMeta

+ type RowSelector interface

+ NewBoolSelector func() DoBoolRowSelector

+ NewFloatSelector func() DoFloatRowSelector

+ NewIntSelector func() DoIntRowSelector

+ NewStringSelector func() DoStringRowSelector

+ NewUIntSelector func() DoUIntRowSelector

+ type Rower interface

+ Rows func() []Row

+ type Runner interface

+ Run func(ctx context.Context)

+ type Scope map[string]Value

+ func (s Scope) GetBool(name string) bool

+ func (s Scope) GetFloat(name string) float64

+ func (s Scope) GetInt(name string) int64

+ func (s Scope) GetString(name string) string

+ func (s Scope) GetTime(name string) Time

+ func (s Scope) GetUInt(name string) uint64

+ func (s Scope) Type(name string) DataType

+ type Source interface

+ func NewStorageSource(id DatasetID, r StorageReader, readSpec ReadSpec, bounds Bounds, w Window, ...) Source

+ type StorageReader interface

+ Close func()

+ Read func(rs ReadSpec, start, stop Time) (BlockIterator, error)

+ func NewStorageReader(hosts []string) (StorageReader, error)

+ type StringValueFunc interface

+ ValueString func() string

+ type Tags map[string]string

+ func TagsForRow(i int, rr RowReader) Tags

+ func (t Tags) Copy() Tags

+ func (t Tags) Equal(o Tags) bool

+ func (t Tags) IntersectingSubset(keys []string) Tags

+ func (t Tags) Key() TagsKey

+ func (t Tags) Keys() []string

+ func (t Tags) Subset(keys []string) (Tags, bool)

+ type TagsKey string

+ func TagsToKey(order []string, t Tags) TagsKey

+ type Time int64

+ func Now() Time

+ func (t Time) Round(d Duration) Time

+ func (t Time) String() string

+ func (t Time) Time() time.Time

+ func (t Time) Truncate(d Duration) Time

+ type Transformation interface

+ Finish func(id DatasetID, err error)

+ Process func(id DatasetID, b Block)

+ RetractBlock func(id DatasetID, meta BlockMetadata)

+ SetParents func(ids []DatasetID)

+ UpdateProcessingTime func(id DatasetID, t Time)

+ UpdateWatermark func(id DatasetID, t Time)

+ type TransformationTransport struct

+ func (t *TransformationTransport) Finish(id DatasetID, err error)

+ func (t *TransformationTransport) Process(id DatasetID, b Block)

+ func (t *TransformationTransport) RetractBlock(id DatasetID, meta BlockMetadata)

+ func (t *TransformationTransport) Run(ctx context.Context)

+ func (t *TransformationTransport) SetParents(ids []DatasetID)

+ func (t *TransformationTransport) UpdateProcessingTime(id DatasetID, time Time)

+ func (t *TransformationTransport) UpdateWatermark(id DatasetID, time Time)

+ type Trigger interface

+ Finished func() bool

+ Reset func()

+ Triggered func(TriggerContext) bool

+ func NewTriggerFromSpec(spec query.TriggerSpec) Trigger

+ type TriggerContext struct

+ Block BlockContext

+ CurrentProcessingTime Time

+ Watermark Time

+ type UIntValueFunc interface

+ ValueUInt func() uint64

+ type UpdateProcessingTimeMsg interface

+ ProcessingTime func() Time

+ type UpdateWatermarkMsg interface

+ WatermarkTime func() Time

+ type Value struct

+ Type DataType

+ Value interface{}

+ func ValueForRow(i, j int, rr RowReader) (v Value)

+ func (v Value) Bool() bool

+ func (v Value) Float() float64

+ func (v Value) Int() int64

+ func (v Value) Str() string

+ func (v Value) Time() Time

+ func (v Value) UInt() uint64

+ type ValueFunc interface

+ Type func() DataType

+ type ValueIterator interface

+ DoBool func(f func([]bool, RowReader))

+ DoFloat func(f func([]float64, RowReader))

+ DoInt func(f func([]int64, RowReader))

+ DoString func(f func([]string, RowReader))

+ DoTime func(f func([]Time, RowReader))

+ DoUInt func(f func([]uint64, RowReader))

+ type Window struct

+ Every Duration

+ Period Duration

+ Round Duration

+ Start Time

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL