query

package

Go to main page

Versions in this module

v0

v0.0.2

Sep 5, 2019

Changes in this version

type AQLQueryContext

+ DataOnly bool

+ IsNonAggregationQuery bool

+ ResponseWriter http.ResponseWriter

+ func (qc *AQLQueryContext) Compile(tableSchemaReader memCom.TableSchemaReader, shardOwner topology.ShardOwner)

+ func (qc *AQLQueryContext) ResultsRowsFlushed() int

+ type BatchExecutor interface

+ func NewBatchExecutor(qc *AQLQueryContext, batchID int32, customFilterFunc customFilterExecutor, ...) BatchExecutor

+ func NewDummyBatchExecutor() BatchExecutor

+ type BatchExecutorImpl struct

+ type DummyBatchExecutorImpl struct

+ type NonAggrBatchExecutorImpl struct

type OOPKContext

+ func (ctx *OOPKContext) IsHLL() bool

+ func (ctx *OOPKContext) UseHashReduction() bool

v0.0.1

Nov 27, 2018

Changes in this version

+ var BinaryExprTypeToCFunctorType = map[expr.Token]C.enum_BinaryFunctorType

+ var ColumnTypeToExprType = map[string]expr.Type

+ var DataTypeToCDataType = map[memCom.DataType]C.enum_DataType

+ var UnaryExprTypeToCFunctorType = map[expr.Token]C.enum_UnaryFunctorType

+ func GetCurrentCalendarUnit(base time.Time, unit string) (start, end time.Time, err error)

+ type AQLQuery struct

+ Dimensions []Dimension

+ Filters []string

+ Joins []Join

+ Measures []Measure

+ Now int64

+ Table string

+ TimeFilter TimeFilter

+ Timezone string

+ func (q *AQLQuery) Compile(store memstore.MemStore, returnHLL bool) *AQLQueryContext

+ type AQLQueryContext struct

+ Debug bool

+ Device int

+ Error error

+ HLLQueryResult []byte

+ OOPK OOPKContext

+ Prefilters []int

+ Profiling string

+ Query *AQLQuery

+ Results queryCom.AQLTimeSeriesResult

+ ReturnHLLData bool

+ TableIDByAlias map[string]int

+ TableScanners []*TableScanner

+ TableSchemaByName map[string]*memstore.TableSchema

+ func (qc *AQLQueryContext) FindDeviceForQuery(memStore memstore.MemStore, preferredDevice int, deviceManager *DeviceManager, ...)

+ func (qc *AQLQueryContext) Postprocess() queryCom.AQLTimeSeriesResult

+ func (qc *AQLQueryContext) PostprocessAsHLLData() ([]byte, error)

+ func (qc *AQLQueryContext) ProcessQuery(memStore memstore.MemStore)

+ func (qc *AQLQueryContext) Release()

+ func (qc *AQLQueryContext) ReleaseHostResultsBuffers()

+ func (qc *AQLQueryContext) Rewrite(expression expr.Expr) expr.Expr

+ func (qc *AQLQueryContext) SerializeHLL(dataTypes []memCom.DataType, enumDicts map[int][]string, timeDimensions []int) ([]byte, error)

+ type AQLRequest struct

+ Queries []AQLQuery

+ type AQLResponse struct

+ Errors []error

+ QueryContext []*AQLQueryContext

+ Results []queryCom.AQLTimeSeriesResult

+ type DeviceInfo struct

+ DeviceID int

+ FreeMemory int

+ QueryCount int

+ QueryMemoryUsageMap map[*AQLQuery]int

+ TotalAvailableMemory int

+ TotalMemory int

+ type DeviceManager struct

+ DeviceInfos []*DeviceInfo

+ MaxAvailableMemory int

+ Timeout int

+ func NewDeviceManager(cfg common.QueryConfig) *DeviceManager

+ func (d *DeviceManager) FindDevice(query *AQLQuery, requiredMem int, preferredDevice int, timeout int) int

+ func (d *DeviceManager) ReleaseReservedMemory(device int, query *AQLQuery)

+ type Dimension struct

+ Expr string

+ NumericBucketizer NumericBucketizerDef

+ TimeBucketizer string

+ TimeUnit string

+ type HLLDataWriter struct

+ func (builder *HLLDataWriter) SerializeHeader() error

+ type HLLQueryResults struct

+ func NewHLLQueryResults() *HLLQueryResults

+ func (r *HLLQueryResults) GetBytes() []byte

+ func (r *HLLQueryResults) WriteError(err error)

+ func (r *HLLQueryResults) WriteResult(result []byte)

+ type Join struct

+ Alias string

+ Conditions []string

+ Table string

+ type Measure struct

+ Expr string

+ Filters []string

+ type NumericBucketizerDef struct

+ BucketWidth float64

+ LogBase float64

+ ManualPartitions []float64

+ type OOPKContext struct

+ AggregateType C.enum_AggregateFunction

+ ArchiveBatchStats oopkQueryStats

+ DeviceMemoryRequirement int

+ DimRowBytes int

+ DimensionVectorIndex []int

+ Dimensions []expr.Expr

+ DurationWaitedForDevice time.Duration

+ ForeignTableCommonFilters []expr.Expr

+ LiveBatchStats oopkQueryStats

+ MainTableCommonFilters []expr.Expr

+ Measure expr.Expr

+ MeasureBytes int

+ NumDimsPerDimWidth queryCom.DimCountsPerDimWidth

+ Prefilters []expr.Expr

+ ResultSize int

+ TimeFilters [2]expr.Expr

+ type TableScanner struct

+ ArchiveBatchIDEnd int

+ ArchiveBatchIDStart int

+ ColumnUsages map[int]columnUsage

+ Columns []int

+ ColumnsByIDs map[int]int

+ EqualityPrefilterValues []uint32

+ RangePrefilterBoundaries [2]boundaryType

+ RangePrefilterValues [2]uint32

+ Schema *memstore.TableSchema

+ Shards []int

+ type TimeFilter struct

+ Column string

+ From string

+ To string

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