tipb

package
v0.0.0-...-07a0962 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package tipb is a generated protocol buffer package.

It is generated from these files: 

analyze.proto
checksum.proto
executor.proto
expression.proto
schema.proto
select.proto

It has these top-level messages: 

AnalyzeReq
AnalyzeIndexReq
AnalyzeColumnsReq
AnalyzeColumnsResp
AnalyzeIndexResp
Bucket
Histogram
FMSketch
SampleCollector
CMSketchRow
CMSketchTopN
CMSketch
ChecksumRewriteRule
ChecksumRequest
ChecksumResponse
Executor
TableScan
IndexScan
Selection
Projection
Aggregation
TopN
Limit
ExecutorExecutionSummary
FieldType
Expr
ByItem
TableInfo
ColumnInfo
IndexInfo
KeyRange
Row
Error
SelectResponse
Chunk
RowMeta
DAGRequest
StreamResponse

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 (
	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 AnalyzeType_name = map[int32]string{
	0: "TypeIndex",
	1: "TypeColumn",
}
View Source 
var AnalyzeType_value = map[string]int32{
	"TypeIndex":  0,
	"TypeColumn": 1,
}
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: "TypeArrow",
}
View Source 
var EncodeType_value = map[string]int32{
	"TypeDefault": 0,
	"TypeArrow":   1,
}
View Source 
var ExecType_name = map[int32]string{
	0: "TypeTableScan",
	1: "TypeIndexScan",
	2: "TypeSelection",
	3: "TypeAggregation",
	4: "TypeTopN",
	5: "TypeLimit",
	6: "TypeStreamAgg",
}
View Source 
var ExecType_value = map[string]int32{
	"TypeTableScan":   0,
	"TypeIndexScan":   1,
	"TypeSelection":   2,
	"TypeAggregation": 3,
	"TypeTopN":        4,
	"TypeLimit":       5,
	"TypeStreamAgg":   6,
}
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",
	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,
	"ScalarFunc":    10000,
}
View Source 
var ScalarFuncSig_name = map[int32]string{}/* 488 elements not displayed */
View Source 
var ScalarFuncSig_value = map[string]int32{}/* 488 elements not displayed */

Functions

This section is empty.

Types

type Aggregation 

type Aggregation struct {
	// Group by clause.
	GroupBy []*Expr `protobuf:"bytes,1,rep,name=group_by,json=groupBy" json:"group_by,omitempty"`
	// Aggregate functions.
	AggFunc []*Expr `protobuf:"bytes,2,rep,name=agg_func,json=aggFunc" json:"agg_func,omitempty"`
	// If it is a stream aggregation.
	Streamed         bool   `protobuf:"varint,3,opt,name=streamed" json:"streamed"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Aggregation) Descriptor 

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

func (*Aggregation) GetAggFunc 

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

func (*Aggregation) GetGroupBy 

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

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 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"`
	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) GetColumnsInfo 

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

func (*AnalyzeColumnsReq) GetSampleSize 

func (m *AnalyzeColumnsReq) GetSampleSize() int64

func (*AnalyzeColumnsReq) GetSketchSize 

func (m *AnalyzeColumnsReq) GetSketchSize() int64

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"`
	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) 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"`
	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) 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"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*AnalyzeIndexResp) Descriptor 

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

func (*AnalyzeIndexResp) GetCms 

func (m *AnalyzeIndexResp) GetCms() *CMSketch

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 AnalyzeReq 

type AnalyzeReq struct {
	Tp               AnalyzeType        `protobuf:"varint,1,opt,name=tp,enum=tipb.AnalyzeType" json:"tp"`
	StartTs          uint64             `protobuf:"varint,2,opt,name=start_ts,json=startTs" json:"start_ts"`
	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) GetStartTs 

func (m *AnalyzeReq) GetStartTs() 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
)

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"`
	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) 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"`
	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) 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 ChecksumAlgorithm 

type ChecksumAlgorithm int32
const (
	ChecksumAlgorithm_Crc64_Xor ChecksumAlgorithm = 0
)

func (ChecksumAlgorithm) Enum 

