tipb

package
Version: v0.0.0-...-3fd327d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 8, 2021 License: Apache-2.0 Imports: 7 Imported by: 1,280

Documentation

Overview

Package tipb is a generated protocol buffer package.

It is generated from these files:

analyze.proto
checksum.proto
executor.proto
expression.proto
metadata.proto
resourcetag.proto
schema.proto
select.proto
topsql_agent.proto
trace.proto

It has these top-level messages:

AnalyzeReq
AnalyzeIndexReq
AnalyzeColumnsReq
AnalyzeMixedResp
AnalyzeColumnGroup
AnalyzeColumnsResp
AnalyzeIndexResp
Bucket
Histogram
FMSketch
SampleCollector
RowSampleCollector
RowSample
CMSketchRow
CMSketchTopN
CMSketch
ChecksumRewriteRule
ChecksumRequest
ChecksumResponse
Executor
ExchangeSender
ExchangeReceiver
TableScan
Join
IndexScan
Selection
Projection
Aggregation
TopN
Limit
Kill
ExecutorExecutionSummary
FieldType
Expr
RpnExpr
ByItem
InUnionMetadata
CompareInMetadata
ResourceGroupTag
TableInfo
ColumnInfo
IndexInfo
KeyRange
Row
Error
SelectResponse
Chunk
RowMeta
DAGRequest
ChunkMemoryLayout
UserIdentity
StreamResponse
CPUTimeRecord
SQLMeta
PlanMeta
EmptyResponse

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthAnalyze = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAnalyze   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthChecksum = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowChecksum   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthExecutor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecutor   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthExpression = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExpression   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthResourcetag = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourcetag   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchema   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthSelect = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSelect   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthTopsqlAgent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopsqlAgent   = fmt.Errorf("proto: integer overflow")
)
View Source
var AnalyzeType_name = map[int32]string{
	0: "TypeIndex",
	1: "TypeColumn",
	2: "TypeCommonHandle",
	3: "TypeSampleIndex",
	4: "TypeMixed",
	5: "TypeFullSampling",
}
View Source
var AnalyzeType_value = map[string]int32{
	"TypeIndex":        0,
	"TypeColumn":       1,
	"TypeCommonHandle": 2,
	"TypeSampleIndex":  3,
	"TypeMixed":        4,
	"TypeFullSampling": 5,
}
View Source
var ChecksumAlgorithm_name = map[int32]string{
	0: "Crc64_Xor",
}
View Source
var ChecksumAlgorithm_value = map[string]int32{
	"Crc64_Xor": 0,
}
View Source
var ChecksumScanOn_name = map[int32]string{
	0: "Table",
	1: "Index",
}
View Source
var ChecksumScanOn_value = map[string]int32{
	"Table": 0,
	"Index": 1,
}
View Source
var EncodeType_name = map[int32]string{
	0: "TypeDefault",
	1: "TypeChunk",
	2: "TypeCHBlock",
}
View Source
var EncodeType_value = map[string]int32{
	"TypeDefault": 0,
	"TypeChunk":   1,
	"TypeCHBlock": 2,
}
View Source
var Endian_name = map[int32]string{
	0: "LittleEndian",
	1: "BigEndian",
}
View Source
var Endian_value = map[string]int32{
	"LittleEndian": 0,
	"BigEndian":    1,
}
View Source
var EngineType_name = map[int32]string{
	0: "Local",
	1: "TiKV",
	2: "TiFlash",
}
View Source
var EngineType_value = map[string]int32{
	"Local":   0,
	"TiKV":    1,
	"TiFlash": 2,
}
View Source
var Event_name = map[int32]string{
	0:    "Unknown",
	1000: "TiKvCoprGetRequest",
	1001: "TiKvCoprHandleRequest",
	1002: "TiKvCoprScheduleTask",
	1003: "TiKvCoprGetSnapshot",
	1004: "TiKvCoprExecuteDagRunner",
	1005: "TiKvCoprExecuteBatchDagRunner",
}
View Source
var Event_value = map[string]int32{
	"Unknown":                       0,
	"TiKvCoprGetRequest":            1000,
	"TiKvCoprHandleRequest":         1001,
	"TiKvCoprScheduleTask":          1002,
	"TiKvCoprGetSnapshot":           1003,
	"TiKvCoprExecuteDagRunner":      1004,
	"TiKvCoprExecuteBatchDagRunner": 1005,
}
View Source
var ExchangeType_name = map[int32]string{
	0: "PassThrough",
	1: "Broadcast",
	2: "Hash",
}
View Source
var ExchangeType_value = map[string]int32{
	"PassThrough": 0,
	"Broadcast":   1,
	"Hash":        2,
}
View Source
var ExecType_name = map[int32]string{
	0:  "TypeTableScan",
	1:  "TypeIndexScan",
	2:  "TypeSelection",
	3:  "TypeAggregation",
	4:  "TypeTopN",
	5:  "TypeLimit",
	6:  "TypeStreamAgg",
	7:  "TypeJoin",
	8:  "TypeKill",
	9:  "TypeExchangeSender",
	10: "TypeExchangeReceiver",
	11: "TypeProjection",
}
View Source
var ExecType_value = map[string]int32{
	"TypeTableScan":        0,
	"TypeIndexScan":        1,
	"TypeSelection":        2,
	"TypeAggregation":      3,
	"TypeTopN":             4,
	"TypeLimit":            5,
	"TypeStreamAgg":        6,
	"TypeJoin":             7,
	"TypeKill":             8,
	"TypeExchangeSender":   9,
	"TypeExchangeReceiver": 10,
	"TypeProjection":       11,
}
View Source
var ExprType_name = map[int32]string{
	0:     "Null",
	1:     "Int64",
	2:     "Uint64",
	3:     "Float32",
	4:     "Float64",
	5:     "String",
	6:     "Bytes",
	101:   "MysqlBit",
	102:   "MysqlDecimal",
	103:   "MysqlDuration",
	104:   "MysqlEnum",
	105:   "MysqlHex",
	106:   "MysqlSet",
	107:   "MysqlTime",
	108:   "MysqlJson",
	151:   "ValueList",
	201:   "ColumnRef",
	3001:  "Count",
	3002:  "Sum",
	3003:  "Avg",
	3004:  "Min",
	3005:  "Max",
	3006:  "First",
	3007:  "GroupConcat",
	3008:  "Agg_BitAnd",
	3009:  "Agg_BitOr",
	3010:  "Agg_BitXor",
	3011:  "Std",
	3012:  "Stddev",
	3013:  "StddevPop",
	3014:  "StddevSamp",
	3015:  "VarPop",
	3016:  "VarSamp",
	3017:  "Variance",
	3018:  "JsonArrayAgg",
	3019:  "JsonObjectAgg",
	3020:  "ApproxCountDistinct",
	10000: "ScalarFunc",
}
View Source
var ExprType_value = map[string]int32{
	"Null":                0,
	"Int64":               1,
	"Uint64":              2,
	"Float32":             3,
	"Float64":             4,
	"String":              5,
	"Bytes":               6,
	"MysqlBit":            101,
	"MysqlDecimal":        102,
	"MysqlDuration":       103,
	"MysqlEnum":           104,
	"MysqlHex":            105,
	"MysqlSet":            106,
	"MysqlTime":           107,
	"MysqlJson":           108,
	"ValueList":           151,
	"ColumnRef":           201,
	"Count":               3001,
	"Sum":                 3002,
	"Avg":                 3003,
	"Min":                 3004,
	"Max":                 3005,
	"First":               3006,
	"GroupConcat":         3007,
	"Agg_BitAnd":          3008,
	"Agg_BitOr":           3009,
	"Agg_BitXor":          3010,
	"Std":                 3011,
	"Stddev":              3012,
	"StddevPop":           3013,
	"StddevSamp":          3014,
	"VarPop":              3015,
	"VarSamp":             3016,
	"Variance":            3017,
	"JsonArrayAgg":        3018,
	"JsonObjectAgg":       3019,
	"ApproxCountDistinct": 3020,
	"ScalarFunc":          10000,
}
View Source
var JoinExecType_name = map[int32]string{
	0: "TypeHashJoin",
}
View Source
var JoinExecType_value = map[string]int32{
	"TypeHashJoin": 0,
}
View Source
var JoinType_name = map[int32]string{
	0: "TypeInnerJoin",
	1: "TypeLeftOuterJoin",
	2: "TypeRightOuterJoin",
	3: "TypeSemiJoin",
	4: "TypeAntiSemiJoin",
	5: "TypeLeftOuterSemiJoin",
	6: "TypeAntiLeftOuterSemiJoin",
}
View Source
var JoinType_value = map[string]int32{
	"TypeInnerJoin":             0,
	"TypeLeftOuterJoin":         1,
	"TypeRightOuterJoin":        2,
	"TypeSemiJoin":              3,
	"TypeAntiSemiJoin":          4,
	"TypeLeftOuterSemiJoin":     5,
	"TypeAntiLeftOuterSemiJoin": 6,
}
View Source
var ScalarFuncSig_name = map[int32]string{}/* 550 elements not displayed */
View Source
var ScalarFuncSig_value = map[string]int32{}/* 550 elements not displayed */

Functions

func RegisterTopSQLAgentServer

func RegisterTopSQLAgentServer(s *grpc.Server, srv TopSQLAgentServer)

Types

type Aggregation

