Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var CallNameToAggType = map[string]AggType{ expr.CountCallName: Count, expr.SumCallName: Sum, expr.AvgCallName: Avg, expr.MaxCallName: Max, expr.MinCallName: Min, expr.HllCallName: Hll, }
Functions ¶
This section is empty.
Types ¶
type BlockingPlanNode ¶
type BlockingPlanNode interface { Execute(ctx context.Context) (queryCom.AQLQueryResult, error) Children() []BlockingPlanNode Add(...BlockingPlanNode) }
BlockingPlanNode defines query plan nodes that waits for children to finish
type MergeNode ¶
type MergeNode interface { BlockingPlanNode AggType() AggType }
type QueryExecutor ¶
type QueryExecutor interface { // Execute executes query and flush result to connection Execute(ctx context.Context, requestID string, aql *queryCom.AQLQuery, returnHLLBinary bool, w http.ResponseWriter) (err error) }
QueryExecutor defines query executor
type QueryPlan ¶
type QueryPlan interface {
Execute(ctx context.Context, w http.ResponseWriter) (err error)
}
type SchemaManager ¶
type SchemaManager interface { // Run initializes all schema and starts jobs to sync from controller Run() // GetTable gets schema by namespace and table name GetTableSchemaReader(namespace string) (memCom.TableSchemaReader, error) }
SchemaManager keeps table schema from all namespaces in current ENV up to date
Click to show internal directories.
Click to hide internal directories.