func (x ChecksumAlgorithm) Enum() *ChecksumAlgorithm

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 {
	StartTs          uint64               `protobuf:"varint,1,opt,name=start_ts,json=startTs" json:"start_ts"`
	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) GetStartTs 

func (m *ChecksumRequest) GetStartTs() 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 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 DAGRequest 

type DAGRequest struct {
	// Transaction start timestamp.
	StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs" json:"start_ts"`
	// 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"`
	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) 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) GetMaxAllowedPacket 

func (m *DAGRequest) GetMaxAllowedPacket() uint64

func (*DAGRequest) GetMaxWarningCount 

func (m *DAGRequest) GetMaxWarningCount() uint64

func (*DAGRequest) GetOutputOffsets 

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

func (*DAGRequest) GetSqlMode 

func (m *DAGRequest) GetSqlMode() uint64

func (*DAGRequest) GetStartTs 

func (m *DAGRequest) GetStartTs() uint64

func (*DAGRequest) GetTimeZoneName 

func (m *DAGRequest) GetTimeZoneName() string

func (*DAGRequest) GetTimeZoneOffset 

func (m *DAGRequest) GetTimeZoneOffset() int64

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 EncodeType 

type EncodeType int32
const (
	EncodeType_TypeDefault EncodeType = 0
	EncodeType_TypeArrow   EncodeType = 1
)

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 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 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
)

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"`
	StreamAgg        *Aggregation `protobuf:"bytes,8,opt,name=stream_agg,json=streamAgg" json:"stream_agg,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) GetIdxScan 

func (m *Executor) GetIdxScan() *IndexScan

func (*Executor) GetLimit 

func (m *Executor) GetLimit() *Limit

func (*Executor) GetSelection 

func (m *Executor) GetSelection() *Selection

func (*Executor) GetStreamAgg 

func (m *Executor) GetStreamAgg() *Aggregation

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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ExecutorExecutionSummary) Descriptor 

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

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"`
	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"`
	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) 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
	// 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"`
	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) 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 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"`
	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) 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 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 Limit 

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

func (*Limit) Descriptor 

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

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 Projection 

type Projection struct {
	// Projection expressions.
	Exprs            []*Expr `protobuf:"bytes,1,rep,name=exprs" json:"exprs,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Projection) Descriptor 

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

func (*Projection) GetExprs 

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

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 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 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 (
	// Casting
	ScalarFuncSig_CastIntAsInt           ScalarFuncSig = 0
	ScalarFuncSig_CastIntAsReal          ScalarFuncSig = 1
	ScalarFuncSig_CastIntAsString        ScalarFuncSig = 2
	ScalarFuncSig_CastIntAsDecimal       ScalarFuncSig = 3
	ScalarFuncSig_CastIntAsTime          ScalarFuncSig = 4
	ScalarFuncSig_CastIntAsDuration      ScalarFuncSig = 5
	ScalarFuncSig_CastIntAsJson          ScalarFuncSig = 6
	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
	// 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_RandWithSeed      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
	// 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
	// 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
	// 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
	// like
	ScalarFuncSig_LikeSig         ScalarFuncSig = 4310
	ScalarFuncSig_RegexpBinarySig ScalarFuncSig = 4311
	ScalarFuncSig_RegexpSig       ScalarFuncSig = 4312
	// 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
	// String functions
	ScalarFuncSig_BitLength            ScalarFuncSig = 7001
	ScalarFuncSig_Bin                  ScalarFuncSig = 7002
	ScalarFuncSig_ASCII                ScalarFuncSig = 7003
	ScalarFuncSig_Char                 ScalarFuncSig = 7004
	ScalarFuncSig_CharLength           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_Insert               ScalarFuncSig = 7022
	ScalarFuncSig_InsertBinary         ScalarFuncSig = 7023
	ScalarFuncSig_Instr                ScalarFuncSig = 7024
	ScalarFuncSig_InstrBinary          ScalarFuncSig = 7025
	ScalarFuncSig_LTrim                ScalarFuncSig = 7026
	ScalarFuncSig_Left                 ScalarFuncSig = 7027
	ScalarFuncSig_LeftBinary           ScalarFuncSig = 7028
	ScalarFuncSig_Length               ScalarFuncSig = 7029
	ScalarFuncSig_Locate2Args          ScalarFuncSig = 7030
	ScalarFuncSig_Locate3Args          ScalarFuncSig = 7031
	ScalarFuncSig_LocateBinary2Args    ScalarFuncSig = 7032
	ScalarFuncSig_LocateBinary3Args    ScalarFuncSig = 7033
	ScalarFuncSig_Lower                ScalarFuncSig = 7034
	ScalarFuncSig_Lpad                 ScalarFuncSig = 7035
	ScalarFuncSig_LpadBinary           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_Reverse              ScalarFuncSig = 7045
	ScalarFuncSig_ReverseBinary        ScalarFuncSig = 7046
	ScalarFuncSig_Right                ScalarFuncSig = 7047
	ScalarFuncSig_RightBinary          ScalarFuncSig = 7048
	ScalarFuncSig_Rpad                 ScalarFuncSig = 7049
	ScalarFuncSig_RpadBinary           ScalarFuncSig = 7050
	ScalarFuncSig_Space                ScalarFuncSig = 7051
	ScalarFuncSig_Strcmp               ScalarFuncSig = 7052
	ScalarFuncSig_Substring2Args       ScalarFuncSig = 7053
	ScalarFuncSig_Substring3Args       ScalarFuncSig = 7054
	ScalarFuncSig_SubstringBinary2Args ScalarFuncSig = 7055
	ScalarFuncSig_SubstringBinary3Args 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_Upper                ScalarFuncSig = 7063
)

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"`
	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) 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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Selection) Descriptor 

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

