Documentation
¶
Index ¶
- func CalcCardinality(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) (error, int64)
- func GetStatementMessageType(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) string
- func MergeAllNodeFiltered(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) (error, interface{})
- func MergeAllNodeMessage(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) (error, interface{})
- func MergeMeasurementsNames(otherNodeNamesMap map[uint64]*netstorage.ExecuteStatementMessage) (error, [][]byte)
- func MergeTagKeys(otherNodeTagKeysMap *map[uint64][]netstorage.TagKeys) (error, []netstorage.TagKeys)
- func MergeTagValues(otherNodeTagKeysMap *map[uint64][]netstorage.TableTagSets) (error, []netstorage.TableTagSets)
- func RemoveFiltered(result [][]byte, filetered [][]byte) [][]byte
- type ByteStringSlice
- type KeyValues
- type StatementExecutor
- func (e *StatementExecutor) Close() error
- func (e *StatementExecutor) ExecuteStatement(stmt influxql.Statement, ctx *query2.ExecutionContext, seq int) error
- func (e *StatementExecutor) FieldKeys(database string, measurements influxql.Measurements) (netstorage.TableColumnKeys, error)
- func (e *StatementExecutor) GetOptions(opt query2.ExecutionOptions, rowsChan chan query2.RowsChan) query2.SelectOptions
- func (e *StatementExecutor) NormalizeStatement(stmt influxql.Statement, defaultDatabase, defaultRetentionPolicy string) (err error)
- func (e *StatementExecutor) Statistics(buffer []byte) ([]byte, error)
- func (e *StatementExecutor) TagKeys(database string, measurements influxql.Measurements, cond influxql.Expr) (netstorage.TableTagKeys, error)
- type TagKeysSlice
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CalcCardinality ¶
func CalcCardinality(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) (error, int64)
func GetStatementMessageType ¶
func GetStatementMessageType(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) string
func MergeAllNodeFiltered ¶
func MergeAllNodeFiltered(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) (error, interface{})
func MergeAllNodeMessage ¶
func MergeAllNodeMessage(OtherNodesMsg map[uint64]*netstorage.ExecuteStatementMessage) (error, interface{})
func MergeMeasurementsNames ¶
func MergeMeasurementsNames(otherNodeNamesMap map[uint64]*netstorage.ExecuteStatementMessage) (error, [][]byte)
func MergeTagKeys ¶
func MergeTagKeys(otherNodeTagKeysMap *map[uint64][]netstorage.TagKeys) (error, []netstorage.TagKeys)
func MergeTagValues ¶
func MergeTagValues(otherNodeTagKeysMap *map[uint64][]netstorage.TableTagSets) (error, []netstorage.TableTagSets)
func RemoveFiltered ¶
Types ¶
type ByteStringSlice ¶
type ByteStringSlice [][]byte
func (ByteStringSlice) Len ¶
func (s ByteStringSlice) Len() int
func (ByteStringSlice) Less ¶
func (s ByteStringSlice) Less(i, j int) bool
func (ByteStringSlice) Swap ¶
func (s ByteStringSlice) Swap(i, j int)
type KeyValues ¶
type KeyValues []netstorage.TagSet
type StatementExecutor ¶
type StatementExecutor struct {
MetaClient meta.MetaClient
// TaskManager holds the StatementExecutor that handles task-related commands.
TaskManager query2.StatementExecutor
NetStorage netstorage.Storage
// ShardMapper for mapping shards when executing a SELECT statement.
ShardMapper query2.ShardMapper
// Holds monitoring data for SHOW STATS and SHOW DIAGNOSTICS.
MetaExecutor *coordinator.MetaExecutor
// Select statement limits
MaxSelectPointN int
MaxSelectSeriesN int
MaxSelectFieldsN int
MaxSelectBucketsN int
MaxQueryMem int64
QueryTimeCompareEnabled bool
RetentionPolicyLimit int
MaxQueryParallel int
StmtExecLogger *logger.Logger
// hostname for show configs statement
Hostname string
SqlConfigs map[string]interface{}
}
StatementExecutor executes a statement in the query.
func (*StatementExecutor) Close ¶
func (e *StatementExecutor) Close() error
func (*StatementExecutor) ExecuteStatement ¶
func (e *StatementExecutor) ExecuteStatement(stmt influxql.Statement, ctx *query2.ExecutionContext, seq int) error
ExecuteStatement executes the given statement with the given execution context.
func (*StatementExecutor) FieldKeys ¶
func (e *StatementExecutor) FieldKeys(database string, measurements influxql.Measurements) (netstorage.TableColumnKeys, error)
func (*StatementExecutor) GetOptions ¶
func (e *StatementExecutor) GetOptions(opt query2.ExecutionOptions, rowsChan chan query2.RowsChan) query2.SelectOptions
func (*StatementExecutor) NormalizeStatement ¶
func (e *StatementExecutor) NormalizeStatement(stmt influxql.Statement, defaultDatabase, defaultRetentionPolicy string) (err error)
NormalizeStatement adds a default database and policy to the measurements in statement. Parameter defaultRetentionPolicy can be "".
func (*StatementExecutor) Statistics ¶
func (e *StatementExecutor) Statistics(buffer []byte) ([]byte, error)
func (*StatementExecutor) TagKeys ¶
func (e *StatementExecutor) TagKeys(database string, measurements influxql.Measurements, cond influxql.Expr) (netstorage.TableTagKeys, error)
type TagKeysSlice ¶
type TagKeysSlice []netstorage.TagKeys
func (TagKeysSlice) Len ¶
func (a TagKeysSlice) Len() int
func (TagKeysSlice) Less ¶
func (a TagKeysSlice) Less(i, j int) bool
func (TagKeysSlice) Swap ¶
func (a TagKeysSlice) Swap(i, j int)
Source Files
Click to show internal directories.
Click to hide internal directories.