coordinator

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
  • func (s ByteStringSlice) Len() int
  • func (s ByteStringSlice) Less(i, j int) bool
  • func (s ByteStringSlice) Swap(i, j int)
• type KeyValues
  • func (a KeyValues) Len() int
  • func (a KeyValues) Less(i, j int) bool
  • func (a KeyValues) Swap(i, j int)
• type StatementExecutor
  • func (e *StatementExecutor) Close() error
  • func (e *StatementExecutor) ExecuteStatement(stmt influxql.Statement, ctx *query.ExecutionContext, seq int) error
  • func (e *StatementExecutor) FieldKeys(database string, measurements influxql.Measurements) (netstorage.TableColumnKeys, error)
  • func (e *StatementExecutor) GetOptions(opt query.ExecutionOptions, rowsChan chan query.RowsChan) query.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
  • func (a TagKeysSlice) Len() int
  • func (a TagKeysSlice) Less(i, j int) bool
  • func (a TagKeysSlice) Swap(i, j int)

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

func RemoveFiltered(result [][]byte, filetered [][]byte) [][]byte

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

func (KeyValues) Len

func (a KeyValues) Len() int

func (KeyValues) Less

func (a KeyValues) Less(i, j int) bool

Less implements sort.Interface. Keys are compared before values.

func (KeyValues) Swap

func (a KeyValues) Swap(i, j int)

Swap implements sort.Interface.

type StatementExecutor

type StatementExecutor struct {
	MetaClient meta.MetaClient

	// TaskManager holds the StatementExecutor that handles task-related commands.
	TaskManager query.StatementExecutor

	NetStorage netstorage.Storage

	// ShardMapper for mapping shards when executing a SELECT statement.
	ShardMapper query.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
	MaxRowSizeLimit         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 *query.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 query.ExecutionOptions, rowsChan chan query.RowsChan) query.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)