type Aggregation struct {
	// Group by clause.
	GroupBy    []*Expr    `protobuf:"bytes,1,rep,name=group_by,json=groupBy" json:"group_by,omitempty"`
	RpnGroupBy []*RpnExpr `protobuf:"bytes,4,rep,name=rpn_group_by,json=rpnGroupBy" json:"rpn_group_by,omitempty"`
	// Aggregate functions.
	AggFunc    []*Expr    `protobuf:"bytes,2,rep,name=agg_func,json=aggFunc" json:"agg_func,omitempty"`
	RpnAggFunc []*RpnExpr `protobuf:"bytes,5,rep,name=rpn_agg_func,json=rpnAggFunc" json:"rpn_agg_func,omitempty"`
	// If it is a stream aggregation.
	Streamed         bool      `protobuf:"varint,3,opt,name=streamed" json:"streamed"`
	Child            *Executor `protobuf:"bytes,6,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*Aggregation) Descriptor

func (*Aggregation) Descriptor() ([]byte, []int)

func (*Aggregation) GetAggFunc

func (m *Aggregation) GetAggFunc() []*Expr

func (*Aggregation) GetChild

func (m *Aggregation) GetChild() *Executor

func (*Aggregation) GetGroupBy

func (m *Aggregation) GetGroupBy() []*Expr

func (*Aggregation) GetRpnAggFunc

func (m *Aggregation) GetRpnAggFunc() []*RpnExpr

func (*Aggregation) GetRpnGroupBy

func (m *Aggregation) GetRpnGroupBy() []*RpnExpr

func (*Aggregation) GetStreamed

func (m *Aggregation) GetStreamed() bool

func (*Aggregation) Marshal

func (m *Aggregation) Marshal() (dAtA []byte, err error)

func (*Aggregation) MarshalTo

func (m *Aggregation) MarshalTo(dAtA []byte) (int, error)

func (*Aggregation) ProtoMessage

func (*Aggregation) ProtoMessage()

func (*Aggregation) Reset

func (m *Aggregation) Reset()

func (*Aggregation) Size

func (m *Aggregation) Size() (n int)

func (*Aggregation) String

func (m *Aggregation) String() string

func (*Aggregation) Unmarshal

func (m *Aggregation) Unmarshal(dAtA []byte) error

type AnalyzeColumnGroup

type AnalyzeColumnGroup struct {
	ColumnOffsets    []int64 `protobuf:"varint,1,rep,name=column_offsets,json=columnOffsets" json:"column_offsets,omitempty"`
	PrefixLengths    []int64 `protobuf:"varint,2,rep,name=prefix_lengths,json=prefixLengths" json:"prefix_lengths,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AnalyzeColumnGroup) Descriptor

func (*AnalyzeColumnGroup) Descriptor() ([]byte, []int)

func (*AnalyzeColumnGroup) GetColumnOffsets

func (m *AnalyzeColumnGroup) GetColumnOffsets() []int64

func (*AnalyzeColumnGroup) GetPrefixLengths

func (m *AnalyzeColumnGroup) GetPrefixLengths() []int64

func (*AnalyzeColumnGroup) Marshal

func (m *AnalyzeColumnGroup) Marshal() (dAtA []byte, err error)

func (*AnalyzeColumnGroup) MarshalTo

func (m *AnalyzeColumnGroup) MarshalTo(dAtA []byte) (int, error)

func (*AnalyzeColumnGroup) ProtoMessage

func (*AnalyzeColumnGroup) ProtoMessage()

func (*AnalyzeColumnGroup) Reset

func (m *AnalyzeColumnGroup) Reset()

func (*AnalyzeColumnGroup) Size

func (m *AnalyzeColumnGroup) Size() (n int)

func (*AnalyzeColumnGroup) String

func (m *AnalyzeColumnGroup) String() string

func (*AnalyzeColumnGroup) Unmarshal

func (m *AnalyzeColumnGroup) Unmarshal(dAtA []byte) error

type AnalyzeColumnsReq

type AnalyzeColumnsReq struct {
	// bucket_size is the max histograms bucket size, we need this because when primary key is handle,
	// the histogram will be directly built.
	BucketSize int64 `protobuf:"varint,1,opt,name=bucket_size,json=bucketSize" json:"bucket_size"`
	// sample_size is the max number of samples that will be collected.
	SampleSize int64 `protobuf:"varint,2,opt,name=sample_size,json=sampleSize" json:"sample_size"`
	// sketch_size is the max sketch size.
	SketchSize int64 `protobuf:"varint,3,opt,name=sketch_size,json=sketchSize" json:"sketch_size"`
	// columns_info is the info of all the columns that needs to be analyzed.
	ColumnsInfo            []*ColumnInfo         `protobuf:"bytes,4,rep,name=columns_info,json=columnsInfo" json:"columns_info,omitempty"`
	CmsketchDepth          *int32                `protobuf:"varint,5,opt,name=cmsketch_depth,json=cmsketchDepth" json:"cmsketch_depth,omitempty"`
	CmsketchWidth          *int32                `protobuf:"varint,6,opt,name=cmsketch_width,json=cmsketchWidth" json:"cmsketch_width,omitempty"`
	PrimaryColumnIds       []int64               `protobuf:"varint,7,rep,name=primary_column_ids,json=primaryColumnIds" json:"primary_column_ids,omitempty"`
	Version                *int32                `protobuf:"varint,8,opt,name=version" json:"version,omitempty"`
	PrimaryPrefixColumnIds []int64               `protobuf:"varint,9,rep,name=primary_prefix_column_ids,json=primaryPrefixColumnIds" json:"primary_prefix_column_ids,omitempty"`
	ColumnGroups           []*AnalyzeColumnGroup `protobuf:"bytes,10,rep,name=column_groups,json=columnGroups" json:"column_groups,omitempty"`
	XXX_unrecognized       []byte                `json:"-"`
}

func (*AnalyzeColumnsReq) Descriptor

func (*AnalyzeColumnsReq) Descriptor() ([]byte, []int)

func (*AnalyzeColumnsReq) GetBucketSize

func (m *AnalyzeColumnsReq) GetBucketSize() int64

func (*AnalyzeColumnsReq) GetCmsketchDepth

func (m *AnalyzeColumnsReq) GetCmsketchDepth() int32

func (*AnalyzeColumnsReq) GetCmsketchWidth

func (m *AnalyzeColumnsReq) GetCmsketchWidth() int32

func (*AnalyzeColumnsReq) GetColumnGroups

func (m *AnalyzeColumnsReq) GetColumnGroups() []*AnalyzeColumnGroup

func (*AnalyzeColumnsReq) GetColumnsInfo

func (m *AnalyzeColumnsReq) GetColumnsInfo() []*ColumnInfo

func (*AnalyzeColumnsReq) GetPrimaryColumnIds

func (m *AnalyzeColumnsReq) GetPrimaryColumnIds() []int64

func (*AnalyzeColumnsReq) GetPrimaryPrefixColumnIds

func (m *AnalyzeColumnsReq) GetPrimaryPrefixColumnIds() []int64

func (*AnalyzeColumnsReq) GetSampleSize

func (m *AnalyzeColumnsReq) GetSampleSize() int64

func (*AnalyzeColumnsReq) GetSketchSize

func (m *AnalyzeColumnsReq) GetSketchSize() int64

func (*AnalyzeColumnsReq) GetVersion

func (m *AnalyzeColumnsReq) GetVersion() int32

func (*AnalyzeColumnsReq) Marshal

func (m *AnalyzeColumnsReq) Marshal() (dAtA []byte, err error)

func (*AnalyzeColumnsReq) MarshalTo

func (m *AnalyzeColumnsReq) MarshalTo(dAtA []byte) (int, error)

func (*AnalyzeColumnsReq) ProtoMessage

func (*AnalyzeColumnsReq) ProtoMessage()

func (*AnalyzeColumnsReq) Reset

func (m *AnalyzeColumnsReq) Reset()

func (*AnalyzeColumnsReq) Size

func (m *AnalyzeColumnsReq) Size() (n int)

func (*AnalyzeColumnsReq) String

func (m *AnalyzeColumnsReq) String() string

func (*AnalyzeColumnsReq) Unmarshal

func (m *AnalyzeColumnsReq) Unmarshal(dAtA []byte) error

type AnalyzeColumnsResp

type AnalyzeColumnsResp struct {
	// collectors is the sample collectors for columns.
	Collectors []*SampleCollector `protobuf:"bytes,1,rep,name=collectors" json:"collectors,omitempty"`
	// pk_hist is the histogram for primary key when it is the handle.
	PkHist           *Histogram          `protobuf:"bytes,2,opt,name=pk_hist,json=pkHist" json:"pk_hist,omitempty"`
	RowCollector     *RowSampleCollector `protobuf:"bytes,3,opt,name=row_collector,json=rowCollector" json:"row_collector,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*AnalyzeColumnsResp) Descriptor

func (*AnalyzeColumnsResp) Descriptor() ([]byte, []int)

func (*AnalyzeColumnsResp) GetCollectors

func (m *AnalyzeColumnsResp) GetCollectors() []*SampleCollector

func (*AnalyzeColumnsResp) GetPkHist

func (m *AnalyzeColumnsResp) GetPkHist() *Histogram

func (*AnalyzeColumnsResp) GetRowCollector

func (m *AnalyzeColumnsResp) GetRowCollector() *RowSampleCollector

func (*AnalyzeColumnsResp) Marshal

func (m *AnalyzeColumnsResp) Marshal() (dAtA []byte, err error)

func (*AnalyzeColumnsResp) MarshalTo

func (m *AnalyzeColumnsResp) MarshalTo(dAtA []byte) (int, error)

func (*AnalyzeColumnsResp) ProtoMessage

func (*AnalyzeColumnsResp) ProtoMessage()

func (*AnalyzeColumnsResp) Reset

func (m *AnalyzeColumnsResp) Reset()

func (*AnalyzeColumnsResp) Size

func (m *AnalyzeColumnsResp) Size() (n int)

func (*AnalyzeColumnsResp) String

func (m *AnalyzeColumnsResp) String() string

func (*AnalyzeColumnsResp) Unmarshal

func (m *AnalyzeColumnsResp) Unmarshal(dAtA []byte) error

type AnalyzeIndexReq

type AnalyzeIndexReq struct {
	// bucket_size is the max histograms bucket size.
	BucketSize int64 `protobuf:"varint,1,opt,name=bucket_size,json=bucketSize" json:"bucket_size"`
	// num_columns is the number of columns in the index.
	NumColumns       int32  `protobuf:"varint,2,opt,name=num_columns,json=numColumns" json:"num_columns"`
	CmsketchDepth    *int32 `protobuf:"varint,3,opt,name=cmsketch_depth,json=cmsketchDepth" json:"cmsketch_depth,omitempty"`
	CmsketchWidth    *int32 `protobuf:"varint,4,opt,name=cmsketch_width,json=cmsketchWidth" json:"cmsketch_width,omitempty"`
	SampleSize       int64  `protobuf:"varint,5,opt,name=sample_size,json=sampleSize" json:"sample_size"`
	SketchSize       int64  `protobuf:"varint,6,opt,name=sketch_size,json=sketchSize" json:"sketch_size"`
	TopNSize         *int32 `protobuf:"varint,7,opt,name=top_n_size,json=topNSize" json:"top_n_size,omitempty"`
	Version          *int32 `protobuf:"varint,8,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AnalyzeIndexReq) Descriptor

func (*AnalyzeIndexReq) Descriptor() ([]byte, []int)

func (*AnalyzeIndexReq) GetBucketSize

func (m *AnalyzeIndexReq) GetBucketSize() int64

func (*AnalyzeIndexReq) GetCmsketchDepth

func (m *AnalyzeIndexReq) GetCmsketchDepth() int32

func (*AnalyzeIndexReq) GetCmsketchWidth

func (m *AnalyzeIndexReq) GetCmsketchWidth() int32

func (*AnalyzeIndexReq) GetNumColumns

func (m *AnalyzeIndexReq) GetNumColumns() int32

func (*AnalyzeIndexReq) GetSampleSize

func (m *AnalyzeIndexReq) GetSampleSize() int64

func (*AnalyzeIndexReq) GetSketchSize

func (m *AnalyzeIndexReq) GetSketchSize() int64

func (*AnalyzeIndexReq) GetTopNSize

func (m *AnalyzeIndexReq) GetTopNSize() int32

func (*AnalyzeIndexReq) GetVersion

func (m *AnalyzeIndexReq) GetVersion() int32

func (*AnalyzeIndexReq) Marshal

func (m *AnalyzeIndexReq) Marshal() (dAtA []byte, err error)

func (*AnalyzeIndexReq) MarshalTo

func (m *AnalyzeIndexReq) MarshalTo(dAtA []byte) (int, error)

func (*AnalyzeIndexReq) ProtoMessage

func (*AnalyzeIndexReq) ProtoMessage()

func (*AnalyzeIndexReq) Reset

func (m *AnalyzeIndexReq) Reset()

func (*AnalyzeIndexReq) Size

func (m *AnalyzeIndexReq) Size() (n int)

func (*AnalyzeIndexReq) String

func (m *AnalyzeIndexReq) String() string

func (*AnalyzeIndexReq) Unmarshal

func (m *AnalyzeIndexReq) Unmarshal(dAtA []byte) error

type AnalyzeIndexResp

type AnalyzeIndexResp struct {
	Hist             *Histogram       `protobuf:"bytes,1,opt,name=hist" json:"hist,omitempty"`
	Cms              *CMSketch        `protobuf:"bytes,2,opt,name=cms" json:"cms,omitempty"`
	Collector        *SampleCollector `protobuf:"bytes,3,opt,name=collector" json:"collector,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*AnalyzeIndexResp) Descriptor

func (*AnalyzeIndexResp) Descriptor() ([]byte, []int)

func (*AnalyzeIndexResp) GetCms

func (m *AnalyzeIndexResp) GetCms() *CMSketch

func (*AnalyzeIndexResp) GetCollector

func (m *AnalyzeIndexResp) GetCollector() *SampleCollector

func (*AnalyzeIndexResp) GetHist

func (m *AnalyzeIndexResp) GetHist() *Histogram

func (*AnalyzeIndexResp) Marshal

func (m *AnalyzeIndexResp) Marshal() (dAtA []byte, err error)

func (*AnalyzeIndexResp) MarshalTo

func (m *AnalyzeIndexResp) MarshalTo(dAtA []byte) (int, error)

func (*AnalyzeIndexResp) ProtoMessage

func (*AnalyzeIndexResp) ProtoMessage()

func (*AnalyzeIndexResp) Reset

func (m *AnalyzeIndexResp) Reset()

func (*AnalyzeIndexResp) Size

func (m *AnalyzeIndexResp) Size() (n int)

func (*AnalyzeIndexResp) String

func (m *AnalyzeIndexResp) String() string

func (*AnalyzeIndexResp) Unmarshal

func (m *AnalyzeIndexResp) Unmarshal(dAtA []byte) error

type AnalyzeMixedResp

type AnalyzeMixedResp struct {
	ColumnsResp      *AnalyzeColumnsResp `protobuf:"bytes,1,opt,name=columns_resp,json=columnsResp" json:"columns_resp,omitempty"`
	IndexResp        *AnalyzeIndexResp   `protobuf:"bytes,2,opt,name=index_resp,json=indexResp" json:"index_resp,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*AnalyzeMixedResp) Descriptor

func (*AnalyzeMixedResp) Descriptor() ([]byte, []int)

func (*AnalyzeMixedResp) GetColumnsResp

func (m *AnalyzeMixedResp) GetColumnsResp() *AnalyzeColumnsResp

func (*AnalyzeMixedResp) GetIndexResp

func (m *AnalyzeMixedResp) GetIndexResp() *AnalyzeIndexResp

func (*AnalyzeMixedResp) Marshal

func (m *AnalyzeMixedResp) Marshal() (dAtA []byte, err error)

func (*AnalyzeMixedResp) MarshalTo

func (m *AnalyzeMixedResp) MarshalTo(dAtA []byte) (int, error)

func (*AnalyzeMixedResp) ProtoMessage

func (*AnalyzeMixedResp) ProtoMessage()

func (*AnalyzeMixedResp) Reset

func (m *AnalyzeMixedResp) Reset()

func (*AnalyzeMixedResp) Size

func (m *AnalyzeMixedResp) Size() (n int)

func (*AnalyzeMixedResp) String

func (m *AnalyzeMixedResp) String() string

func (*AnalyzeMixedResp) Unmarshal

func (m *AnalyzeMixedResp) Unmarshal(dAtA []byte) error

type AnalyzeReq

type AnalyzeReq struct {
	Tp AnalyzeType `protobuf:"varint,1,opt,name=tp,enum=tipb.AnalyzeType" json:"tp"`
	// Deprecated. Start Ts has been moved to coprocessor.Request.
	StartTsFallback  *uint64            `protobuf:"varint,2,opt,name=start_ts_fallback,json=startTsFallback" json:"start_ts_fallback,omitempty"`
	Flags            uint64             `protobuf:"varint,3,opt,name=flags" json:"flags"`
	TimeZoneOffset   int64              `protobuf:"varint,4,opt,name=time_zone_offset,json=timeZoneOffset" json:"time_zone_offset"`
	IdxReq           *AnalyzeIndexReq   `protobuf:"bytes,5,opt,name=idx_req,json=idxReq" json:"idx_req,omitempty"`
	ColReq           *AnalyzeColumnsReq `protobuf:"bytes,6,opt,name=col_req,json=colReq" json:"col_req,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*AnalyzeReq) Descriptor

func (*AnalyzeReq) Descriptor() ([]byte, []int)

func (*AnalyzeReq) GetColReq

func (m *AnalyzeReq) GetColReq() *AnalyzeColumnsReq

func (*AnalyzeReq) GetFlags

func (m *AnalyzeReq) GetFlags() uint64

func (*AnalyzeReq) GetIdxReq

func (m *AnalyzeReq) GetIdxReq() *AnalyzeIndexReq

func (*AnalyzeReq) GetStartTsFallback

func (m *AnalyzeReq) GetStartTsFallback() uint64

func (*AnalyzeReq) GetTimeZoneOffset

func (m *AnalyzeReq) GetTimeZoneOffset() int64

func (*AnalyzeReq) GetTp

func (m *AnalyzeReq) GetTp() AnalyzeType

func (*AnalyzeReq) Marshal

func (m *AnalyzeReq) Marshal() (dAtA []byte, err error)

func (*AnalyzeReq) MarshalTo

func (m *AnalyzeReq) MarshalTo(dAtA []byte) (int, error)

func (*AnalyzeReq) ProtoMessage

func (*AnalyzeReq) ProtoMessage()

func (*AnalyzeReq) Reset

func (m *AnalyzeReq) Reset()

func (*AnalyzeReq) Size

func (m *AnalyzeReq) Size() (n int)

func (*AnalyzeReq) String

func (m *AnalyzeReq) String() string

func (*AnalyzeReq) Unmarshal

func (m *AnalyzeReq) Unmarshal(dAtA []byte) error

type AnalyzeType

type AnalyzeType int32
const (
	AnalyzeType_TypeIndex        AnalyzeType = 0
	AnalyzeType_TypeColumn       AnalyzeType = 1
	AnalyzeType_TypeCommonHandle AnalyzeType = 2
	AnalyzeType_TypeSampleIndex  AnalyzeType = 3
	AnalyzeType_TypeMixed        AnalyzeType = 4
	AnalyzeType_TypeFullSampling AnalyzeType = 5
)

func (AnalyzeType) Enum

func (x AnalyzeType) Enum() *AnalyzeType

func (AnalyzeType) EnumDescriptor

func (AnalyzeType) EnumDescriptor() ([]byte, []int)

func (AnalyzeType) String

func (x AnalyzeType) String() string

func (*AnalyzeType) UnmarshalJSON

func (x *AnalyzeType) UnmarshalJSON(data []byte) error

type Bucket

type Bucket struct {
	Count            int64  `protobuf:"varint,1,opt,name=count" json:"count"`
	LowerBound       []byte `protobuf:"bytes,2,opt,name=lower_bound,json=lowerBound" json:"lower_bound,omitempty"`
	UpperBound       []byte `protobuf:"bytes,3,opt,name=upper_bound,json=upperBound" json:"upper_bound,omitempty"`
	Repeats          int64  `protobuf:"varint,4,opt,name=repeats" json:"repeats"`
	Ndv              *int64 `protobuf:"varint,5,opt,name=ndv" json:"ndv,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Bucket is an element of histogram.

func (*Bucket) Descriptor

func (*Bucket) Descriptor() ([]byte, []int)

func (*Bucket) GetCount

func (m *Bucket) GetCount() int64

func (*Bucket) GetLowerBound

func (m *Bucket) GetLowerBound() []byte

func (*Bucket) GetNdv

func (m *Bucket) GetNdv() int64

func (*Bucket) GetRepeats

func (m *Bucket) GetRepeats() int64

func (*Bucket) GetUpperBound

func (m *Bucket) GetUpperBound() []byte

func (*Bucket) Marshal

func (m *Bucket) Marshal() (dAtA []byte, err error)

func (*Bucket) MarshalTo

func (m *Bucket) MarshalTo(dAtA []byte) (int, error)

func (*Bucket) ProtoMessage

func (*Bucket) ProtoMessage()

func (*Bucket) Reset

func (m *Bucket) Reset()

func (*Bucket) Size

func (m *Bucket) Size() (n int)

func (*Bucket) String

func (m *Bucket) String() string

func (*Bucket) Unmarshal

func (m *Bucket) Unmarshal(dAtA []byte) error

type ByItem

type ByItem struct {
	Expr             *Expr    `protobuf:"bytes,1,opt,name=expr" json:"expr,omitempty"`
	RpnExpr          *RpnExpr `protobuf:"bytes,3,opt,name=rpn_expr,json=rpnExpr" json:"rpn_expr,omitempty"`
	Desc             bool     `protobuf:"varint,2,opt,name=desc" json:"desc"`
	XXX_unrecognized []byte   `json:"-"`
}

ByItem type for group by and order by.

func (*ByItem) Descriptor

func (*ByItem) Descriptor() ([]byte, []int)

func (*ByItem) GetDesc

func (m *ByItem) GetDesc() bool

func (*ByItem) GetExpr

func (m *ByItem) GetExpr() *Expr

func (*ByItem) GetRpnExpr

func (m *ByItem) GetRpnExpr() *RpnExpr

func (*ByItem) Marshal

func (m *ByItem) Marshal() (dAtA []byte, err error)

func (*ByItem) MarshalTo

func (m *ByItem) MarshalTo(dAtA []byte) (int, error)

func (*ByItem) ProtoMessage

func (*ByItem) ProtoMessage()

func (*ByItem) Reset

func (m *ByItem) Reset()

func (*ByItem) Size

func (m *ByItem) Size() (n int)

func (*ByItem) String

func (m *ByItem) String() string

func (*ByItem) Unmarshal

func (m *ByItem) Unmarshal(dAtA []byte) error

type CMSketch

type CMSketch struct {
	Rows             []*CMSketchRow  `protobuf:"bytes,1,rep,name=rows" json:"rows,omitempty"`
	TopN             []*CMSketchTopN `protobuf:"bytes,2,rep,name=top_n,json=topN" json:"top_n,omitempty"`
	DefaultValue     uint64          `protobuf:"varint,3,opt,name=default_value,json=defaultValue" json:"default_value"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*CMSketch) Descriptor

func (*CMSketch) Descriptor() ([]byte, []int)

func (*CMSketch) GetDefaultValue

func (m *CMSketch) GetDefaultValue() uint64

func (*CMSketch) GetRows

func (m *CMSketch) GetRows() []*CMSketchRow

func (*CMSketch) GetTopN

func (m *CMSketch) GetTopN() []*CMSketchTopN

func (*CMSketch) Marshal

func (m *CMSketch) Marshal() (dAtA []byte, err error)

func (*CMSketch) MarshalTo

func (m *CMSketch) MarshalTo(dAtA []byte) (int, error)

func (*CMSketch) ProtoMessage

func (*CMSketch) ProtoMessage()

func (*CMSketch) Reset

func (m *CMSketch) Reset()

func (*CMSketch) Size

func (m *CMSketch) Size() (n int)

func (*CMSketch) String

func (m *CMSketch) String() string

func (*CMSketch) Unmarshal

func (m *CMSketch) Unmarshal(dAtA []byte) error

type CMSketchRow

type CMSketchRow struct {
	Counters         []uint32 `protobuf:"varint,1,rep,name=counters" json:"counters,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*CMSketchRow) Descriptor

func (*CMSketchRow) Descriptor() ([]byte, []int)

func (*CMSketchRow) GetCounters

func (m *CMSketchRow) GetCounters() []uint32

func (*CMSketchRow) Marshal

func (m *CMSketchRow) Marshal() (dAtA []byte, err error)

func (*CMSketchRow) MarshalTo

func (m *CMSketchRow) MarshalTo(dAtA []byte) (int, error)

func (*CMSketchRow) ProtoMessage

func (*CMSketchRow) ProtoMessage()

func (*CMSketchRow) Reset

func (m *CMSketchRow) Reset()

func (*CMSketchRow) Size

func (m *CMSketchRow) Size() (n int)

func (*CMSketchRow) String

func (m *CMSketchRow) String() string

func (*CMSketchRow) Unmarshal

func (m *CMSketchRow) Unmarshal(dAtA []byte) error

type CMSketchTopN

type CMSketchTopN struct {
	Data             []byte `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
	Count            uint64 `protobuf:"varint,2,opt,name=count" json:"count"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CMSketchTopN) Descriptor

func (*CMSketchTopN) Descriptor() ([]byte, []int)

func (*CMSketchTopN) GetCount

func (m *CMSketchTopN) GetCount() uint64

func (*CMSketchTopN) GetData

func (m *CMSketchTopN) GetData() []byte

func (*CMSketchTopN) Marshal

func (m *CMSketchTopN) Marshal() (dAtA []byte, err error)

func (*CMSketchTopN) MarshalTo

func (m *CMSketchTopN) MarshalTo(dAtA []byte) (int, error)

func (*CMSketchTopN) ProtoMessage

func (*CMSketchTopN) ProtoMessage()

func (*CMSketchTopN) Reset

func (m *CMSketchTopN) Reset()

func (*CMSketchTopN) Size

func (m *CMSketchTopN) Size() (n int)

func (*CMSketchTopN) String

func (m *CMSketchTopN) String() string

func (*CMSketchTopN) Unmarshal

func (m *CMSketchTopN) Unmarshal(dAtA []byte) error

type CPUTimeRecord

type CPUTimeRecord struct {
	SqlDigest  []byte `protobuf:"bytes,1,opt,name=sql_digest,json=sqlDigest,proto3" json:"sql_digest,omitempty"`
	PlanDigest []byte `protobuf:"bytes,2,opt,name=plan_digest,json=planDigest,proto3" json:"plan_digest,omitempty"`
	// The following 2 repeated zipped together represents a List<(UnixTimestamp, CPUTime)>
	RecordListTimestampSec []uint64 `` /* 133-byte string literal not displayed */
	RecordListCpuTimeMs    []uint32 `` /* 126-byte string literal not displayed */
}

func (*CPUTimeRecord) Descriptor

func (*CPUTimeRecord) Descriptor() ([]byte, []int)

func (*CPUTimeRecord) GetPlanDigest

func (m *CPUTimeRecord) GetPlanDigest() []byte

func (*CPUTimeRecord) GetRecordListCpuTimeMs

func (m *CPUTimeRecord) GetRecordListCpuTimeMs() []uint32

func (*CPUTimeRecord) GetRecordListTimestampSec

func (m *CPUTimeRecord) GetRecordListTimestampSec() []uint64

func (*CPUTimeRecord) GetSqlDigest

func (m *CPUTimeRecord) GetSqlDigest() []byte

func (*CPUTimeRecord) Marshal

func (m *CPUTimeRecord) Marshal() (dAtA []byte, err error)

func (*CPUTimeRecord) MarshalTo

func (m *CPUTimeRecord) MarshalTo(dAtA []byte) (int, error)

func (*CPUTimeRecord) ProtoMessage

func (*CPUTimeRecord) ProtoMessage()

func (*CPUTimeRecord) Reset

func (m *CPUTimeRecord) Reset()

func (*CPUTimeRecord) Size

func (m *CPUTimeRecord) Size() (n int)

func (*CPUTimeRecord) String

func (m *CPUTimeRecord) String() string

func (*CPUTimeRecord) Unmarshal

func (m *CPUTimeRecord) Unmarshal(dAtA []byte) error

type ChecksumAlgorithm

type ChecksumAlgorithm int32
const (
	ChecksumAlgorithm_Crc64_Xor ChecksumAlgorithm = 0
)

func (ChecksumAlgorithm) Enum

func (ChecksumAlgorithm) EnumDescriptor

func (ChecksumAlgorithm) EnumDescriptor() ([]byte, []int)

func (ChecksumAlgorithm) String

func (x ChecksumAlgorithm) String() string

func (*ChecksumAlgorithm) UnmarshalJSON

func (x *ChecksumAlgorithm) UnmarshalJSON(data []byte) error

type ChecksumRequest

type ChecksumRequest struct {
	// Deprecated. Start Ts has been moved to coprocessor.Request.
	StartTsFallback  *uint64              `protobuf:"varint,1,opt,name=start_ts_fallback,json=startTsFallback" json:"start_ts_fallback,omitempty"`
	ScanOn           ChecksumScanOn       `protobuf:"varint,2,opt,name=scan_on,json=scanOn,enum=tipb.ChecksumScanOn" json:"scan_on"`
	Algorithm        ChecksumAlgorithm    `protobuf:"varint,3,opt,name=algorithm,enum=tipb.ChecksumAlgorithm" json:"algorithm"`
	Rule             *ChecksumRewriteRule `protobuf:"bytes,4,opt,name=rule" json:"rule,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*ChecksumRequest) Descriptor

func (*ChecksumRequest) Descriptor() ([]byte, []int)

func (*ChecksumRequest) GetAlgorithm

func (m *ChecksumRequest) GetAlgorithm() ChecksumAlgorithm

func (*ChecksumRequest) GetRule

func (m *ChecksumRequest) GetRule() *ChecksumRewriteRule

func (*ChecksumRequest) GetScanOn

func (m *ChecksumRequest) GetScanOn() ChecksumScanOn

func (*ChecksumRequest) GetStartTsFallback

func (m *ChecksumRequest) GetStartTsFallback() uint64

func (*ChecksumRequest) Marshal

func (m *ChecksumRequest) Marshal() (dAtA []byte, err error)

func (*ChecksumRequest) MarshalTo

func (m *ChecksumRequest) MarshalTo(dAtA []byte) (int, error)

func (*ChecksumRequest) ProtoMessage

func (*ChecksumRequest) ProtoMessage()

func (*ChecksumRequest) Reset

func (m *ChecksumRequest) Reset()

func (*ChecksumRequest) Size

func (m *ChecksumRequest) Size() (n int)

func (*ChecksumRequest) String

func (m *ChecksumRequest) String() string

func (*ChecksumRequest) Unmarshal

func (m *ChecksumRequest) Unmarshal(dAtA []byte) error

type ChecksumResponse

type ChecksumResponse struct {
	Checksum         uint64 `protobuf:"varint,1,opt,name=checksum" json:"checksum"`
	TotalKvs         uint64 `protobuf:"varint,2,opt,name=total_kvs,json=totalKvs" json:"total_kvs"`
	TotalBytes       uint64 `protobuf:"varint,3,opt,name=total_bytes,json=totalBytes" json:"total_bytes"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ChecksumResponse) Descriptor

func (*ChecksumResponse) Descriptor() ([]byte, []int)

func (*ChecksumResponse) GetChecksum

func (m *ChecksumResponse) GetChecksum() uint64

func (*ChecksumResponse) GetTotalBytes

func (m *ChecksumResponse) GetTotalBytes() uint64

func (*ChecksumResponse) GetTotalKvs

func (m *ChecksumResponse) GetTotalKvs() uint64

func (*ChecksumResponse) Marshal

func (m *ChecksumResponse) Marshal() (dAtA []byte, err error)

func (*ChecksumResponse) MarshalTo

func (m *ChecksumResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChecksumResponse) ProtoMessage

func (*ChecksumResponse) ProtoMessage()

func (*ChecksumResponse) Reset

func (m *ChecksumResponse) Reset()

func (*ChecksumResponse) Size

func (m *ChecksumResponse) Size() (n int)

func (*ChecksumResponse) String

func (m *ChecksumResponse) String() string

func (*ChecksumResponse) Unmarshal

func (m *ChecksumResponse) Unmarshal(dAtA []byte) error

type ChecksumRewriteRule

type ChecksumRewriteRule struct {
	OldPrefix        []byte `protobuf:"bytes,1,opt,name=old_prefix,json=oldPrefix" json:"old_prefix,omitempty"`
	NewPrefix        []byte `protobuf:"bytes,2,opt,name=new_prefix,json=newPrefix" json:"new_prefix,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ChecksumRewriteRule) Descriptor

func (*ChecksumRewriteRule) Descriptor() ([]byte, []int)

func (*ChecksumRewriteRule) GetNewPrefix

func (m *ChecksumRewriteRule) GetNewPrefix() []byte

func (*ChecksumRewriteRule) GetOldPrefix

func (m *ChecksumRewriteRule) GetOldPrefix() []byte

func (*ChecksumRewriteRule) Marshal

func (m *ChecksumRewriteRule) Marshal() (dAtA []byte, err error)

func (*ChecksumRewriteRule) MarshalTo

func (m *ChecksumRewriteRule) MarshalTo(dAtA []byte) (int, error)

func (*ChecksumRewriteRule) ProtoMessage

func (*ChecksumRewriteRule) ProtoMessage()

func (*ChecksumRewriteRule) Reset

func (m *ChecksumRewriteRule) Reset()

func (*ChecksumRewriteRule) Size

func (m *ChecksumRewriteRule) Size() (n int)

func (*ChecksumRewriteRule) String

func (m *ChecksumRewriteRule) String() string

func (*ChecksumRewriteRule) Unmarshal

func (m *ChecksumRewriteRule) Unmarshal(dAtA []byte) error

type ChecksumScanOn

type ChecksumScanOn int32
const (
	ChecksumScanOn_Table ChecksumScanOn = 0
	ChecksumScanOn_Index ChecksumScanOn = 1
)

func (ChecksumScanOn) Enum

func (x ChecksumScanOn) Enum() *ChecksumScanOn

func (ChecksumScanOn) EnumDescriptor

func (ChecksumScanOn) EnumDescriptor() ([]byte, []int)

func (ChecksumScanOn) String

func (x ChecksumScanOn) String() string

func (*ChecksumScanOn) UnmarshalJSON

func (x *ChecksumScanOn) UnmarshalJSON(data []byte) error

type Chunk

type Chunk struct {
	// Data for all rows in the chunk.
	RowsData github_com_pingcap_tipb_sharedbytes.SharedBytes `` /* 127-byte string literal not displayed */
	// Meta data for every row.
	RowsMeta         []RowMeta `protobuf:"bytes,4,rep,name=rows_meta,json=rowsMeta" json:"rows_meta"`
	XXX_unrecognized []byte    `json:"-"`
}

Chunk contains multiple rows data and rows meta.

func (*Chunk) Descriptor

func (*Chunk) Descriptor() ([]byte, []int)

func (*Chunk) GetRowsMeta

func (m *Chunk) GetRowsMeta() []RowMeta

func (*Chunk) Marshal

func (m *Chunk) Marshal() (dAtA []byte, err error)

func (*Chunk) MarshalTo

func (m *Chunk) MarshalTo(dAtA []byte) (int, error)

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) Reset

func (m *Chunk) Reset()

func (*Chunk) Size

func (m *Chunk) Size() (n int)

func (*Chunk) String

func (m *Chunk) String() string

func (*Chunk) Unmarshal

func (m *Chunk) Unmarshal(dAtA []byte) error

type ChunkMemoryLayout

type ChunkMemoryLayout struct {
	// Represents the endian.
	Endian           Endian `protobuf:"varint,1,opt,name=endian,enum=tipb.Endian" json:"endian"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ChunkMemoryLayout) Descriptor

func (*ChunkMemoryLayout) Descriptor() ([]byte, []int)

func (*ChunkMemoryLayout) GetEndian

func (m *ChunkMemoryLayout) GetEndian() Endian

func (*ChunkMemoryLayout) Marshal

func (m *ChunkMemoryLayout) Marshal() (dAtA []byte, err error)

func (*ChunkMemoryLayout) MarshalTo

func (m *ChunkMemoryLayout) MarshalTo(dAtA []byte) (int, error)

func (*ChunkMemoryLayout) ProtoMessage

func (*ChunkMemoryLayout) ProtoMessage()

func (*ChunkMemoryLayout) Reset

func (m *ChunkMemoryLayout) Reset()

func (*ChunkMemoryLayout) Size

func (m *ChunkMemoryLayout) Size() (n int)

func (*ChunkMemoryLayout) String

func (m *ChunkMemoryLayout) String() string

func (*ChunkMemoryLayout) Unmarshal

func (m *ChunkMemoryLayout) Unmarshal(dAtA []byte) error

type ColumnInfo

type ColumnInfo struct {
	ColumnId         int64    `protobuf:"varint,1,opt,name=column_id,json=columnId" json:"column_id"`
	Tp               int32    `protobuf:"varint,2,opt,name=tp" json:"tp"`
	Collation        int32    `protobuf:"varint,3,opt,name=collation" json:"collation"`
	ColumnLen        int32    `protobuf:"varint,4,opt,name=columnLen" json:"columnLen"`
	Decimal          int32    `protobuf:"varint,5,opt,name=decimal" json:"decimal"`
	Flag             int32    `protobuf:"varint,6,opt,name=flag" json:"flag"`
	Elems            []string `protobuf:"bytes,7,rep,name=elems" json:"elems,omitempty"`
	DefaultVal       []byte   `protobuf:"bytes,8,opt,name=default_val,json=defaultVal" json:"default_val,omitempty"`
	PkHandle         bool     `protobuf:"varint,21,opt,name=pk_handle,json=pkHandle" json:"pk_handle"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ColumnInfo) Descriptor

func (*ColumnInfo) Descriptor() ([]byte, []int)

func (*ColumnInfo) GetCollation

func (m *ColumnInfo) GetCollation() int32

func (*ColumnInfo) GetColumnId

func (m *ColumnInfo) GetColumnId() int64

func (*ColumnInfo) GetColumnLen

func (m *ColumnInfo) GetColumnLen() int32

func (*ColumnInfo) GetDecimal

func (m *ColumnInfo) GetDecimal() int32

func (*ColumnInfo) GetDefaultVal

func (m *ColumnInfo) GetDefaultVal() []byte

func (*ColumnInfo) GetElems

func (m *ColumnInfo) GetElems() []string

func (*ColumnInfo) GetFlag

func (m *ColumnInfo) GetFlag() int32

func (*ColumnInfo) GetPkHandle

func (m *ColumnInfo) GetPkHandle() bool

func (*ColumnInfo) GetTp

func (m *ColumnInfo) GetTp() int32

func (*ColumnInfo) Marshal

func (m *ColumnInfo) Marshal() (dAtA []byte, err error)

func (*ColumnInfo) MarshalTo

func (m *ColumnInfo) MarshalTo(dAtA []byte) (int, error)

func (*ColumnInfo) ProtoMessage

func (*ColumnInfo) ProtoMessage()

func (*ColumnInfo) Reset

func (m *ColumnInfo) Reset()

func (*ColumnInfo) Size

func (m *ColumnInfo) Size() (n int)

func (*ColumnInfo) String

func (m *ColumnInfo) String() string

func (*ColumnInfo) Unmarshal

func (m *ColumnInfo) Unmarshal(dAtA []byte) error

type CompareInMetadata

type CompareInMetadata struct {
	HasNull bool `protobuf:"varint,1,req,name=has_null,json=hasNull" json:"has_null"`
	// consts represents all non-null const args in repeated Datum format.
	Consts           []byte `protobuf:"bytes,2,opt,name=consts" json:"consts,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CompareInMetadata) Descriptor

func (*CompareInMetadata) Descriptor() ([]byte, []int)

func (*CompareInMetadata) GetConsts

func (m *CompareInMetadata) GetConsts() []byte

func (*CompareInMetadata) GetHasNull

func (m *CompareInMetadata) GetHasNull() bool

func (*CompareInMetadata) Marshal

func (m *CompareInMetadata) Marshal() (dAtA []byte, err error)

func (*CompareInMetadata) MarshalTo

func (m *CompareInMetadata) MarshalTo(dAtA []byte) (int, error)

func (*CompareInMetadata) ProtoMessage

func (*CompareInMetadata) ProtoMessage()

func (*CompareInMetadata) Reset

func (m *CompareInMetadata) Reset()

func (*CompareInMetadata) Size

func (m *CompareInMetadata) Size() (n int)

func (*CompareInMetadata) String

func (m *CompareInMetadata) String() string

func (*CompareInMetadata) Unmarshal

func (m *CompareInMetadata) Unmarshal(dAtA []byte) error

type DAGRequest

type DAGRequest struct {
	// Transaction start timestamp.
	// Deprecated. Start Ts has been moved to coprocessor.Request.
	StartTsFallback *uint64 `protobuf:"varint,1,opt,name=start_ts_fallback,json=startTsFallback" json:"start_ts_fallback,omitempty"`
	// It represents push down Executors.
	Executors []*Executor `protobuf:"bytes,2,rep,name=executors" json:"executors,omitempty"`
	// time zone offset in seconds
	TimeZoneOffset int64 `protobuf:"varint,3,opt,name=time_zone_offset,json=timeZoneOffset" json:"time_zone_offset"`
	// flags are used to store flags that change the execution mode, it contains:
	// 	ignore_truncate = 1
	// 		truncate error should be ignore if set.
	// 	truncate_as_warning = 1 << 1
	// 		when ignored_truncate is not set, return warning instead of error if this flag is set.
	// 	...
	// 	add more when needed.
	Flags uint64 `protobuf:"varint,4,opt,name=flags" json:"flags"`
	// It represents which columns we should output.
	OutputOffsets []uint32 `protobuf:"varint,5,rep,name=output_offsets,json=outputOffsets" json:"output_offsets,omitempty"`
	// It represents whether we collect the detailed scan counts in each range.
	CollectRangeCounts *bool `protobuf:"varint,6,opt,name=collect_range_counts,json=collectRangeCounts" json:"collect_range_counts,omitempty"`
	// It indicates the maximum number of warning,
	// which is the number of messages that SHOW WARNINGS displays.
	MaxWarningCount *uint64 `protobuf:"varint,7,opt,name=max_warning_count,json=maxWarningCount" json:"max_warning_count,omitempty"`
	// It indicates the encode type of response.
	EncodeType EncodeType `protobuf:"varint,8,opt,name=encode_type,json=encodeType,enum=tipb.EncodeType" json:"encode_type"`
	// It indicates the sql_mode.
	SqlMode *uint64 `protobuf:"varint,9,opt,name=sql_mode,json=sqlMode" json:"sql_mode,omitempty"`
	// supply offset is not enough since we have daylight saving time present in some regions
	TimeZoneName string `protobuf:"bytes,11,opt,name=time_zone_name,json=timeZoneName" json:"time_zone_name"`
	// It represents whether or not TiKV should collect execution summaries.
	// Execution summaries will be collected into `execution_summaries` field
	// in the response.
	CollectExecutionSummaries *bool `` /* 133-byte string literal not displayed */
	// Represents the maximum size of one packet, any generated string, or any parameter sent as long data.
	MaxAllowedPacket *uint64 `protobuf:"varint,13,opt,name=max_allowed_packet,json=maxAllowedPacket" json:"max_allowed_packet,omitempty"`
	// Represents the chunk memory layout.
	ChunkMemoryLayout *ChunkMemoryLayout `protobuf:"bytes,14,opt,name=chunk_memory_layout,json=chunkMemoryLayout" json:"chunk_memory_layout,omitempty"`
	// Represents whether the expression use RPN form.
	IsRpnExpr *bool `protobuf:"varint,15,opt,name=is_rpn_expr,json=isRpnExpr" json:"is_rpn_expr,omitempty"`
	// UserIdentity uses to do privilege check. It is only used in TiDB cluster memory table.
	User *UserIdentity `protobuf:"bytes,16,opt,name=user" json:"user,omitempty"`
	// Represents tree struct based executors, if this field is set, should ignore the executors field, currently only used in TiFlash
	RootExecutor *Executor `protobuf:"bytes,17,opt,name=root_executor,json=rootExecutor" json:"root_executor,omitempty"`
	// Force using the encode type specified by encode_type, currently only used in TiFlash
	ForceEncodeType  *bool  `protobuf:"varint,18,opt,name=force_encode_type,json=forceEncodeType" json:"force_encode_type,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

DAGRequest represents the request that will be handled with DAG mode.

func (*DAGRequest) Descriptor

func (*DAGRequest) Descriptor() ([]byte, []int)

func (*DAGRequest) GetChunkMemoryLayout

func (m *DAGRequest) GetChunkMemoryLayout() *ChunkMemoryLayout

func (*DAGRequest) GetCollectExecutionSummaries

func (m *DAGRequest) GetCollectExecutionSummaries() bool

func (*DAGRequest) GetCollectRangeCounts

func (m *DAGRequest) GetCollectRangeCounts() bool

func (*DAGRequest) GetEncodeType

func (m *DAGRequest) GetEncodeType() EncodeType

func (*DAGRequest) GetExecutors

func (m *DAGRequest) GetExecutors() []*Executor

func (*DAGRequest) GetFlags

func (m *DAGRequest) GetFlags() uint64

func (*DAGRequest) GetForceEncodeType

func (m *DAGRequest) GetForceEncodeType() bool

func (*DAGRequest) GetIsRpnExpr

func (m *DAGRequest) GetIsRpnExpr() bool

func (*DAGRequest) GetMaxAllowedPacket

func (m *DAGRequest) GetMaxAllowedPacket() uint64

func (*DAGRequest) GetMaxWarningCount

func (m *DAGRequest) GetMaxWarningCount() uint64

func (*DAGRequest) GetOutputOffsets

func (m *DAGRequest) GetOutputOffsets() []uint32

func (*DAGRequest) GetRootExecutor

func (m *DAGRequest) GetRootExecutor() *Executor

func (*DAGRequest) GetSqlMode

func (m *DAGRequest) GetSqlMode() uint64

func (*DAGRequest) GetStartTsFallback

func (m *DAGRequest) GetStartTsFallback() uint64

func (*DAGRequest) GetTimeZoneName

func (m *DAGRequest) GetTimeZoneName() string

func (*DAGRequest) GetTimeZoneOffset

func (m *DAGRequest) GetTimeZoneOffset() int64

func (*DAGRequest) GetUser

func (m *DAGRequest) GetUser() *UserIdentity

func (*DAGRequest) Marshal

func (m *DAGRequest) Marshal() (dAtA []byte, err error)

func (*DAGRequest) MarshalTo

func (m *DAGRequest) MarshalTo(dAtA []byte) (int, error)

func (*DAGRequest) ProtoMessage

func (*DAGRequest) ProtoMessage()

func (*DAGRequest) Reset

func (m *DAGRequest) Reset()

func (*DAGRequest) Size

func (m *DAGRequest) Size() (n int)

func (*DAGRequest) String

func (m *DAGRequest) String() string

func (*DAGRequest) Unmarshal

func (m *DAGRequest) Unmarshal(dAtA []byte) error

type EmptyResponse

type EmptyResponse struct {
}

func (*EmptyResponse) Descriptor

func (*EmptyResponse) Descriptor() ([]byte, []int)

func (*EmptyResponse) Marshal

func (m *EmptyResponse) Marshal() (dAtA []byte, err error)

func (*EmptyResponse) MarshalTo

func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error)

func (*EmptyResponse) ProtoMessage

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size

func (m *EmptyResponse) Size() (n int)

func (*EmptyResponse) String

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal

func (m *EmptyResponse) Unmarshal(dAtA []byte) error

type EncodeType

type EncodeType int32
const (
	EncodeType_TypeDefault EncodeType = 0
	EncodeType_TypeChunk   EncodeType = 1
	// TypeCHBlock is used by TiSpark and TiFlash, in this encode mode, TiFlash will encode the data using native ch block format
	EncodeType_TypeCHBlock EncodeType = 2
)

func (EncodeType) Enum

func (x EncodeType) Enum() *EncodeType

func (EncodeType) EnumDescriptor

func (EncodeType) EnumDescriptor() ([]byte, []int)

func (EncodeType) String

func (x EncodeType) String() string

func (*EncodeType) UnmarshalJSON

func (x *EncodeType) UnmarshalJSON(data []byte) error

type Endian

type Endian int32
const (
	Endian_LittleEndian Endian = 0
	Endian_BigEndian    Endian = 1
)

func (Endian) Enum

func (x Endian) Enum() *Endian

func (Endian) EnumDescriptor

func (Endian) EnumDescriptor() ([]byte, []int)

func (Endian) String

func (x Endian) String() string

func (*Endian) UnmarshalJSON

func (x *Endian) UnmarshalJSON(data []byte) error

type EngineType

type EngineType int32
const (
	EngineType_Local   EngineType = 0
	EngineType_TiKV    EngineType = 1
	EngineType_TiFlash EngineType = 2
)

func (EngineType) Enum

func (x EngineType) Enum() *EngineType

func (EngineType) EnumDescriptor

func (EngineType) EnumDescriptor() ([]byte, []int)

func (EngineType) String

func (x EngineType) String() string

func (*EngineType) UnmarshalJSON

func (x *EngineType) UnmarshalJSON(data []byte) error

type Error

type Error struct {
	Code             int32  `protobuf:"varint,1,opt,name=code" json:"code"`
	Msg              string `protobuf:"bytes,2,opt,name=msg" json:"msg"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Error) Descriptor

func (*Error) Descriptor() ([]byte, []int)

func (*Error) GetCode

func (m *Error) GetCode() int32

func (*Error) GetMsg

func (m *Error) GetMsg() string

func (*Error) Marshal

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

func (m *Error) Size() (n int)

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

func (m *Error) Unmarshal(dAtA []byte) error

type Event

type Event int32
const (
	Event_Unknown                       Event = 0
	Event_TiKvCoprGetRequest            Event = 1000
	Event_TiKvCoprHandleRequest         Event = 1001
	Event_TiKvCoprScheduleTask          Event = 1002
	Event_TiKvCoprGetSnapshot           Event = 1003
	Event_TiKvCoprExecuteDagRunner      Event = 1004
	Event_TiKvCoprExecuteBatchDagRunner Event = 1005
)

func (Event) Enum

func (x Event) Enum() *Event

func (Event) EnumDescriptor

func (Event) EnumDescriptor() ([]byte, []int)

func (Event) String

func (x Event) String() string

func (*Event) UnmarshalJSON

func (x *Event) UnmarshalJSON(data []byte) error

type ExchangeReceiver

type ExchangeReceiver struct {
	EncodedTaskMeta  [][]byte      `protobuf:"bytes,1,rep,name=encoded_task_meta,json=encodedTaskMeta" json:"encoded_task_meta,omitempty"`
	FieldTypes       []*FieldType  `protobuf:"bytes,2,rep,name=field_types,json=fieldTypes" json:"field_types,omitempty"`
	Tp               *ExchangeType `protobuf:"varint,3,opt,name=tp,enum=tipb.ExchangeType" json:"tp,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

ExchangeReceiver accept connection and receiver data from ExchangeSender.

func (*ExchangeReceiver) Descriptor

func (*ExchangeReceiver) Descriptor() ([]byte, []int)

func (*ExchangeReceiver) GetEncodedTaskMeta

func (m *ExchangeReceiver) GetEncodedTaskMeta() [][]byte

func (*ExchangeReceiver) GetFieldTypes

func (m *ExchangeReceiver) GetFieldTypes() []*FieldType

func (*ExchangeReceiver) GetTp

func (m *ExchangeReceiver) GetTp() ExchangeType

func (*ExchangeReceiver) Marshal

func (m *ExchangeReceiver) Marshal() (dAtA []byte, err error)

func (*ExchangeReceiver) MarshalTo

func (m *ExchangeReceiver) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeReceiver) ProtoMessage

func (*ExchangeReceiver) ProtoMessage()

func (*ExchangeReceiver) Reset

func (m *ExchangeReceiver) Reset()

func (*ExchangeReceiver) Size

func (m *ExchangeReceiver) Size() (n int)

func (*ExchangeReceiver) String

func (m *ExchangeReceiver) String() string

func (*ExchangeReceiver) Unmarshal

func (m *ExchangeReceiver) Unmarshal(dAtA []byte) error

type ExchangeSender

type ExchangeSender struct {
	Tp               ExchangeType `protobuf:"varint,1,opt,name=tp,enum=tipb.ExchangeType" json:"tp"`
	EncodedTaskMeta  [][]byte     `protobuf:"bytes,2,rep,name=encoded_task_meta,json=encodedTaskMeta" json:"encoded_task_meta,omitempty"`
	PartitionKeys    []*Expr      `protobuf:"bytes,3,rep,name=partition_keys,json=partitionKeys" json:"partition_keys,omitempty"`
	Child            *Executor    `protobuf:"bytes,4,opt,name=child" json:"child,omitempty"`
	Types            []*FieldType `protobuf:"bytes,5,rep,name=types" json:"types,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

ExchangeSender will build connection with ExchangeReceiver.

func (*ExchangeSender) Descriptor

func (*ExchangeSender) Descriptor() ([]byte, []int)

func (*ExchangeSender) GetChild

func (m *ExchangeSender) GetChild() *Executor

func (*ExchangeSender) GetEncodedTaskMeta

func (m *ExchangeSender) GetEncodedTaskMeta() [][]byte

func (*ExchangeSender) GetPartitionKeys

func (m *ExchangeSender) GetPartitionKeys() []*Expr

func (*ExchangeSender) GetTp

func (m *ExchangeSender) GetTp() ExchangeType

func (*ExchangeSender) GetTypes

func (m *ExchangeSender) GetTypes() []*FieldType

func (*ExchangeSender) Marshal

func (m *ExchangeSender) Marshal() (dAtA []byte, err error)

func (*ExchangeSender) MarshalTo

func (m *ExchangeSender) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeSender) ProtoMessage

func (*ExchangeSender) ProtoMessage()

func (*ExchangeSender) Reset

func (m *ExchangeSender) Reset()

func (*ExchangeSender) Size

func (m *ExchangeSender) Size() (n int)

func (*ExchangeSender) String

func (m *ExchangeSender) String() string

func (*ExchangeSender) Unmarshal

func (m *ExchangeSender) Unmarshal(dAtA []byte) error

type ExchangeType

type ExchangeType int32
const (
	ExchangeType_PassThrough ExchangeType = 0
	ExchangeType_Broadcast   ExchangeType = 1
	ExchangeType_Hash        ExchangeType = 2
)

func (ExchangeType) Enum

func (x ExchangeType) Enum() *ExchangeType

func (ExchangeType) EnumDescriptor

func (ExchangeType) EnumDescriptor() ([]byte, []int)

func (ExchangeType) String

func (x ExchangeType) String() string

func (*ExchangeType) UnmarshalJSON

func (x *ExchangeType) UnmarshalJSON(data []byte) error

type ExecType

type ExecType int32
const (
	ExecType_TypeTableScan        ExecType = 0
	ExecType_TypeIndexScan        ExecType = 1
	ExecType_TypeSelection        ExecType = 2
	ExecType_TypeAggregation      ExecType = 3
	ExecType_TypeTopN             ExecType = 4
	ExecType_TypeLimit            ExecType = 5
	ExecType_TypeStreamAgg        ExecType = 6
	ExecType_TypeJoin             ExecType = 7
	ExecType_TypeKill             ExecType = 8
	ExecType_TypeExchangeSender   ExecType = 9
	ExecType_TypeExchangeReceiver ExecType = 10
	ExecType_TypeProjection       ExecType = 11
)

func (ExecType) Enum

func (x ExecType) Enum() *ExecType

func (ExecType) EnumDescriptor

func (ExecType) EnumDescriptor() ([]byte, []int)

func (ExecType) String

func (x ExecType) String() string

func (*ExecType) UnmarshalJSON

func (x *ExecType) UnmarshalJSON(data []byte) error

type Executor

type Executor struct {
	Tp               ExecType          `protobuf:"varint,1,opt,name=tp,enum=tipb.ExecType" json:"tp"`
	TblScan          *TableScan        `protobuf:"bytes,2,opt,name=tbl_scan,json=tblScan" json:"tbl_scan,omitempty"`
	IdxScan          *IndexScan        `protobuf:"bytes,3,opt,name=idx_scan,json=idxScan" json:"idx_scan,omitempty"`
	Selection        *Selection        `protobuf:"bytes,4,opt,name=selection" json:"selection,omitempty"`
	Aggregation      *Aggregation      `protobuf:"bytes,5,opt,name=aggregation" json:"aggregation,omitempty"`
	TopN             *TopN             `protobuf:"bytes,6,opt,name=topN" json:"topN,omitempty"`
	Limit            *Limit            `protobuf:"bytes,7,opt,name=limit" json:"limit,omitempty"`
	ExchangeReceiver *ExchangeReceiver `protobuf:"bytes,8,opt,name=exchange_receiver,json=exchangeReceiver" json:"exchange_receiver,omitempty"`
	Join             *Join             `protobuf:"bytes,9,opt,name=join" json:"join,omitempty"`
	ExecutorId       *string           `protobuf:"bytes,10,opt,name=executor_id,json=executorId" json:"executor_id,omitempty"`
	Kill             *Kill             `protobuf:"bytes,11,opt,name=kill" json:"kill,omitempty"`
	ExchangeSender   *ExchangeSender   `protobuf:"bytes,12,opt,name=exchange_sender,json=exchangeSender" json:"exchange_sender,omitempty"`
	Projection       *Projection       `protobuf:"bytes,13,opt,name=Projection" json:"Projection,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

It represents a Executor.

func (*Executor) Descriptor

func (*Executor) Descriptor() ([]byte, []int)

func (*Executor) GetAggregation

func (m *Executor) GetAggregation() *Aggregation

func (*Executor) GetExchangeReceiver

func (m *Executor) GetExchangeReceiver() *ExchangeReceiver

func (*Executor) GetExchangeSender

func (m *Executor) GetExchangeSender() *ExchangeSender

func (*Executor) GetExecutorId

func (m *Executor) GetExecutorId() string

func (*Executor) GetIdxScan

func (m *Executor) GetIdxScan() *IndexScan

func (*Executor) GetJoin

func (m *Executor) GetJoin() *Join

func (*Executor) GetKill

func (m *Executor) GetKill() *Kill

func (*Executor) GetLimit

func (m *Executor) GetLimit() *Limit

func (*Executor) GetProjection

func (m *Executor) GetProjection() *Projection

func (*Executor) GetSelection

func (m *Executor) GetSelection() *Selection

func (*Executor) GetTblScan

func (m *Executor) GetTblScan() *TableScan

func (*Executor) GetTopN

func (m *Executor) GetTopN() *TopN

func (*Executor) GetTp

func (m *Executor) GetTp() ExecType

func (*Executor) Marshal

func (m *Executor) Marshal() (dAtA []byte, err error)

func (*Executor) MarshalTo

func (m *Executor) MarshalTo(dAtA []byte) (int, error)

func (*Executor) ProtoMessage

func (*Executor) ProtoMessage()

func (*Executor) Reset

func (m *Executor) Reset()

func (*Executor) Size

func (m *Executor) Size() (n int)

func (*Executor) String

func (m *Executor) String() string

func (*Executor) Unmarshal

func (m *Executor) Unmarshal(dAtA []byte) error

type ExecutorExecutionSummary

type ExecutorExecutionSummary struct {
	// Total time cost in this executor. Includes self time cost and children time cost.
	TimeProcessedNs *uint64 `protobuf:"varint,1,opt,name=time_processed_ns,json=timeProcessedNs" json:"time_processed_ns,omitempty"`
	// How many rows this executor produced totally.
	NumProducedRows *uint64 `protobuf:"varint,2,opt,name=num_produced_rows,json=numProducedRows" json:"num_produced_rows,omitempty"`
	// How many times executor's `next()` is called.
	NumIterations *uint64 `protobuf:"varint,3,opt,name=num_iterations,json=numIterations" json:"num_iterations,omitempty"`
	// Coresponding executor id
	ExecutorId *string `protobuf:"bytes,4,opt,name=executor_id,json=executorId" json:"executor_id,omitempty"`
	// The execution concurrency for this executor
	Concurrency      *uint64 `protobuf:"varint,5,opt,name=concurrency" json:"concurrency,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ExecutorExecutionSummary) Descriptor

func (*ExecutorExecutionSummary) Descriptor() ([]byte, []int)

func (*ExecutorExecutionSummary) GetConcurrency

func (m *ExecutorExecutionSummary) GetConcurrency() uint64

func (*ExecutorExecutionSummary) GetExecutorId

func (m *ExecutorExecutionSummary) GetExecutorId() string

func (*ExecutorExecutionSummary) GetNumIterations

func (m *ExecutorExecutionSummary) GetNumIterations() uint64

func (*ExecutorExecutionSummary) GetNumProducedRows

func (m *ExecutorExecutionSummary) GetNumProducedRows() uint64

func (*ExecutorExecutionSummary) GetTimeProcessedNs

func (m *ExecutorExecutionSummary) GetTimeProcessedNs() uint64

func (*ExecutorExecutionSummary) Marshal

func (m *ExecutorExecutionSummary) Marshal() (dAtA []byte, err error)

func (*ExecutorExecutionSummary) MarshalTo

func (m *ExecutorExecutionSummary) MarshalTo(dAtA []byte) (int, error)

func (*ExecutorExecutionSummary) ProtoMessage

func (*ExecutorExecutionSummary) ProtoMessage()

func (*ExecutorExecutionSummary) Reset

func (m *ExecutorExecutionSummary) Reset()

func (*ExecutorExecutionSummary) Size

func (m *ExecutorExecutionSummary) Size() (n int)

func (*ExecutorExecutionSummary) String

func (m *ExecutorExecutionSummary) String() string

func (*ExecutorExecutionSummary) Unmarshal

func (m *ExecutorExecutionSummary) Unmarshal(dAtA []byte) error

type Expr

type Expr struct {
	Tp               ExprType      `protobuf:"varint,1,opt,name=tp,enum=tipb.ExprType" json:"tp"`
	Val              []byte        `protobuf:"bytes,2,opt,name=val" json:"val,omitempty"`
	Children         []*Expr       `protobuf:"bytes,3,rep,name=children" json:"children,omitempty"`
	RpnArgsLen       *uint32       `protobuf:"varint,6,opt,name=rpn_args_len,json=rpnArgsLen" json:"rpn_args_len,omitempty"`
	Sig              ScalarFuncSig `protobuf:"varint,4,opt,name=sig,enum=tipb.ScalarFuncSig" json:"sig"`
	FieldType        *FieldType    `protobuf:"bytes,5,opt,name=field_type,json=fieldType" json:"field_type,omitempty"`
	HasDistinct      bool          `protobuf:"varint,7,opt,name=has_distinct,json=hasDistinct" json:"has_distinct"`
	OrderBy          []*ByItem     `protobuf:"bytes,8,rep,name=order_by,json=orderBy" json:"order_by,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

Evaluators should implement evaluation functions for every expression type.

func (*Expr) Descriptor

func (*Expr) Descriptor() ([]byte, []int)

func (*Expr) GetChildren

func (m *Expr) GetChildren() []*Expr

func (*Expr) GetFieldType

func (m *Expr) GetFieldType() *FieldType

func (*Expr) GetHasDistinct

func (m *Expr) GetHasDistinct() bool

func (*Expr) GetOrderBy

func (m *Expr) GetOrderBy() []*ByItem

func (*Expr) GetRpnArgsLen

func (m *Expr) GetRpnArgsLen() uint32

func (*Expr) GetSig

func (m *Expr) GetSig() ScalarFuncSig

func (*Expr) GetTp

func (m *Expr) GetTp() ExprType

func (*Expr) GetVal

func (m *Expr) GetVal() []byte

func (*Expr) Marshal

func (m *Expr) Marshal() (dAtA []byte, err error)

func (*Expr) MarshalTo

func (m *Expr) MarshalTo(dAtA []byte) (int, error)

func (*Expr) ProtoMessage

func (*Expr) ProtoMessage()

func (*Expr) Reset

func (m *Expr) Reset()

func (*Expr) Size

func (m *Expr) Size() (n int)

func (*Expr) String

func (m *Expr) String() string

func (*Expr) Unmarshal

func (m *Expr) Unmarshal(dAtA []byte) error

type ExprType

type ExprType int32
const (
	// Values are encoded bytes.
	ExprType_Null    ExprType = 0
	ExprType_Int64   ExprType = 1
	ExprType_Uint64  ExprType = 2
	ExprType_Float32 ExprType = 3
	ExprType_Float64 ExprType = 4
	ExprType_String  ExprType = 5
	ExprType_Bytes   ExprType = 6
	// Mysql specific types.
	ExprType_MysqlBit      ExprType = 101
	ExprType_MysqlDecimal  ExprType = 102
	ExprType_MysqlDuration ExprType = 103
	ExprType_MysqlEnum     ExprType = 104
	ExprType_MysqlHex      ExprType = 105
	ExprType_MysqlSet      ExprType = 106
	ExprType_MysqlTime     ExprType = 107
	ExprType_MysqlJson     ExprType = 108
	// Encoded value list.
	ExprType_ValueList ExprType = 151
	// Column reference. value is int64 column ID.
	ExprType_ColumnRef ExprType = 201
	// Aggregate functions.
	ExprType_Count               ExprType = 3001
	ExprType_Sum                 ExprType = 3002
	ExprType_Avg                 ExprType = 3003
	ExprType_Min                 ExprType = 3004
	ExprType_Max                 ExprType = 3005
	ExprType_First               ExprType = 3006
	ExprType_GroupConcat         ExprType = 3007
	ExprType_Agg_BitAnd          ExprType = 3008
	ExprType_Agg_BitOr           ExprType = 3009
	ExprType_Agg_BitXor          ExprType = 3010
	ExprType_Std                 ExprType = 3011
	ExprType_Stddev              ExprType = 3012
	ExprType_StddevPop           ExprType = 3013
	ExprType_StddevSamp          ExprType = 3014
	ExprType_VarPop              ExprType = 3015
	ExprType_VarSamp             ExprType = 3016
	ExprType_Variance            ExprType = 3017
	ExprType_JsonArrayAgg        ExprType = 3018
	ExprType_JsonObjectAgg       ExprType = 3019
	ExprType_ApproxCountDistinct ExprType = 3020
	// Scalar Function
	ExprType_ScalarFunc ExprType = 10000
)

func (ExprType) Enum

func (x ExprType) Enum() *ExprType

func (ExprType) EnumDescriptor

func (ExprType) EnumDescriptor() ([]byte, []int)

func (ExprType) String

func (x ExprType) String() string

func (*ExprType) UnmarshalJSON

func (x *ExprType) UnmarshalJSON(data []byte) error

type FMSketch

type FMSketch struct {
	Mask             uint64   `protobuf:"varint,1,opt,name=mask" json:"mask"`
	Hashset          []uint64 `protobuf:"varint,2,rep,name=hashset" json:"hashset,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

FMSketch is used to count distinct values for columns.

func (*FMSketch) Descriptor

func (*FMSketch) Descriptor() ([]byte, []int)

func (*FMSketch) GetHashset

func (m *FMSketch) GetHashset() []uint64

func (*FMSketch) GetMask

func (m *FMSketch) GetMask() uint64

func (*FMSketch) Marshal

func (m *FMSketch) Marshal() (dAtA []byte, err error)

func (*FMSketch) MarshalTo

func (m *FMSketch) MarshalTo(dAtA []byte) (int, error)

func (*FMSketch) ProtoMessage

func (*FMSketch) ProtoMessage()

func (*FMSketch) Reset

func (m *FMSketch) Reset()

func (*FMSketch) Size

func (m *FMSketch) Size() (n int)

func (*FMSketch) String

func (m *FMSketch) String() string

func (*FMSketch) Unmarshal

func (m *FMSketch) Unmarshal(dAtA []byte) error

type FieldType

type FieldType struct {
	Tp               int32    `protobuf:"varint,1,opt,name=tp" json:"tp"`
	Flag             uint32   `protobuf:"varint,2,opt,name=flag" json:"flag"`
	Flen             int32    `protobuf:"varint,3,opt,name=flen" json:"flen"`
	Decimal          int32    `protobuf:"varint,4,opt,name=decimal" json:"decimal"`
	Collate          int32    `protobuf:"varint,5,opt,name=collate" json:"collate"`
	Charset          string   `protobuf:"bytes,6,opt,name=charset" json:"charset"`
	Elems            []string `protobuf:"bytes,7,rep,name=elems" json:"elems,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*FieldType) Descriptor

func (*FieldType) Descriptor() ([]byte, []int)

func (*FieldType) GetCharset

func (m *FieldType) GetCharset() string

func (*FieldType) GetCollate

func (m *FieldType) GetCollate() int32

func (*FieldType) GetDecimal

func (m *FieldType) GetDecimal() int32

func (*FieldType) GetElems

func (m *FieldType) GetElems() []string

func (*FieldType) GetFlag

func (m *FieldType) GetFlag() uint32

func (*FieldType) GetFlen

func (m *FieldType) GetFlen() int32

func (*FieldType) GetTp

func (m *FieldType) GetTp() int32

func (*FieldType) Marshal

func (m *FieldType) Marshal() (dAtA []byte, err error)

func (*FieldType) MarshalTo

func (m *FieldType) MarshalTo(dAtA []byte) (int, error)

func (*FieldType) ProtoMessage

func (*FieldType) ProtoMessage()

func (*FieldType) Reset

func (m *FieldType) Reset()

func (*FieldType) Size

func (m *FieldType) Size() (n int)

func (*FieldType) String

func (m *FieldType) String() string

func (*FieldType) Unmarshal

func (m *FieldType) Unmarshal(dAtA []byte) error

type Histogram

type Histogram struct {
	// ndv is the number of distinct values.
	Ndv int64 `protobuf:"varint,1,opt,name=ndv" json:"ndv"`
	// buckets represents all the buckets.
	Buckets          []*Bucket `protobuf:"bytes,2,rep,name=buckets" json:"buckets,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*Histogram) Descriptor

func (*Histogram) Descriptor() ([]byte, []int)

func (*Histogram) GetBuckets

func (m *Histogram) GetBuckets() []*Bucket

func (*Histogram) GetNdv

func (m *Histogram) GetNdv() int64

func (*Histogram) Marshal

func (m *Histogram) Marshal() (dAtA []byte, err error)

func (*Histogram) MarshalTo

func (m *Histogram) MarshalTo(dAtA []byte) (int, error)

func (*Histogram) ProtoMessage

func (*Histogram) ProtoMessage()

func (*Histogram) Reset

func (m *Histogram) Reset()

func (*Histogram) Size

func (m *Histogram) Size() (n int)

func (*Histogram) String

func (m *Histogram) String() string

func (*Histogram) Unmarshal

func (m *Histogram) Unmarshal(dAtA []byte) error

type InUnionMetadata

type InUnionMetadata struct {
	InUnion          bool   `protobuf:"varint,1,req,name=in_union,json=inUnion" json:"in_union"`
	XXX_unrecognized []byte `json:"-"`
}

func (*InUnionMetadata) Descriptor

func (*InUnionMetadata) Descriptor() ([]byte, []int)

func (*InUnionMetadata) GetInUnion

func (m *InUnionMetadata) GetInUnion() bool

func (*InUnionMetadata) Marshal

func (m *InUnionMetadata) Marshal() (dAtA []byte, err error)

func (*InUnionMetadata) MarshalTo

func (m *InUnionMetadata) MarshalTo(dAtA []byte) (int, error)

func (*InUnionMetadata) ProtoMessage

func (*InUnionMetadata) ProtoMessage()

func (*InUnionMetadata) Reset

func (m *InUnionMetadata) Reset()

func (*InUnionMetadata) Size

func (m *InUnionMetadata) Size() (n int)

func (*InUnionMetadata) String

func (m *InUnionMetadata) String() string

func (*InUnionMetadata) Unmarshal

func (m *InUnionMetadata) Unmarshal(dAtA []byte) error

type IndexInfo

type IndexInfo struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	IndexId          int64         `protobuf:"varint,2,opt,name=index_id,json=indexId" json:"index_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,3,rep,name=columns" json:"columns,omitempty"`
	Unique           bool          `protobuf:"varint,4,opt,name=unique" json:"unique"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*IndexInfo) Descriptor

func (*IndexInfo) Descriptor() ([]byte, []int)

func (*IndexInfo) GetColumns

func (m *IndexInfo) GetColumns() []*ColumnInfo

func (*IndexInfo) GetIndexId

func (m *IndexInfo) GetIndexId() int64

func (*IndexInfo) GetTableId

func (m *IndexInfo) GetTableId() int64

func (*IndexInfo) GetUnique

func (m *IndexInfo) GetUnique() bool

func (*IndexInfo) Marshal

func (m *IndexInfo) Marshal() (dAtA []byte, err error)

func (*IndexInfo) MarshalTo

func (m *IndexInfo) MarshalTo(dAtA []byte) (int, error)

func (*IndexInfo) ProtoMessage

func (*IndexInfo) ProtoMessage()

func (*IndexInfo) Reset

func (m *IndexInfo) Reset()

func (*IndexInfo) Size

func (m *IndexInfo) Size() (n int)

func (*IndexInfo) String

func (m *IndexInfo) String() string

func (*IndexInfo) Unmarshal

func (m *IndexInfo) Unmarshal(dAtA []byte) error

type IndexScan

type IndexScan struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	IndexId          int64         `protobuf:"varint,2,opt,name=index_id,json=indexId" json:"index_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,3,rep,name=columns" json:"columns,omitempty"`
	Desc             bool          `protobuf:"varint,4,opt,name=desc" json:"desc"`
	Unique           *bool         `protobuf:"varint,5,opt,name=unique" json:"unique,omitempty"`
	PrimaryColumnIds []int64       `protobuf:"varint,6,rep,name=primary_column_ids,json=primaryColumnIds" json:"primary_column_ids,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*IndexScan) Descriptor

func (*IndexScan) Descriptor() ([]byte, []int)

func (*IndexScan) GetColumns

func (m *IndexScan) GetColumns() []*ColumnInfo

func (*IndexScan) GetDesc

func (m *IndexScan) GetDesc() bool

func (*IndexScan) GetIndexId

func (m *IndexScan) GetIndexId() int64

func (*IndexScan) GetPrimaryColumnIds

func (m *IndexScan) GetPrimaryColumnIds() []int64

func (*IndexScan) GetTableId

func (m *IndexScan) GetTableId() int64

func (*IndexScan) GetUnique

func (m *IndexScan) GetUnique() bool

func (*IndexScan) Marshal

func (m *IndexScan) Marshal() (dAtA []byte, err error)

func (*IndexScan) MarshalTo

func (m *IndexScan) MarshalTo(dAtA []byte) (int, error)

func (*IndexScan) ProtoMessage

func (*IndexScan) ProtoMessage()

func (*IndexScan) Reset

func (m *IndexScan) Reset()

func (*IndexScan) Size

func (m *IndexScan) Size() (n int)

func (*IndexScan) String

func (m *IndexScan) String() string

func (*IndexScan) Unmarshal

func (m *IndexScan) Unmarshal(dAtA []byte) error

type Join

type Join struct {
	JoinType      JoinType     `protobuf:"varint,1,opt,name=join_type,json=joinType,enum=tipb.JoinType" json:"join_type"`
	JoinExecType  JoinExecType `protobuf:"varint,2,opt,name=join_exec_type,json=joinExecType,enum=tipb.JoinExecType" json:"join_exec_type"`
	Children      []*Executor  `protobuf:"bytes,3,rep,name=children" json:"children,omitempty"`
	InnerIdx      int64        `protobuf:"varint,4,opt,name=inner_idx,json=innerIdx" json:"inner_idx"`
	LeftJoinKeys  []*Expr      `protobuf:"bytes,5,rep,name=left_join_keys,json=leftJoinKeys" json:"left_join_keys,omitempty"`
	RightJoinKeys []*Expr      `protobuf:"bytes,6,rep,name=right_join_keys,json=rightJoinKeys" json:"right_join_keys,omitempty"`
	// used by TiFlash join when new collation is enabled.
	ProbeTypes              []*FieldType `protobuf:"bytes,7,rep,name=probe_types,json=probeTypes" json:"probe_types,omitempty"`
	BuildTypes              []*FieldType `protobuf:"bytes,8,rep,name=build_types,json=buildTypes" json:"build_types,omitempty"`
	LeftConditions          []*Expr      `protobuf:"bytes,9,rep,name=left_conditions,json=leftConditions" json:"left_conditions,omitempty"`
	RightConditions         []*Expr      `protobuf:"bytes,10,rep,name=right_conditions,json=rightConditions" json:"right_conditions,omitempty"`
	OtherConditions         []*Expr      `protobuf:"bytes,11,rep,name=other_conditions,json=otherConditions" json:"other_conditions,omitempty"`
	OtherEqConditionsFromIn []*Expr      `` /* 130-byte string literal not displayed */
	XXX_unrecognized        []byte       `json:"-"`
}

func (*Join) Descriptor

func (*Join) Descriptor() ([]byte, []int)

func (*Join) GetBuildTypes

func (m *Join) GetBuildTypes() []*FieldType

func (*Join) GetChildren

func (m *Join) GetChildren() []*Executor

func (*Join) GetInnerIdx

func (m *Join) GetInnerIdx() int64

func (*Join) GetJoinExecType

func (m *Join) GetJoinExecType() JoinExecType

func (*Join) GetJoinType

func (m *Join) GetJoinType() JoinType

func (*Join) GetLeftConditions

func (m *Join) GetLeftConditions() []*Expr

func (*Join) GetLeftJoinKeys

func (m *Join) GetLeftJoinKeys() []*Expr

func (*Join) GetOtherConditions

func (m *Join) GetOtherConditions() []*Expr

func (*Join) GetOtherEqConditionsFromIn

func (m *Join) GetOtherEqConditionsFromIn() []*Expr

func (*Join) GetProbeTypes

func (m *Join) GetProbeTypes() []*FieldType

func (*Join) GetRightConditions

func (m *Join) GetRightConditions() []*Expr

func (*Join) GetRightJoinKeys

func (m *Join) GetRightJoinKeys() []*Expr

func (*Join) Marshal

func (m *Join) Marshal() (dAtA []byte, err error)

func (*Join) MarshalTo

func (m *Join) MarshalTo(dAtA []byte) (int, error)

func (*Join) ProtoMessage

func (*Join) ProtoMessage()

func (*Join) Reset

func (m *Join) Reset()

func (*Join) Size

func (m *Join) Size() (n int)

func (*Join) String

func (m *Join) String() string

func (*Join) Unmarshal

func (m *Join) Unmarshal(dAtA []byte) error

type JoinExecType

type JoinExecType int32
const (
	JoinExecType_TypeHashJoin JoinExecType = 0
)

func (JoinExecType) Enum

func (x JoinExecType) Enum() *JoinExecType

func (JoinExecType) EnumDescriptor

func (JoinExecType) EnumDescriptor() ([]byte, []int)

func (JoinExecType) String

func (x JoinExecType) String() string

func (*JoinExecType) UnmarshalJSON

func (x *JoinExecType) UnmarshalJSON(data []byte) error

type JoinType

type JoinType int32
const (
	JoinType_TypeInnerJoin             JoinType = 0
	JoinType_TypeLeftOuterJoin         JoinType = 1
	JoinType_TypeRightOuterJoin        JoinType = 2
	JoinType_TypeSemiJoin              JoinType = 3
	JoinType_TypeAntiSemiJoin          JoinType = 4
	JoinType_TypeLeftOuterSemiJoin     JoinType = 5
	JoinType_TypeAntiLeftOuterSemiJoin JoinType = 6
)

func (JoinType) Enum

func (x JoinType) Enum() *JoinType

func (JoinType) EnumDescriptor

func (JoinType) EnumDescriptor() ([]byte, []int)

func (JoinType) String

func (x JoinType) String() string

func (*JoinType) UnmarshalJSON

func (x *JoinType) UnmarshalJSON(data []byte) error

type KeyRange

type KeyRange struct {
	Low              []byte `protobuf:"bytes,1,opt,name=low" json:"low,omitempty"`
	High             []byte `protobuf:"bytes,2,opt,name=high" json:"high,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

KeyRange is the encoded index key range, low is closed, high is open. (low <= x < high)

func (*KeyRange) Descriptor

func (*KeyRange) Descriptor() ([]byte, []int)

func (*KeyRange) GetHigh

func (m *KeyRange) GetHigh() []byte

func (*KeyRange) GetLow

func (m *KeyRange) GetLow() []byte

func (*KeyRange) Marshal

func (m *KeyRange) Marshal() (dAtA []byte, err error)

func (*KeyRange) MarshalTo

func (m *KeyRange) MarshalTo(dAtA []byte) (int, error)

func (*KeyRange) ProtoMessage

func (*KeyRange) ProtoMessage()

func (*KeyRange) Reset

func (m *KeyRange) Reset()

func (*KeyRange) Size

func (m *KeyRange) Size() (n int)

func (*KeyRange) String

func (m *KeyRange) String() string

func (*KeyRange) Unmarshal

func (m *KeyRange) Unmarshal(dAtA []byte) error

type Kill

type Kill struct {
	ConnID uint64 `protobuf:"varint,1,opt,name=connID" json:"connID"`
	// Query indicates whether terminate a single query on this connection or the whole connection.
	//   If Query is true, terminates the statement the connection is currently executing, but leaves the connection itself intact.
	//   If Query is false, terminates the connection associated with the given ConnectionID, after terminating any statement the connection is executing.
	//   See https://dev.mysql.com/doc/refman/8.0/en/kill.html.
	Query            bool   `protobuf:"varint,2,opt,name=query" json:"query"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Kill) Descriptor

func (*Kill) Descriptor() ([]byte, []int)

func (*Kill) GetConnID

func (m *Kill) GetConnID() uint64

func (*Kill) GetQuery

func (m *Kill) GetQuery() bool

func (*Kill) Marshal

func (m *Kill) Marshal() (dAtA []byte, err error)

func (*Kill) MarshalTo

func (m *Kill) MarshalTo(dAtA []byte) (int, error)

func (*Kill) ProtoMessage

func (*Kill) ProtoMessage()

func (*Kill) Reset

func (m *Kill) Reset()

func (*Kill) Size

func (m *Kill) Size() (n int)

func (*Kill) String

func (m *Kill) String() string

func (*Kill) Unmarshal

func (m *Kill) Unmarshal(dAtA []byte) error

type Limit

type Limit struct {
	// Limit the result to be returned.
	Limit            uint64    `protobuf:"varint,1,opt,name=limit" json:"limit"`
	Child            *Executor `protobuf:"bytes,2,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*Limit) Descriptor

func (*Limit) Descriptor() ([]byte, []int)

func (*Limit) GetChild

func (m *Limit) GetChild() *Executor

func (*Limit) GetLimit

func (m *Limit) GetLimit() uint64

func (*Limit) Marshal

func (m *Limit) Marshal() (dAtA []byte, err error)

func (*Limit) MarshalTo

func (m *Limit) MarshalTo(dAtA []byte) (int, error)

func (*Limit) ProtoMessage

func (*Limit) ProtoMessage()

func (*Limit) Reset

func (m *Limit) Reset()

func (*Limit) Size

func (m *Limit) Size() (n int)

func (*Limit) String

func (m *Limit) String() string

func (*Limit) Unmarshal

func (m *Limit) Unmarshal(dAtA []byte) error

type PlanMeta

type PlanMeta struct {
	PlanDigest     []byte `protobuf:"bytes,1,opt,name=plan_digest,json=planDigest,proto3" json:"plan_digest,omitempty"`
	NormalizedPlan string `protobuf:"bytes,2,opt,name=normalized_plan,json=normalizedPlan,proto3" json:"normalized_plan,omitempty"`
}

func (*PlanMeta) Descriptor

func (*PlanMeta) Descriptor() ([]byte, []int)

func (*PlanMeta) GetNormalizedPlan

func (m *PlanMeta) GetNormalizedPlan() string

func (*PlanMeta) GetPlanDigest

func (m *PlanMeta) GetPlanDigest() []byte

func (*PlanMeta) Marshal

func (m *PlanMeta) Marshal() (dAtA []byte, err error)

func (*PlanMeta) MarshalTo

func (m *PlanMeta) MarshalTo(dAtA []byte) (int, error)

func (*PlanMeta) ProtoMessage

func (*PlanMeta) ProtoMessage()

func (*PlanMeta) Reset

func (m *PlanMeta) Reset()

func (*PlanMeta) Size

func (m *PlanMeta) Size() (n int)

func (*PlanMeta) String

func (m *PlanMeta) String() string

func (*PlanMeta) Unmarshal

func (m *PlanMeta) Unmarshal(dAtA []byte) error

type Projection

type Projection struct {
	// Projection expressions.
	Exprs            []*Expr    `protobuf:"bytes,1,rep,name=exprs" json:"exprs,omitempty"`
	RpnExprs         []*RpnExpr `protobuf:"bytes,2,rep,name=rpn_exprs,json=rpnExprs" json:"rpn_exprs,omitempty"`
	Child            *Executor  `protobuf:"bytes,3,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*Projection) Descriptor

func (*Projection) Descriptor() ([]byte, []int)

func (*Projection) GetChild

func (m *Projection) GetChild() *Executor

func (*Projection) GetExprs

func (m *Projection) GetExprs() []*Expr

func (*Projection) GetRpnExprs

func (m *Projection) GetRpnExprs() []*RpnExpr

func (*Projection) Marshal

func (m *Projection) Marshal() (dAtA []byte, err error)

func (*Projection) MarshalTo

func (m *Projection) MarshalTo(dAtA []byte) (int, error)

func (*Projection) ProtoMessage

func (*Projection) ProtoMessage()

func (*Projection) Reset

func (m *Projection) Reset()

func (*Projection) Size

func (m *Projection) Size() (n int)

func (*Projection) String

func (m *Projection) String() string

func (*Projection) Unmarshal

func (m *Projection) Unmarshal(dAtA []byte) error

type ResourceGroupTag

type ResourceGroupTag struct {
	SqlDigest        []byte `protobuf:"bytes,1,opt,name=sql_digest,json=sqlDigest" json:"sql_digest,omitempty"`
	PlanDigest       []byte `protobuf:"bytes,2,opt,name=plan_digest,json=planDigest" json:"plan_digest,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ResourceGroupTag) Descriptor

func (*ResourceGroupTag) Descriptor() ([]byte, []int)

func (*ResourceGroupTag) GetPlanDigest

func (m *ResourceGroupTag) GetPlanDigest() []byte

func (*ResourceGroupTag) GetSqlDigest

func (m *ResourceGroupTag) GetSqlDigest() []byte

func (*ResourceGroupTag) Marshal

func (m *ResourceGroupTag) Marshal() (dAtA []byte, err error)

func (*ResourceGroupTag) MarshalTo

func (m *ResourceGroupTag) MarshalTo(dAtA []byte) (int, error)

func (*ResourceGroupTag) ProtoMessage

func (*ResourceGroupTag) ProtoMessage()

func (*ResourceGroupTag) Reset

func (m *ResourceGroupTag) Reset()

func (*ResourceGroupTag) Size

func (m *ResourceGroupTag) Size() (n int)

func (*ResourceGroupTag) String

func (m *ResourceGroupTag) String() string

func (*ResourceGroupTag) Unmarshal

func (m *ResourceGroupTag) Unmarshal(dAtA []byte) error

type Row

type Row struct {
	Handle           []byte `protobuf:"bytes,1,opt,name=handle" json:"handle,omitempty"`
	Data             []byte `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

values are all in text format.

func (*Row) Descriptor

func (*Row) Descriptor() ([]byte, []int)

func (*Row) GetData

func (m *Row) GetData() []byte

func (*Row) GetHandle

func (m *Row) GetHandle() []byte

func (*Row) Marshal

func (m *Row) Marshal() (dAtA []byte, err error)

func (*Row) MarshalTo

func (m *Row) MarshalTo(dAtA []byte) (int, error)

func (*Row) ProtoMessage

func (*Row) ProtoMessage()

func (*Row) Reset

func (m *Row) Reset()

func (*Row) Size

func (m *Row) Size() (n int)

func (*Row) String

func (m *Row) String() string

func (*Row) Unmarshal

func (m *Row) Unmarshal(dAtA []byte) error

type RowMeta

type RowMeta struct {
	Handle           int64  `protobuf:"varint,1,opt,name=handle" json:"handle"`
	Length           int64  `protobuf:"varint,2,opt,name=length" json:"length"`
	XXX_unrecognized []byte `json:"-"`
}

RowMeta contains row handle and length of a row.

func (*RowMeta) Descriptor

func (*RowMeta) Descriptor() ([]byte, []int)

func (*RowMeta) GetHandle

func (m *RowMeta) GetHandle() int64

func (*RowMeta) GetLength

func (m *RowMeta) GetLength() int64

func (*RowMeta) Marshal

func (m *RowMeta) Marshal() (dAtA []byte, err error)

func (*RowMeta) MarshalTo

func (m *RowMeta) MarshalTo(dAtA []byte) (int, error)

func (*RowMeta) ProtoMessage

func (*RowMeta) ProtoMessage()

func (*RowMeta) Reset

func (m *RowMeta) Reset()

func (*RowMeta) Size

func (m *RowMeta) Size() (n int)

func (*RowMeta) String

func (m *RowMeta) String() string

func (*RowMeta) Unmarshal

func (m *RowMeta) Unmarshal(dAtA []byte) error

type RowSample

type RowSample struct {
	Row              [][]byte `protobuf:"bytes,1,rep,name=row" json:"row,omitempty"`
	Weight           int64    `protobuf:"varint,2,opt,name=weight" json:"weight"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*RowSample) Descriptor

func (*RowSample) Descriptor() ([]byte, []int)

func (*RowSample) GetRow

func (m *RowSample) GetRow() [][]byte

func (*RowSample) GetWeight

func (m *RowSample) GetWeight() int64

func (*RowSample) Marshal

func (m *RowSample) Marshal() (dAtA []byte, err error)

func (*RowSample) MarshalTo

func (m *RowSample) MarshalTo(dAtA []byte) (int, error)

func (*RowSample) ProtoMessage

func (*RowSample) ProtoMessage()

func (*RowSample) Reset

func (m *RowSample) Reset()

func (*RowSample) Size

func (m *RowSample) Size() (n int)

func (*RowSample) String

func (m *RowSample) String() string

func (*RowSample) Unmarshal

func (m *RowSample) Unmarshal(dAtA []byte) error

type RowSampleCollector

type RowSampleCollector struct {
	Samples          []*RowSample `protobuf:"bytes,1,rep,name=samples" json:"samples,omitempty"`
	NullCounts       []int64      `protobuf:"varint,2,rep,name=null_counts,json=nullCounts" json:"null_counts,omitempty"`
	Count            int64        `protobuf:"varint,3,opt,name=count" json:"count"`
	FmSketch         []*FMSketch  `protobuf:"bytes,4,rep,name=fm_sketch,json=fmSketch" json:"fm_sketch,omitempty"`
	TotalSize        []int64      `protobuf:"varint,5,rep,name=total_size,json=totalSize" json:"total_size,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*RowSampleCollector) Descriptor

func (*RowSampleCollector) Descriptor() ([]byte, []int)

func (*RowSampleCollector) GetCount

func (m *RowSampleCollector) GetCount() int64

func (*RowSampleCollector) GetFmSketch

func (m *RowSampleCollector) GetFmSketch() []*FMSketch

func (*RowSampleCollector) GetNullCounts

func (m *RowSampleCollector) GetNullCounts() []int64

func (*RowSampleCollector) GetSamples

func (m *RowSampleCollector) GetSamples() []*RowSample

func (*RowSampleCollector) GetTotalSize

func (m *RowSampleCollector) GetTotalSize() []int64

func (*RowSampleCollector) Marshal

func (m *RowSampleCollector) Marshal() (dAtA []byte, err error)

func (*RowSampleCollector) MarshalTo

func (m *RowSampleCollector) MarshalTo(dAtA []byte) (int, error)

func (*RowSampleCollector) ProtoMessage

func (*RowSampleCollector) ProtoMessage()

func (*RowSampleCollector) Reset

func (m *RowSampleCollector) Reset()

func (*RowSampleCollector) Size

func (m *RowSampleCollector) Size() (n int)

func (*RowSampleCollector) String

func (m *RowSampleCollector) String() string

func (*RowSampleCollector) Unmarshal

func (m *RowSampleCollector) Unmarshal(dAtA []byte) error

type RpnExpr

type RpnExpr struct {
	// All children fields in exprs should be empty.
	Exprs            []*Expr `protobuf:"bytes,1,rep,name=exprs" json:"exprs,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Expression organized in RPN form. https://en.wikipedia.org/wiki/Reverse_Polish_notation

func (*RpnExpr) Descriptor

func (*RpnExpr) Descriptor() ([]byte, []int)

func (*RpnExpr) GetExprs

func (m *RpnExpr) GetExprs() []*Expr

func (*RpnExpr) Marshal

func (m *RpnExpr) Marshal() (dAtA []byte, err error)

func (*RpnExpr) MarshalTo

func (m *RpnExpr) MarshalTo(dAtA []byte) (int, error)

func (*RpnExpr) ProtoMessage

func (*RpnExpr) ProtoMessage()

func (*RpnExpr) Reset

func (m *RpnExpr) Reset()

func (*RpnExpr) Size

func (m *RpnExpr) Size() (n int)

func (*RpnExpr) String

func (m *RpnExpr) String() string

func (*RpnExpr) Unmarshal

func (m *RpnExpr) Unmarshal(dAtA []byte) error

type SQLMeta

type SQLMeta struct {
	SqlDigest     []byte `protobuf:"bytes,1,opt,name=sql_digest,json=sqlDigest,proto3" json:"sql_digest,omitempty"`
	NormalizedSql string `protobuf:"bytes,2,opt,name=normalized_sql,json=normalizedSql,proto3" json:"normalized_sql,omitempty"`
	IsInternalSql bool   `protobuf:"varint,3,opt,name=is_internal_sql,json=isInternalSql,proto3" json:"is_internal_sql,omitempty"`
}

func (*SQLMeta) Descriptor

func (*SQLMeta) Descriptor() ([]byte, []int)

func (*SQLMeta) GetIsInternalSql

func (m *SQLMeta) GetIsInternalSql() bool

func (*SQLMeta) GetNormalizedSql

func (m *SQLMeta) GetNormalizedSql() string

func (*SQLMeta) GetSqlDigest

func (m *SQLMeta) GetSqlDigest() []byte

func (*SQLMeta) Marshal

func (m *SQLMeta) Marshal() (dAtA []byte, err error)

func (*SQLMeta) MarshalTo

func (m *SQLMeta) MarshalTo(dAtA []byte) (int, error)

func (*SQLMeta) ProtoMessage

func (*SQLMeta) ProtoMessage()

func (*SQLMeta) Reset

func (m *SQLMeta) Reset()

func (*SQLMeta) Size

func (m *SQLMeta) Size() (n int)

func (*SQLMeta) String

func (m *SQLMeta) String() string

func (*SQLMeta) Unmarshal

func (m *SQLMeta) Unmarshal(dAtA []byte) error

type SampleCollector

type SampleCollector struct {
	Samples          [][]byte  `protobuf:"bytes,1,rep,name=samples" json:"samples,omitempty"`
	NullCount        int64     `protobuf:"varint,2,opt,name=null_count,json=nullCount" json:"null_count"`
	Count            int64     `protobuf:"varint,3,opt,name=count" json:"count"`
	FmSketch         *FMSketch `protobuf:"bytes,4,opt,name=fm_sketch,json=fmSketch" json:"fm_sketch,omitempty"`
	CmSketch         *CMSketch `protobuf:"bytes,5,opt,name=cm_sketch,json=cmSketch" json:"cm_sketch,omitempty"`
	TotalSize        *int64    `protobuf:"varint,6,opt,name=total_size,json=totalSize" json:"total_size,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

SampleCollector is used for collect samples and calculate the count and ndv of an column.

func (*SampleCollector) Descriptor

func (*SampleCollector) Descriptor() ([]byte, []int)

func (*SampleCollector) GetCmSketch

func (m *SampleCollector) GetCmSketch() *CMSketch

func (*SampleCollector) GetCount

func (m *SampleCollector) GetCount() int64

func (*SampleCollector) GetFmSketch

func (m *SampleCollector) GetFmSketch() *FMSketch

func (*SampleCollector) GetNullCount

func (m *SampleCollector) GetNullCount() int64

func (*SampleCollector) GetSamples

func (m *SampleCollector) GetSamples() [][]byte

func (*SampleCollector) GetTotalSize

func (m *SampleCollector) GetTotalSize() int64

func (*SampleCollector) Marshal

func (m *SampleCollector) Marshal() (dAtA []byte, err error)

func (*SampleCollector) MarshalTo

func (m *SampleCollector) MarshalTo(dAtA []byte) (int, error)

func (*SampleCollector) ProtoMessage

func (*SampleCollector) ProtoMessage()

func (*SampleCollector) Reset

func (m *SampleCollector) Reset()

func (*SampleCollector) Size

func (m *SampleCollector) Size() (n int)

func (*SampleCollector) String

func (m *SampleCollector) String() string

func (*SampleCollector) Unmarshal

func (m *SampleCollector) Unmarshal(dAtA []byte) error

type ScalarFuncSig

type ScalarFuncSig int32
const (
	ScalarFuncSig_Unspecified ScalarFuncSig = 0
	// Casting
	ScalarFuncSig_CastIntAsInt           ScalarFuncSig = 1
	ScalarFuncSig_CastIntAsReal          ScalarFuncSig = 2
	ScalarFuncSig_CastIntAsString        ScalarFuncSig = 3
	ScalarFuncSig_CastIntAsDecimal       ScalarFuncSig = 4
	ScalarFuncSig_CastIntAsTime          ScalarFuncSig = 5
	ScalarFuncSig_CastIntAsDuration      ScalarFuncSig = 6
	ScalarFuncSig_CastIntAsJson          ScalarFuncSig = 7
	ScalarFuncSig_CastRealAsInt          ScalarFuncSig = 10
	ScalarFuncSig_CastRealAsReal         ScalarFuncSig = 11
	ScalarFuncSig_CastRealAsString       ScalarFuncSig = 12
	ScalarFuncSig_CastRealAsDecimal      ScalarFuncSig = 13
	ScalarFuncSig_CastRealAsTime         ScalarFuncSig = 14
	ScalarFuncSig_CastRealAsDuration     ScalarFuncSig = 15
	ScalarFuncSig_CastRealAsJson         ScalarFuncSig = 16
	ScalarFuncSig_CastDecimalAsInt       ScalarFuncSig = 20
	ScalarFuncSig_CastDecimalAsReal      ScalarFuncSig = 21
	ScalarFuncSig_CastDecimalAsString    ScalarFuncSig = 22
	ScalarFuncSig_CastDecimalAsDecimal   ScalarFuncSig = 23
	ScalarFuncSig_CastDecimalAsTime      ScalarFuncSig = 24
	ScalarFuncSig_CastDecimalAsDuration  ScalarFuncSig = 25
	ScalarFuncSig_CastDecimalAsJson      ScalarFuncSig = 26
	ScalarFuncSig_CastStringAsInt        ScalarFuncSig = 30
	ScalarFuncSig_CastStringAsReal       ScalarFuncSig = 31
	ScalarFuncSig_CastStringAsString     ScalarFuncSig = 32
	ScalarFuncSig_CastStringAsDecimal    ScalarFuncSig = 33
	ScalarFuncSig_CastStringAsTime       ScalarFuncSig = 34
	ScalarFuncSig_CastStringAsDuration   ScalarFuncSig = 35
	ScalarFuncSig_CastStringAsJson       ScalarFuncSig = 36
	ScalarFuncSig_CastTimeAsInt          ScalarFuncSig = 40
	ScalarFuncSig_CastTimeAsReal         ScalarFuncSig = 41
	ScalarFuncSig_CastTimeAsString       ScalarFuncSig = 42
	ScalarFuncSig_CastTimeAsDecimal      ScalarFuncSig = 43
	ScalarFuncSig_CastTimeAsTime         ScalarFuncSig = 44
	ScalarFuncSig_CastTimeAsDuration     ScalarFuncSig = 45
	ScalarFuncSig_CastTimeAsJson         ScalarFuncSig = 46
	ScalarFuncSig_CastDurationAsInt      ScalarFuncSig = 50
	ScalarFuncSig_CastDurationAsReal     ScalarFuncSig = 51
	ScalarFuncSig_CastDurationAsString   ScalarFuncSig = 52
	ScalarFuncSig_CastDurationAsDecimal  ScalarFuncSig = 53
	ScalarFuncSig_CastDurationAsTime     ScalarFuncSig = 54
	ScalarFuncSig_CastDurationAsDuration ScalarFuncSig = 55
	ScalarFuncSig_CastDurationAsJson     ScalarFuncSig = 56
	ScalarFuncSig_CastJsonAsInt          ScalarFuncSig = 60
	ScalarFuncSig_CastJsonAsReal         ScalarFuncSig = 61
	ScalarFuncSig_CastJsonAsString       ScalarFuncSig = 62
	ScalarFuncSig_CastJsonAsDecimal      ScalarFuncSig = 63
	ScalarFuncSig_CastJsonAsTime         ScalarFuncSig = 64
	ScalarFuncSig_CastJsonAsDuration     ScalarFuncSig = 65
	ScalarFuncSig_CastJsonAsJson         ScalarFuncSig = 66
	// compare
	ScalarFuncSig_CoalesceInt      ScalarFuncSig = 4201
	ScalarFuncSig_CoalesceReal     ScalarFuncSig = 4202
	ScalarFuncSig_CoalesceDecimal  ScalarFuncSig = 4203
	ScalarFuncSig_CoalesceString   ScalarFuncSig = 4204
	ScalarFuncSig_CoalesceTime     ScalarFuncSig = 4205
	ScalarFuncSig_CoalesceDuration ScalarFuncSig = 4206
	// unimplemented in tidb
	ScalarFuncSig_CoalesceJson    ScalarFuncSig = 4207
	ScalarFuncSig_LTInt           ScalarFuncSig = 100
	ScalarFuncSig_LTReal          ScalarFuncSig = 101
	ScalarFuncSig_LTDecimal       ScalarFuncSig = 102
	ScalarFuncSig_LTString        ScalarFuncSig = 103
	ScalarFuncSig_LTTime          ScalarFuncSig = 104
	ScalarFuncSig_LTDuration      ScalarFuncSig = 105
	ScalarFuncSig_LTJson          ScalarFuncSig = 106
	ScalarFuncSig_LEInt           ScalarFuncSig = 110
	ScalarFuncSig_LEReal          ScalarFuncSig = 111
	ScalarFuncSig_LEDecimal       ScalarFuncSig = 112
	ScalarFuncSig_LEString        ScalarFuncSig = 113
	ScalarFuncSig_LETime          ScalarFuncSig = 114
	ScalarFuncSig_LEDuration      ScalarFuncSig = 115
	ScalarFuncSig_LEJson          ScalarFuncSig = 116
	ScalarFuncSig_GTInt           ScalarFuncSig = 120
	ScalarFuncSig_GTReal          ScalarFuncSig = 121
	ScalarFuncSig_GTDecimal       ScalarFuncSig = 122
	ScalarFuncSig_GTString        ScalarFuncSig = 123
	ScalarFuncSig_GTTime          ScalarFuncSig = 124
	ScalarFuncSig_GTDuration      ScalarFuncSig = 125
	ScalarFuncSig_GTJson          ScalarFuncSig = 126
	ScalarFuncSig_GreatestInt     ScalarFuncSig = 4215
	ScalarFuncSig_GreatestReal    ScalarFuncSig = 4216
	ScalarFuncSig_GreatestDecimal ScalarFuncSig = 4217
	ScalarFuncSig_GreatestString  ScalarFuncSig = 4218
	ScalarFuncSig_GreatestTime    ScalarFuncSig = 4219
	ScalarFuncSig_LeastInt        ScalarFuncSig = 4220
	ScalarFuncSig_LeastReal       ScalarFuncSig = 4221
	ScalarFuncSig_LeastDecimal    ScalarFuncSig = 4222
	ScalarFuncSig_LeastString     ScalarFuncSig = 4223
	ScalarFuncSig_LeastTime       ScalarFuncSig = 4224
	ScalarFuncSig_IntervalInt     ScalarFuncSig = 4225
	ScalarFuncSig_IntervalReal    ScalarFuncSig = 4226
	ScalarFuncSig_GEInt           ScalarFuncSig = 130
	ScalarFuncSig_GEReal          ScalarFuncSig = 131
	ScalarFuncSig_GEDecimal       ScalarFuncSig = 132
	ScalarFuncSig_GEString        ScalarFuncSig = 133
	ScalarFuncSig_GETime          ScalarFuncSig = 134
	ScalarFuncSig_GEDuration      ScalarFuncSig = 135
	ScalarFuncSig_GEJson          ScalarFuncSig = 136
	ScalarFuncSig_EQInt           ScalarFuncSig = 140
	ScalarFuncSig_EQReal          ScalarFuncSig = 141
	ScalarFuncSig_EQDecimal       ScalarFuncSig = 142
	ScalarFuncSig_EQString        ScalarFuncSig = 143
	ScalarFuncSig_EQTime          ScalarFuncSig = 144
	ScalarFuncSig_EQDuration      ScalarFuncSig = 145
	ScalarFuncSig_EQJson          ScalarFuncSig = 146
	ScalarFuncSig_NEInt           ScalarFuncSig = 150
	ScalarFuncSig_NEReal          ScalarFuncSig = 151
	ScalarFuncSig_NEDecimal       ScalarFuncSig = 152
	ScalarFuncSig_NEString        ScalarFuncSig = 153
	ScalarFuncSig_NETime          ScalarFuncSig = 154
	ScalarFuncSig_NEDuration      ScalarFuncSig = 155
	ScalarFuncSig_NEJson          ScalarFuncSig = 156
	ScalarFuncSig_NullEQInt       ScalarFuncSig = 160
	ScalarFuncSig_NullEQReal      ScalarFuncSig = 161
	ScalarFuncSig_NullEQDecimal   ScalarFuncSig = 162
	ScalarFuncSig_NullEQString    ScalarFuncSig = 163
	ScalarFuncSig_NullEQTime      ScalarFuncSig = 164
	ScalarFuncSig_NullEQDuration  ScalarFuncSig = 165
	ScalarFuncSig_NullEQJson      ScalarFuncSig = 166
	// arithmetic
	ScalarFuncSig_PlusReal                       ScalarFuncSig = 200
	ScalarFuncSig_PlusDecimal                    ScalarFuncSig = 201
	ScalarFuncSig_PlusInt                        ScalarFuncSig = 203
	ScalarFuncSig_MinusReal                      ScalarFuncSig = 204
	ScalarFuncSig_MinusDecimal                   ScalarFuncSig = 205
	ScalarFuncSig_MinusInt                       ScalarFuncSig = 207
	ScalarFuncSig_MultiplyReal                   ScalarFuncSig = 208
	ScalarFuncSig_MultiplyDecimal                ScalarFuncSig = 209
	ScalarFuncSig_MultiplyInt                    ScalarFuncSig = 210
	ScalarFuncSig_DivideReal                     ScalarFuncSig = 211
	ScalarFuncSig_DivideDecimal                  ScalarFuncSig = 212
	ScalarFuncSig_IntDivideInt                   ScalarFuncSig = 213
	ScalarFuncSig_IntDivideDecimal               ScalarFuncSig = 214
	ScalarFuncSig_ModReal                        ScalarFuncSig = 215
	ScalarFuncSig_ModDecimal                     ScalarFuncSig = 216
	ScalarFuncSig_ModInt                         ScalarFuncSig = 217
	ScalarFuncSig_MultiplyIntUnsigned            ScalarFuncSig = 218
	ScalarFuncSig_PlusIntUnsignedUnsigned        ScalarFuncSig = 219
	ScalarFuncSig_PlusIntUnsignedSigned          ScalarFuncSig = 220
	ScalarFuncSig_PlusIntSignedUnsigned          ScalarFuncSig = 221
	ScalarFuncSig_PlusIntSignedSigned            ScalarFuncSig = 222
	ScalarFuncSig_ModIntUnsignedUnsigned         ScalarFuncSig = 223
	ScalarFuncSig_ModIntUnsignedSigned           ScalarFuncSig = 224
	ScalarFuncSig_ModIntSignedUnsigned           ScalarFuncSig = 225
	ScalarFuncSig_ModIntSignedSigned             ScalarFuncSig = 226
	ScalarFuncSig_MinusIntUnsignedUnsigned       ScalarFuncSig = 227
	ScalarFuncSig_MinusIntUnsignedSigned         ScalarFuncSig = 228
	ScalarFuncSig_MinusIntSignedUnsigned         ScalarFuncSig = 229
	ScalarFuncSig_MinusIntSignedSigned           ScalarFuncSig = 230
	ScalarFuncSig_MinusIntForcedUnsignedUnsigned ScalarFuncSig = 231
	ScalarFuncSig_MinusIntForcedUnsignedSigned   ScalarFuncSig = 232
	ScalarFuncSig_MinusIntForcedSignedUnsigned   ScalarFuncSig = 233
	ScalarFuncSig_IntDivideIntUnsignedUnsigned   ScalarFuncSig = 234
	ScalarFuncSig_IntDivideIntUnsignedSigned     ScalarFuncSig = 235
	ScalarFuncSig_IntDivideIntSignedSigned       ScalarFuncSig = 236
	ScalarFuncSig_IntDivideIntSignedUnsigned     ScalarFuncSig = 237
	// math
	ScalarFuncSig_AbsInt               ScalarFuncSig = 2101
	ScalarFuncSig_AbsUInt              ScalarFuncSig = 2102
	ScalarFuncSig_AbsReal              ScalarFuncSig = 2103
	ScalarFuncSig_AbsDecimal           ScalarFuncSig = 2104
	ScalarFuncSig_CeilIntToDec         ScalarFuncSig = 2105
	ScalarFuncSig_CeilIntToInt         ScalarFuncSig = 2106
	ScalarFuncSig_CeilDecToInt         ScalarFuncSig = 2107
	ScalarFuncSig_CeilDecToDec         ScalarFuncSig = 2108
	ScalarFuncSig_CeilReal             ScalarFuncSig = 2109
	ScalarFuncSig_FloorIntToDec        ScalarFuncSig = 2110
	ScalarFuncSig_FloorIntToInt        ScalarFuncSig = 2111
	ScalarFuncSig_FloorDecToInt        ScalarFuncSig = 2112
	ScalarFuncSig_FloorDecToDec        ScalarFuncSig = 2113
	ScalarFuncSig_FloorReal            ScalarFuncSig = 2114
	ScalarFuncSig_RoundReal            ScalarFuncSig = 2121
	ScalarFuncSig_RoundInt             ScalarFuncSig = 2122
	ScalarFuncSig_RoundDec             ScalarFuncSig = 2123
	ScalarFuncSig_RoundWithFracReal    ScalarFuncSig = 2124
	ScalarFuncSig_RoundWithFracInt     ScalarFuncSig = 2125
	ScalarFuncSig_RoundWithFracDec     ScalarFuncSig = 2126
	ScalarFuncSig_Log1Arg              ScalarFuncSig = 2131
	ScalarFuncSig_Log2Args             ScalarFuncSig = 2132
	ScalarFuncSig_Log2                 ScalarFuncSig = 2133
	ScalarFuncSig_Log10                ScalarFuncSig = 2134
	ScalarFuncSig_Rand                 ScalarFuncSig = 2135
	ScalarFuncSig_RandWithSeedFirstGen ScalarFuncSig = 2136
	ScalarFuncSig_Pow                  ScalarFuncSig = 2137
	ScalarFuncSig_Conv                 ScalarFuncSig = 2138
	ScalarFuncSig_CRC32                ScalarFuncSig = 2139
	ScalarFuncSig_Sign                 ScalarFuncSig = 2140
	ScalarFuncSig_Sqrt                 ScalarFuncSig = 2141
	ScalarFuncSig_Acos                 ScalarFuncSig = 2142
	ScalarFuncSig_Asin                 ScalarFuncSig = 2143
	ScalarFuncSig_Atan1Arg             ScalarFuncSig = 2144
	ScalarFuncSig_Atan2Args            ScalarFuncSig = 2145
	ScalarFuncSig_Cos                  ScalarFuncSig = 2146
	ScalarFuncSig_Cot                  ScalarFuncSig = 2147
	ScalarFuncSig_Degrees              ScalarFuncSig = 2148
	ScalarFuncSig_Exp                  ScalarFuncSig = 2149
	ScalarFuncSig_PI                   ScalarFuncSig = 2150
	ScalarFuncSig_Radians              ScalarFuncSig = 2151
	ScalarFuncSig_Sin                  ScalarFuncSig = 2152
	ScalarFuncSig_Tan                  ScalarFuncSig = 2153
	ScalarFuncSig_TruncateInt          ScalarFuncSig = 2154
	ScalarFuncSig_TruncateReal         ScalarFuncSig = 2155
	ScalarFuncSig_TruncateDecimal      ScalarFuncSig = 2156
	ScalarFuncSig_TruncateUint         ScalarFuncSig = 2157
	// op
	ScalarFuncSig_LogicalAnd        ScalarFuncSig = 3101
	ScalarFuncSig_LogicalOr         ScalarFuncSig = 3102
	ScalarFuncSig_LogicalXor        ScalarFuncSig = 3103
	ScalarFuncSig_UnaryNotInt       ScalarFuncSig = 3104
	ScalarFuncSig_UnaryNotDecimal   ScalarFuncSig = 3105
	ScalarFuncSig_UnaryNotReal      ScalarFuncSig = 3106
	ScalarFuncSig_UnaryMinusInt     ScalarFuncSig = 3108
	ScalarFuncSig_UnaryMinusReal    ScalarFuncSig = 3109
	ScalarFuncSig_UnaryMinusDecimal ScalarFuncSig = 3110
	ScalarFuncSig_DecimalIsNull     ScalarFuncSig = 3111
	ScalarFuncSig_DurationIsNull    ScalarFuncSig = 3112
	ScalarFuncSig_RealIsNull        ScalarFuncSig = 3113
	ScalarFuncSig_StringIsNull      ScalarFuncSig = 3114
	ScalarFuncSig_TimeIsNull        ScalarFuncSig = 3115
	ScalarFuncSig_IntIsNull         ScalarFuncSig = 3116
	// unimplemented in tidb
	ScalarFuncSig_JsonIsNull             ScalarFuncSig = 3117
	ScalarFuncSig_BitAndSig              ScalarFuncSig = 3118
	ScalarFuncSig_BitOrSig               ScalarFuncSig = 3119
	ScalarFuncSig_BitXorSig              ScalarFuncSig = 3120
	ScalarFuncSig_BitNegSig              ScalarFuncSig = 3121
	ScalarFuncSig_IntIsTrue              ScalarFuncSig = 3122
	ScalarFuncSig_RealIsTrue             ScalarFuncSig = 3123
	ScalarFuncSig_DecimalIsTrue          ScalarFuncSig = 3124
	ScalarFuncSig_IntIsFalse             ScalarFuncSig = 3125
	ScalarFuncSig_RealIsFalse            ScalarFuncSig = 3126
	ScalarFuncSig_DecimalIsFalse         ScalarFuncSig = 3127
	ScalarFuncSig_LeftShift              ScalarFuncSig = 3129
	ScalarFuncSig_RightShift             ScalarFuncSig = 3130
	ScalarFuncSig_IntIsTrueWithNull      ScalarFuncSig = 3142
	ScalarFuncSig_RealIsTrueWithNull     ScalarFuncSig = 3143
	ScalarFuncSig_DecimalIsTrueWithNull  ScalarFuncSig = 3144
	ScalarFuncSig_IntIsFalseWithNull     ScalarFuncSig = 3145
	ScalarFuncSig_RealIsFalseWithNull    ScalarFuncSig = 3146
	ScalarFuncSig_DecimalIsFalseWithNull ScalarFuncSig = 3147
	// other
	ScalarFuncSig_BitCount       ScalarFuncSig = 3128
	ScalarFuncSig_GetParamString ScalarFuncSig = 3131
	ScalarFuncSig_GetVar         ScalarFuncSig = 3132
	ScalarFuncSig_RowSig         ScalarFuncSig = 3133
	ScalarFuncSig_SetVar         ScalarFuncSig = 3134
	ScalarFuncSig_ValuesDecimal  ScalarFuncSig = 3135
	ScalarFuncSig_ValuesDuration ScalarFuncSig = 3136
	ScalarFuncSig_ValuesInt      ScalarFuncSig = 3137
	ScalarFuncSig_ValuesJSON     ScalarFuncSig = 3138
	ScalarFuncSig_ValuesReal     ScalarFuncSig = 3139
	ScalarFuncSig_ValuesString   ScalarFuncSig = 3140
	ScalarFuncSig_ValuesTime     ScalarFuncSig = 3141
	ScalarFuncSig_InInt          ScalarFuncSig = 4001
	ScalarFuncSig_InReal         ScalarFuncSig = 4002
	ScalarFuncSig_InDecimal      ScalarFuncSig = 4003
	ScalarFuncSig_InString       ScalarFuncSig = 4004
	ScalarFuncSig_InTime         ScalarFuncSig = 4005
	ScalarFuncSig_InDuration     ScalarFuncSig = 4006
	ScalarFuncSig_InJson         ScalarFuncSig = 4007
	// control
	ScalarFuncSig_IfNullInt        ScalarFuncSig = 4101
	ScalarFuncSig_IfNullReal       ScalarFuncSig = 4102
	ScalarFuncSig_IfNullDecimal    ScalarFuncSig = 4103
	ScalarFuncSig_IfNullString     ScalarFuncSig = 4104
	ScalarFuncSig_IfNullTime       ScalarFuncSig = 4105
	ScalarFuncSig_IfNullDuration   ScalarFuncSig = 4106
	ScalarFuncSig_IfInt            ScalarFuncSig = 4107
	ScalarFuncSig_IfReal           ScalarFuncSig = 4108
	ScalarFuncSig_IfDecimal        ScalarFuncSig = 4109
	ScalarFuncSig_IfString         ScalarFuncSig = 4110
	ScalarFuncSig_IfTime           ScalarFuncSig = 4111
	ScalarFuncSig_IfDuration       ScalarFuncSig = 4112
	ScalarFuncSig_IfNullJson       ScalarFuncSig = 4113
	ScalarFuncSig_IfJson           ScalarFuncSig = 4114
	ScalarFuncSig_CaseWhenInt      ScalarFuncSig = 4208
	ScalarFuncSig_CaseWhenReal     ScalarFuncSig = 4209
	ScalarFuncSig_CaseWhenDecimal  ScalarFuncSig = 4210
	ScalarFuncSig_CaseWhenString   ScalarFuncSig = 4211
	ScalarFuncSig_CaseWhenTime     ScalarFuncSig = 4212
	ScalarFuncSig_CaseWhenDuration ScalarFuncSig = 4213
	// unimplemented in tidb
	ScalarFuncSig_CaseWhenJson ScalarFuncSig = 4214
	// encryption
	ScalarFuncSig_AesDecrypt         ScalarFuncSig = 4501
	ScalarFuncSig_AesEncrypt         ScalarFuncSig = 4502
	ScalarFuncSig_Compress           ScalarFuncSig = 4503
	ScalarFuncSig_MD5                ScalarFuncSig = 4504
	ScalarFuncSig_Password           ScalarFuncSig = 4505
	ScalarFuncSig_RandomBytes        ScalarFuncSig = 4506
	ScalarFuncSig_SHA1               ScalarFuncSig = 4507
	ScalarFuncSig_SHA2               ScalarFuncSig = 4508
	ScalarFuncSig_Uncompress         ScalarFuncSig = 4509
	ScalarFuncSig_UncompressedLength ScalarFuncSig = 4510
	ScalarFuncSig_AesDecryptIV       ScalarFuncSig = 4511
	ScalarFuncSig_AesEncryptIV       ScalarFuncSig = 4512
	ScalarFuncSig_Encode             ScalarFuncSig = 4513
	ScalarFuncSig_Decode             ScalarFuncSig = 4514
	// info
	ScalarFuncSig_Database           ScalarFuncSig = 4521
	ScalarFuncSig_FoundRows          ScalarFuncSig = 4522
	ScalarFuncSig_CurrentUser        ScalarFuncSig = 4523
	ScalarFuncSig_User               ScalarFuncSig = 4524
	ScalarFuncSig_ConnectionID       ScalarFuncSig = 4525
	ScalarFuncSig_LastInsertID       ScalarFuncSig = 4526
	ScalarFuncSig_LastInsertIDWithID ScalarFuncSig = 4527
	ScalarFuncSig_Version            ScalarFuncSig = 4528
	ScalarFuncSig_TiDBVersion        ScalarFuncSig = 4529
	ScalarFuncSig_RowCount           ScalarFuncSig = 4530
	// miscellaneous
	ScalarFuncSig_Sleep            ScalarFuncSig = 4551
	ScalarFuncSig_Lock             ScalarFuncSig = 4552
	ScalarFuncSig_ReleaseLock      ScalarFuncSig = 4553
	ScalarFuncSig_DecimalAnyValue  ScalarFuncSig = 4554
	ScalarFuncSig_DurationAnyValue ScalarFuncSig = 4555
	ScalarFuncSig_IntAnyValue      ScalarFuncSig = 4556
	ScalarFuncSig_JSONAnyValue     ScalarFuncSig = 4557
	ScalarFuncSig_RealAnyValue     ScalarFuncSig = 4558
	ScalarFuncSig_StringAnyValue   ScalarFuncSig = 4559
	ScalarFuncSig_TimeAnyValue     ScalarFuncSig = 4560
	ScalarFuncSig_InetAton         ScalarFuncSig = 4561
	ScalarFuncSig_InetNtoa         ScalarFuncSig = 4562
	ScalarFuncSig_Inet6Aton        ScalarFuncSig = 4563
	ScalarFuncSig_Inet6Ntoa        ScalarFuncSig = 4564
	ScalarFuncSig_IsIPv4           ScalarFuncSig = 4565
	ScalarFuncSig_IsIPv4Compat     ScalarFuncSig = 4566
	ScalarFuncSig_IsIPv4Mapped     ScalarFuncSig = 4567
	ScalarFuncSig_IsIPv6           ScalarFuncSig = 4568
	ScalarFuncSig_UUID             ScalarFuncSig = 4569
	ScalarFuncSig_VitessHash       ScalarFuncSig = 4570
	// like
	ScalarFuncSig_LikeSig              ScalarFuncSig = 4310
	ScalarFuncSig_RegexpSig            ScalarFuncSig = 4311
	ScalarFuncSig_RegexpUTF8Sig        ScalarFuncSig = 4312
	ScalarFuncSig_RegexpLikeSig        ScalarFuncSig = 4313
	ScalarFuncSig_RegexpLikeUTF8Sig    ScalarFuncSig = 4314
	ScalarFuncSig_RegexpInStrSig       ScalarFuncSig = 4315
	ScalarFuncSig_RegexpInStrUTF8Sig   ScalarFuncSig = 4316
	ScalarFuncSig_RegexpReplaceSig     ScalarFuncSig = 4317
	ScalarFuncSig_RegexpReplaceUTF8Sig ScalarFuncSig = 4318
	ScalarFuncSig_RegexpSubstrSig      ScalarFuncSig = 4319
	ScalarFuncSig_RegexpSubstrUTF8Sig  ScalarFuncSig = 4320
	// json
	ScalarFuncSig_JsonExtractSig       ScalarFuncSig = 5001
	ScalarFuncSig_JsonUnquoteSig       ScalarFuncSig = 5002
	ScalarFuncSig_JsonTypeSig          ScalarFuncSig = 5003
	ScalarFuncSig_JsonSetSig           ScalarFuncSig = 5004
	ScalarFuncSig_JsonInsertSig        ScalarFuncSig = 5005
	ScalarFuncSig_JsonReplaceSig       ScalarFuncSig = 5006
	ScalarFuncSig_JsonRemoveSig        ScalarFuncSig = 5007
	ScalarFuncSig_JsonMergeSig         ScalarFuncSig = 5008
	ScalarFuncSig_JsonObjectSig        ScalarFuncSig = 5009
	ScalarFuncSig_JsonArraySig         ScalarFuncSig = 5010
	ScalarFuncSig_JsonValidJsonSig     ScalarFuncSig = 5011
	ScalarFuncSig_JsonContainsSig      ScalarFuncSig = 5012
	ScalarFuncSig_JsonArrayAppendSig   ScalarFuncSig = 5013
	ScalarFuncSig_JsonArrayInsertSig   ScalarFuncSig = 5014
	ScalarFuncSig_JsonMergePatchSig    ScalarFuncSig = 5015
	ScalarFuncSig_JsonMergePreserveSig ScalarFuncSig = 5016
	ScalarFuncSig_JsonContainsPathSig  ScalarFuncSig = 5017
	ScalarFuncSig_JsonPrettySig        ScalarFuncSig = 5018
	ScalarFuncSig_JsonQuoteSig         ScalarFuncSig = 5019
	ScalarFuncSig_JsonSearchSig        ScalarFuncSig = 5020
	ScalarFuncSig_JsonStorageSizeSig   ScalarFuncSig = 5021
	ScalarFuncSig_JsonDepthSig         ScalarFuncSig = 5022
	ScalarFuncSig_JsonKeysSig          ScalarFuncSig = 5023
	ScalarFuncSig_JsonLengthSig        ScalarFuncSig = 5024
	ScalarFuncSig_JsonKeys2ArgsSig     ScalarFuncSig = 5025
	ScalarFuncSig_JsonValidStringSig   ScalarFuncSig = 5026
	ScalarFuncSig_JsonValidOthersSig   ScalarFuncSig = 5027
	// time
	ScalarFuncSig_DateFormatSig             ScalarFuncSig = 6001
	ScalarFuncSig_DateLiteral               ScalarFuncSig = 6002
	ScalarFuncSig_DateDiff                  ScalarFuncSig = 6003
	ScalarFuncSig_NullTimeDiff              ScalarFuncSig = 6004
	ScalarFuncSig_TimeStringTimeDiff        ScalarFuncSig = 6005
	ScalarFuncSig_DurationStringTimeDiff    ScalarFuncSig = 6006
	ScalarFuncSig_DurationDurationTimeDiff  ScalarFuncSig = 6007
	ScalarFuncSig_StringTimeTimeDiff        ScalarFuncSig = 6008
	ScalarFuncSig_StringDurationTimeDiff    ScalarFuncSig = 6009
	ScalarFuncSig_StringStringTimeDiff      ScalarFuncSig = 6010
	ScalarFuncSig_TimeTimeTimeDiff          ScalarFuncSig = 6011
	ScalarFuncSig_Date                      ScalarFuncSig = 6012
	ScalarFuncSig_Hour                      ScalarFuncSig = 6013
	ScalarFuncSig_Minute                    ScalarFuncSig = 6014
	ScalarFuncSig_Second                    ScalarFuncSig = 6015
	ScalarFuncSig_MicroSecond               ScalarFuncSig = 6016
	ScalarFuncSig_Month                     ScalarFuncSig = 6017
	ScalarFuncSig_MonthName                 ScalarFuncSig = 6018
	ScalarFuncSig_NowWithArg                ScalarFuncSig = 6019
	ScalarFuncSig_NowWithoutArg             ScalarFuncSig = 6020
	ScalarFuncSig_DayName                   ScalarFuncSig = 6021
	ScalarFuncSig_DayOfMonth                ScalarFuncSig = 6022
	ScalarFuncSig_DayOfWeek                 ScalarFuncSig = 6023
	ScalarFuncSig_DayOfYear                 ScalarFuncSig = 6024
	ScalarFuncSig_WeekWithMode              ScalarFuncSig = 6025
	ScalarFuncSig_WeekWithoutMode           ScalarFuncSig = 6026
	ScalarFuncSig_WeekDay                   ScalarFuncSig = 6027
	ScalarFuncSig_WeekOfYear                ScalarFuncSig = 6028
	ScalarFuncSig_Year                      ScalarFuncSig = 6029
	ScalarFuncSig_YearWeekWithMode          ScalarFuncSig = 6030
	ScalarFuncSig_YearWeekWithoutMode       ScalarFuncSig = 6031
	ScalarFuncSig_GetFormat                 ScalarFuncSig = 6032
	ScalarFuncSig_SysDateWithFsp            ScalarFuncSig = 6033
	ScalarFuncSig_SysDateWithoutFsp         ScalarFuncSig = 6034
	ScalarFuncSig_CurrentDate               ScalarFuncSig = 6035
	ScalarFuncSig_CurrentTime0Arg           ScalarFuncSig = 6036
	ScalarFuncSig_CurrentTime1Arg           ScalarFuncSig = 6037
	ScalarFuncSig_Time                      ScalarFuncSig = 6038
	ScalarFuncSig_TimeLiteral               ScalarFuncSig = 6039
	ScalarFuncSig_UTCDate                   ScalarFuncSig = 6040
	ScalarFuncSig_UTCTimestampWithArg       ScalarFuncSig = 6041
	ScalarFuncSig_UTCTimestampWithoutArg    ScalarFuncSig = 6042
	ScalarFuncSig_AddDatetimeAndDuration    ScalarFuncSig = 6043
	ScalarFuncSig_AddDatetimeAndString      ScalarFuncSig = 6044
	ScalarFuncSig_AddTimeDateTimeNull       ScalarFuncSig = 6045
	ScalarFuncSig_AddStringAndDuration      ScalarFuncSig = 6046
	ScalarFuncSig_AddStringAndString        ScalarFuncSig = 6047
	ScalarFuncSig_AddTimeStringNull         ScalarFuncSig = 6048
	ScalarFuncSig_AddDurationAndDuration    ScalarFuncSig = 6049
	ScalarFuncSig_AddDurationAndString      ScalarFuncSig = 6050
	ScalarFuncSig_AddTimeDurationNull       ScalarFuncSig = 6051
	ScalarFuncSig_AddDateAndDuration        ScalarFuncSig = 6052
	ScalarFuncSig_AddDateAndString          ScalarFuncSig = 6053
	ScalarFuncSig_SubDatetimeAndDuration    ScalarFuncSig = 6054
	ScalarFuncSig_SubDatetimeAndString      ScalarFuncSig = 6055
	ScalarFuncSig_SubTimeDateTimeNull       ScalarFuncSig = 6056
	ScalarFuncSig_SubStringAndDuration      ScalarFuncSig = 6057
	ScalarFuncSig_SubStringAndString        ScalarFuncSig = 6058
	ScalarFuncSig_SubTimeStringNull         ScalarFuncSig = 6059
	ScalarFuncSig_SubDurationAndDuration    ScalarFuncSig = 6060
	ScalarFuncSig_SubDurationAndString      ScalarFuncSig = 6061
	ScalarFuncSig_SubTimeDurationNull       ScalarFuncSig = 6062
	ScalarFuncSig_SubDateAndDuration        ScalarFuncSig = 6063
	ScalarFuncSig_SubDateAndString          ScalarFuncSig = 6064
	ScalarFuncSig_UnixTimestampCurrent      ScalarFuncSig = 6065
	ScalarFuncSig_UnixTimestampInt          ScalarFuncSig = 6066
	ScalarFuncSig_UnixTimestampDec          ScalarFuncSig = 6067
	ScalarFuncSig_ConvertTz                 ScalarFuncSig = 6068
	ScalarFuncSig_MakeDate                  ScalarFuncSig = 6069
	ScalarFuncSig_MakeTime                  ScalarFuncSig = 6070
	ScalarFuncSig_PeriodAdd                 ScalarFuncSig = 6071
	ScalarFuncSig_PeriodDiff                ScalarFuncSig = 6072
	ScalarFuncSig_Quarter                   ScalarFuncSig = 6073
	ScalarFuncSig_SecToTime                 ScalarFuncSig = 6074
	ScalarFuncSig_TimeToSec                 ScalarFuncSig = 6075
	ScalarFuncSig_TimestampAdd              ScalarFuncSig = 6076
	ScalarFuncSig_ToDays                    ScalarFuncSig = 6077
	ScalarFuncSig_ToSeconds                 ScalarFuncSig = 6078
	ScalarFuncSig_UTCTimeWithArg            ScalarFuncSig = 6079
	ScalarFuncSig_UTCTimeWithoutArg         ScalarFuncSig = 6080
	ScalarFuncSig_Timestamp1Arg             ScalarFuncSig = 6081
	ScalarFuncSig_Timestamp2Args            ScalarFuncSig = 6082
	ScalarFuncSig_TimestampLiteral          ScalarFuncSig = 6083
	ScalarFuncSig_LastDay                   ScalarFuncSig = 6084
	ScalarFuncSig_StrToDateDate             ScalarFuncSig = 6085
	ScalarFuncSig_StrToDateDatetime         ScalarFuncSig = 6086
	ScalarFuncSig_StrToDateDuration         ScalarFuncSig = 6087
	ScalarFuncSig_FromUnixTime1Arg          ScalarFuncSig = 6088
	ScalarFuncSig_FromUnixTime2Arg          ScalarFuncSig = 6089
	ScalarFuncSig_ExtractDatetime           ScalarFuncSig = 6090
	ScalarFuncSig_ExtractDuration           ScalarFuncSig = 6091
	ScalarFuncSig_AddDateStringString       ScalarFuncSig = 6092
	ScalarFuncSig_AddDateStringInt          ScalarFuncSig = 6093
	ScalarFuncSig_AddDateStringDecimal      ScalarFuncSig = 6094
	ScalarFuncSig_AddDateIntString          ScalarFuncSig = 6095
	ScalarFuncSig_AddDateIntInt             ScalarFuncSig = 6096
	ScalarFuncSig_AddDateDatetimeString     ScalarFuncSig = 6097
	ScalarFuncSig_AddDateDatetimeInt        ScalarFuncSig = 6098
	ScalarFuncSig_SubDateStringString       ScalarFuncSig = 6099
	ScalarFuncSig_SubDateStringInt          ScalarFuncSig = 6100
	ScalarFuncSig_SubDateStringDecimal      ScalarFuncSig = 6101
	ScalarFuncSig_SubDateIntString          ScalarFuncSig = 6102
	ScalarFuncSig_SubDateIntInt             ScalarFuncSig = 6103
	ScalarFuncSig_SubDateDatetimeString     ScalarFuncSig = 6104
	ScalarFuncSig_SubDateDatetimeInt        ScalarFuncSig = 6105
	ScalarFuncSig_FromDays                  ScalarFuncSig = 6106
	ScalarFuncSig_TimeFormat                ScalarFuncSig = 6107
	ScalarFuncSig_TimestampDiff             ScalarFuncSig = 6108
	ScalarFuncSig_SubDateStringReal         ScalarFuncSig = 6109
	ScalarFuncSig_SubDateIntReal            ScalarFuncSig = 6110
	ScalarFuncSig_SubDateIntDecimal         ScalarFuncSig = 6111
	ScalarFuncSig_SubDateDatetimeReal       ScalarFuncSig = 6112
	ScalarFuncSig_SubDateDatetimeDecimal    ScalarFuncSig = 6113
	ScalarFuncSig_SubDateDurationString     ScalarFuncSig = 6114
	ScalarFuncSig_SubDateDurationInt        ScalarFuncSig = 6115
	ScalarFuncSig_SubDateDurationReal       ScalarFuncSig = 6116
	ScalarFuncSig_SubDateDurationDecimal    ScalarFuncSig = 6117
	ScalarFuncSig_AddDateStringReal         ScalarFuncSig = 6118
	ScalarFuncSig_AddDateIntReal            ScalarFuncSig = 6119
	ScalarFuncSig_AddDateIntDecimal         ScalarFuncSig = 6120
	ScalarFuncSig_AddDateDatetimeReal       ScalarFuncSig = 6121
	ScalarFuncSig_AddDateDatetimeDecimal    ScalarFuncSig = 6122
	ScalarFuncSig_AddDateDurationString     ScalarFuncSig = 6123
	ScalarFuncSig_AddDateDurationInt        ScalarFuncSig = 6124
	ScalarFuncSig_AddDateDurationReal       ScalarFuncSig = 6125
	ScalarFuncSig_AddDateDurationDecimal    ScalarFuncSig = 6126
	ScalarFuncSig_ExtractDatetimeFromString ScalarFuncSig = 6127
	// String functions
	ScalarFuncSig_BitLength          ScalarFuncSig = 7001
	ScalarFuncSig_Bin                ScalarFuncSig = 7002
	ScalarFuncSig_ASCII              ScalarFuncSig = 7003
	ScalarFuncSig_Char               ScalarFuncSig = 7004
	ScalarFuncSig_CharLengthUTF8     ScalarFuncSig = 7005
	ScalarFuncSig_Concat             ScalarFuncSig = 7006
	ScalarFuncSig_ConcatWS           ScalarFuncSig = 7007
	ScalarFuncSig_Convert            ScalarFuncSig = 7008
	ScalarFuncSig_Elt                ScalarFuncSig = 7009
	ScalarFuncSig_ExportSet3Arg      ScalarFuncSig = 7010
	ScalarFuncSig_ExportSet4Arg      ScalarFuncSig = 7011
	ScalarFuncSig_ExportSet5Arg      ScalarFuncSig = 7012
	ScalarFuncSig_FieldInt           ScalarFuncSig = 7013
	ScalarFuncSig_FieldReal          ScalarFuncSig = 7014
	ScalarFuncSig_FieldString        ScalarFuncSig = 7015
	ScalarFuncSig_FindInSet          ScalarFuncSig = 7016
	ScalarFuncSig_Format             ScalarFuncSig = 7017
	ScalarFuncSig_FormatWithLocale   ScalarFuncSig = 7018
	ScalarFuncSig_FromBase64         ScalarFuncSig = 7019
	ScalarFuncSig_HexIntArg          ScalarFuncSig = 7020
	ScalarFuncSig_HexStrArg          ScalarFuncSig = 7021
	ScalarFuncSig_InsertUTF8         ScalarFuncSig = 7022
	ScalarFuncSig_Insert             ScalarFuncSig = 7023
	ScalarFuncSig_InstrUTF8          ScalarFuncSig = 7024
	ScalarFuncSig_Instr              ScalarFuncSig = 7025
	ScalarFuncSig_LTrim              ScalarFuncSig = 7026
	ScalarFuncSig_LeftUTF8           ScalarFuncSig = 7027
	ScalarFuncSig_Left               ScalarFuncSig = 7028
	ScalarFuncSig_Length             ScalarFuncSig = 7029
	ScalarFuncSig_Locate2ArgsUTF8    ScalarFuncSig = 7030
	ScalarFuncSig_Locate3ArgsUTF8    ScalarFuncSig = 7031
	ScalarFuncSig_Locate2Args        ScalarFuncSig = 7032
	ScalarFuncSig_Locate3Args        ScalarFuncSig = 7033
	ScalarFuncSig_Lower              ScalarFuncSig = 7034
	ScalarFuncSig_LpadUTF8           ScalarFuncSig = 7035
	ScalarFuncSig_Lpad               ScalarFuncSig = 7036
	ScalarFuncSig_MakeSet            ScalarFuncSig = 7037
	ScalarFuncSig_OctInt             ScalarFuncSig = 7038
	ScalarFuncSig_OctString          ScalarFuncSig = 7039
	ScalarFuncSig_Ord                ScalarFuncSig = 7040
	ScalarFuncSig_Quote              ScalarFuncSig = 7041
	ScalarFuncSig_RTrim              ScalarFuncSig = 7042
	ScalarFuncSig_Repeat             ScalarFuncSig = 7043
	ScalarFuncSig_Replace            ScalarFuncSig = 7044
	ScalarFuncSig_ReverseUTF8        ScalarFuncSig = 7045
	ScalarFuncSig_Reverse            ScalarFuncSig = 7046
	ScalarFuncSig_RightUTF8          ScalarFuncSig = 7047
	ScalarFuncSig_Right              ScalarFuncSig = 7048
	ScalarFuncSig_RpadUTF8           ScalarFuncSig = 7049
	ScalarFuncSig_Rpad               ScalarFuncSig = 7050
	ScalarFuncSig_Space              ScalarFuncSig = 7051
	ScalarFuncSig_Strcmp             ScalarFuncSig = 7052
	ScalarFuncSig_Substring2ArgsUTF8 ScalarFuncSig = 7053
	ScalarFuncSig_Substring3ArgsUTF8 ScalarFuncSig = 7054
	ScalarFuncSig_Substring2Args     ScalarFuncSig = 7055
	ScalarFuncSig_Substring3Args     ScalarFuncSig = 7056
	ScalarFuncSig_SubstringIndex     ScalarFuncSig = 7057
	ScalarFuncSig_ToBase64           ScalarFuncSig = 7058
	ScalarFuncSig_Trim1Arg           ScalarFuncSig = 7059
	ScalarFuncSig_Trim2Args          ScalarFuncSig = 7060
	ScalarFuncSig_Trim3Args          ScalarFuncSig = 7061
	ScalarFuncSig_UnHex              ScalarFuncSig = 7062
	ScalarFuncSig_UpperUTF8          ScalarFuncSig = 7063
	ScalarFuncSig_Upper              ScalarFuncSig = 7064
	ScalarFuncSig_CharLength         ScalarFuncSig = 7065
	ScalarFuncSig_LowerUTF8          ScalarFuncSig = 7066
)

func (ScalarFuncSig) Enum

func (x ScalarFuncSig) Enum() *ScalarFuncSig

func (ScalarFuncSig) EnumDescriptor

func (ScalarFuncSig) EnumDescriptor() ([]byte, []int)

func (ScalarFuncSig) String

func (x ScalarFuncSig) String() string

func (*ScalarFuncSig) UnmarshalJSON

func (x *ScalarFuncSig) UnmarshalJSON(data []byte) error

type SelectResponse

type SelectResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// Result rows.
	Rows []*Row `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	// Use multiple chunks to reduce memory allocation and
	// avoid allocating large contiguous memory.
	Chunks       []Chunk  `protobuf:"bytes,3,rep,name=chunks" json:"chunks"`
	Warnings     []*Error `protobuf:"bytes,4,rep,name=warnings" json:"warnings,omitempty"`
	OutputCounts []int64  `protobuf:"varint,5,rep,name=output_counts,json=outputCounts" json:"output_counts,omitempty"`
	WarningCount *int64   `protobuf:"varint,6,opt,name=warning_count,json=warningCount" json:"warning_count,omitempty"`
	// The execution summary of each executor, in the order in request.
	ExecutionSummaries []*ExecutorExecutionSummary `protobuf:"bytes,8,rep,name=execution_summaries,json=executionSummaries" json:"execution_summaries,omitempty"`
	// It indicates the encode type of response.
	EncodeType EncodeType `protobuf:"varint,9,opt,name=encode_type,json=encodeType,enum=tipb.EncodeType" json:"encode_type"`
	// ndvs collects the number of distinct value information per range. It will be used to serve as execution feedback information.
	// Helping us improve the table's statistics information.
	Ndvs             []int64 `protobuf:"varint,10,rep,name=ndvs" json:"ndvs,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Response for SelectRequest.

func (*SelectResponse) Descriptor

func (*SelectResponse) Descriptor() ([]byte, []int)

func (*SelectResponse) GetChunks

func (m *SelectResponse) GetChunks() []Chunk

func (*SelectResponse) GetEncodeType

func (m *SelectResponse) GetEncodeType() EncodeType

func (*SelectResponse) GetError

func (m *SelectResponse) GetError() *Error

func (*SelectResponse) GetExecutionSummaries

func (m *SelectResponse) GetExecutionSummaries() []*ExecutorExecutionSummary

func (*SelectResponse) GetNdvs

func (m *SelectResponse) GetNdvs() []int64

func (*SelectResponse) GetOutputCounts

func (m *SelectResponse) GetOutputCounts() []int64

func (*SelectResponse) GetRows

func (m *SelectResponse) GetRows() []*Row

func (*SelectResponse) GetWarningCount

func (m *SelectResponse) GetWarningCount() int64

func (*SelectResponse) GetWarnings

func (m *SelectResponse) GetWarnings() []*Error

func (*SelectResponse) Marshal

func (m *SelectResponse) Marshal() (dAtA []byte, err error)

func (*SelectResponse) MarshalTo

func (m *SelectResponse) MarshalTo(dAtA []byte) (int, error)

func (*SelectResponse) ProtoMessage

func (*SelectResponse) ProtoMessage()

func (*SelectResponse) Reset

func (m *SelectResponse) Reset()

func (*SelectResponse) Size

func (m *SelectResponse) Size() (n int)

func (*SelectResponse) String

func (m *SelectResponse) String() string

func (*SelectResponse) Unmarshal

func (m *SelectResponse) Unmarshal(dAtA []byte) error

type Selection

type Selection struct {
	// Where conditions.
	Conditions       []*Expr    `protobuf:"bytes,1,rep,name=conditions" json:"conditions,omitempty"`
	RpnConditions    []*RpnExpr `protobuf:"bytes,2,rep,name=rpn_conditions,json=rpnConditions" json:"rpn_conditions,omitempty"`
	Child            *Executor  `protobuf:"bytes,3,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*Selection) Descriptor

func (*Selection) Descriptor() ([]byte, []int)

func (*Selection) GetChild

func (m *Selection) GetChild() *Executor

func (*Selection) GetConditions

func (m *Selection) GetConditions() []*Expr

func (*Selection) GetRpnConditions

func (m *Selection) GetRpnConditions() []*RpnExpr

func (*Selection) Marshal

func (m *Selection) Marshal() (dAtA []byte, err error)

func (*Selection) MarshalTo

func (m *Selection) MarshalTo(dAtA []byte) (int, error)

func (*Selection) ProtoMessage

func (*Selection) ProtoMessage()

func (*Selection) Reset

func (m *Selection) Reset()

func (*Selection) Size

func (m *Selection) Size() (n int)

func (*Selection) String

func (m *Selection) String() string

func (*Selection) Unmarshal

func (m *Selection) Unmarshal(dAtA []byte) error

type StreamResponse

type StreamResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// Data for all rows
	Data     github_com_pingcap_tipb_sharedbytes.SharedBytes `protobuf:"bytes,3,opt,name=data,customtype=github.com/pingcap/tipb/sharedbytes.SharedBytes" json:"data"`
	Warnings []*Error                                        `protobuf:"bytes,4,rep,name=warnings" json:"warnings,omitempty"`
	// output row count for each executor
	OutputCounts     []int64 `protobuf:"varint,5,rep,name=output_counts,json=outputCounts" json:"output_counts,omitempty"`
	WarningCount     *int64  `protobuf:"varint,6,opt,name=warning_count,json=warningCount" json:"warning_count,omitempty"`
	Ndvs             []int64 `protobuf:"varint,7,rep,name=ndvs" json:"ndvs,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StreamResponse) Descriptor

func (*StreamResponse) Descriptor() ([]byte, []int)

func (*StreamResponse) GetError

func (m *StreamResponse) GetError() *Error

func (*StreamResponse) GetNdvs

func (m *StreamResponse) GetNdvs() []int64

func (*StreamResponse) GetOutputCounts

func (m *StreamResponse) GetOutputCounts() []int64

func (*StreamResponse) GetWarningCount

func (m *StreamResponse) GetWarningCount() int64

func (*StreamResponse) GetWarnings

func (m *StreamResponse) GetWarnings() []*Error

func (*StreamResponse) Marshal

func (m *StreamResponse) Marshal() (dAtA []byte, err error)

func (*StreamResponse) MarshalTo

func (m *StreamResponse) MarshalTo(dAtA []byte) (int, error)

func (*StreamResponse) ProtoMessage

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset

func (m *StreamResponse) Reset()

func (*StreamResponse) Size

func (m *StreamResponse) Size() (n int)