query

Documentation

Index

• type Executor
  • func NewStorageExecutor(engine tsdb.Engine, shardIDs []int32, query *stmt.Query) Executor
• type Plan
• type SeriesSearch

Types

type Executor

type Executor interface {
	// Execute execute query
	// 1) plan query language
	// 2) aggregator data from time series(memory/file/network)
	Execute() <-chan field.GroupedTimeSeries
}

Executor represents a query executor both storage/broker side. When returning query results the following is the order in which processing takes place: 1) filtering 2) Scanning 3) Grouping if need 4) Down sampling 5) Aggregation 6) Functions 7) Expressions

func NewStorageExecutor

func NewStorageExecutor(engine tsdb.Engine, shardIDs []int32, query *stmt.Query) Executor

NewStorageExecutor creates execution which queries the data of storage engine

type Plan

type Plan interface {
	// Plan plans the query language, then generate an execute plan
	Plan() error
}

Plan represents an execute plan of a query language with computing and storage

type SeriesSearch

type SeriesSearch interface {
	// Search searches series ids base on condition, if search fail return nil, else return multi-version series ids
	Search() (*series.MultiVerSeriesIDSet, error)
}

SeriesSearch represents a series search by condition expression