measure

May 9, 2024

Changes in this version

+ func BuildTopNSchema(md *databasev1.Measure) (logical.Schema, error)

+ func TopNAnalyze(_ context.Context, criteria *measurev1.TopNRequest, schema *databasev1.Measure, ...) (logical.Plan, error)

Oct 17, 2023

Changes in this version

+ func DistributedAnalyze(criteria *measurev1.QueryRequest, s logical.Schema) (logical.Plan, error)

Feb 6, 2023

Changes in this version

+ func Analyze(_ context.Context, criteria *measurev1.QueryRequest, ...) (logical.Plan, error)

+ func BuildSchema(measureSchema measure.Measure) (logical.Schema, error)

Nov 5, 2022

Changes in this version

+ func Aggregation(input logical.UnresolvedPlan, aggrField *logical.Field, ...) logical.UnresolvedPlan

+ func GroupBy(input logical.UnresolvedPlan, groupBy [][]*logical.Tag, groupByEntity bool) logical.UnresolvedPlan

+ func IndexScan(startTime, endTime time.Time, metadata *commonv1.Metadata, filter index.Filter, ...) logical.UnresolvedPlan

+ func Limit(input logical.UnresolvedPlan, offset, limit uint32) logical.UnresolvedPlan

+ func Top(input logical.UnresolvedPlan, top *measurev1.QueryRequest_Top) logical.UnresolvedPlan

+ type Analyzer struct

+ func CreateAnalyzerFromMetaService(metaSvc metadata.Service) (*Analyzer, error)

+ func (a *Analyzer) Analyze(_ context.Context, criteria *measurev1.QueryRequest, ...) (logical.Plan, error)

+ func (a *Analyzer) BuildSchema(ctx context.Context, metadata *commonv1.Metadata) (logical.Schema, error)

+ type TopElement struct

+ func NewTopElement(dp *measurev1.DataPoint, value int64) TopElement

+ func (e TopElement) Val() int64

+ type TopQueue struct

+ func NewTopQueue(n int, reverted bool) *TopQueue

+ func (s *TopQueue) Elements() []TopElement

+ func (s *TopQueue) Equal(other *TopQueue) bool

+ func (s *TopQueue) Insert(element TopElement) bool

+ func (s *TopQueue) Purge()

+ func (s TopQueue) String() string