func (*Selection) GetConditions 

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

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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StreamResponse) Descriptor 

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

func (*StreamResponse) GetError 

func (m *StreamResponse) GetError() *Error

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)

func (*StreamResponse) String 

func (m *StreamResponse) String() string

func (*StreamResponse) Unmarshal 

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

type TableInfo 

type TableInfo struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*TableInfo) Descriptor 

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

func (*TableInfo) GetColumns 

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

func (*TableInfo) GetTableId 

func (m *TableInfo) GetTableId() int64

func (*TableInfo) Marshal 

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

func (*TableInfo) MarshalTo 

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

func (*TableInfo) ProtoMessage 

func (*TableInfo) ProtoMessage()

func (*TableInfo) Reset 

func (m *TableInfo) Reset()

func (*TableInfo) Size 

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

func (*TableInfo) String 

func (m *TableInfo) String() string

func (*TableInfo) Unmarshal 

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

type TableScan 

type TableScan struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	Desc             bool          `protobuf:"varint,3,opt,name=desc" json:"desc"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*TableScan) Descriptor 

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

func (*TableScan) GetColumns 

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

func (*TableScan) GetDesc 

func (m *TableScan) GetDesc() bool

func (*TableScan) GetTableId 

func (m *TableScan) GetTableId() int64

func (*TableScan) Marshal 

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

func (*TableScan) MarshalTo 

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

func (*TableScan) ProtoMessage 

func (*TableScan) ProtoMessage()

func (*TableScan) Reset 

func (m *TableScan) Reset()

func (*TableScan) Size 

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

func (*TableScan) String 

func (m *TableScan) String() string

func (*TableScan) Unmarshal 

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

type TopN 

type TopN struct {
	// Order by clause.
	OrderBy          []*ByItem `protobuf:"bytes,1,rep,name=order_by,json=orderBy" json:"order_by,omitempty"`
	Limit            uint64    `protobuf:"varint,2,opt,name=limit" json:"limit"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TopN) Descriptor 

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

func (*TopN) GetLimit 

func (m *TopN) GetLimit() uint64

func (*TopN) GetOrderBy 

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

func (*TopN) Marshal 

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

func (*TopN) MarshalTo 

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

func (*TopN) ProtoMessage 

func (*TopN) ProtoMessage()

func (*TopN) Reset 

func (m *TopN) Reset()

func (*TopN) Size 

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

func (*TopN) String 

func (m *TopN) String() string

func (*TopN) Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.