tipb

package
v0.0.0-...-309139f Latest Latest
Warning

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

Go to latest
Published: Jan 16, 2021 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
expression.proto
metadata.proto
schema.proto
select.proto
trace.proto

It has these top-level messages:

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

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 (
	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 (
	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",
	2: "TypeCommonHandle",
	3: "TypeSampleIndex",
	4: "TypeMixed",
}
View Source
var AnalyzeType_value = map[string]int32{
	"TypeIndex":        0,
	"TypeColumn":       1,
	"TypeCommonHandle": 2,
	"TypeSampleIndex":  3,
	"TypeMixed":        4,
}
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",
	12: "TypeOneTripIndexLookup",
}
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,
	"TypeOneTripIndexLookup": 12,
}
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{}/* 539 elements not displayed */
View Source
var ScalarFuncSig_value = map[string]int32{}/* 539 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"`
	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 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"`
	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) GetPrimaryColumnIds

func (m *AnalyzeColumnsReq) GetPrimaryColumnIds() []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"`
	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"`
	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
)

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 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"`
	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) 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 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"`
	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) 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"`
	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) 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
	ExecType_TypeOneTripIndexLookup ExecType = 12
)

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"`
	OneTripIdxLookup *OneTripIndexLookup `protobuf:"bytes,14,opt,name=one_trip_idx_lookup,json=oneTripIdxLookup" json:"one_trip_idx_lookup,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) GetOneTripIdxLookup

func (m *Executor) GetOneTripIdxLookup() *OneTripIndexLookup

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

type OneTripIndexLookup struct {
	IdxScan          *DAGRequest `protobuf:"bytes,1,req,name=idx_scan,json=idxScan" json:"idx_scan,omitempty"`
	TblScan          *DAGRequest `protobuf:"bytes,2,req,name=tbl_scan,json=tblScan" json:"tbl_scan,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*OneTripIndexLookup) Descriptor

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

func (*OneTripIndexLookup) GetIdxScan

func (m *OneTripIndexLookup) GetIdxScan() *DAGRequest

func (*OneTripIndexLookup) GetTblScan

func (m *OneTripIndexLookup) GetTblScan() *DAGRequest

func (*OneTripIndexLookup) Marshal

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

func (*OneTripIndexLookup) MarshalTo

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

func (*OneTripIndexLookup) ProtoMessage

func (*OneTripIndexLookup) ProtoMessage()

func (*OneTripIndexLookup) Reset

func (m *OneTripIndexLookup) Reset()

func (*OneTripIndexLookup) Size

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

func (*OneTripIndexLookup) String

func (m *OneTripIndexLookup) String() string

func (*OneTripIndexLookup) Unmarshal

func (m *OneTripIndexLookup) 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 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 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 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
	// like
	ScalarFuncSig_LikeSig       ScalarFuncSig = 4310
	ScalarFuncSig_RegexpSig     ScalarFuncSig = 4311
	ScalarFuncSig_RegexpUTF8Sig 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
	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
	// 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
)

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)

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"`
	PrimaryColumnIds []int64       `protobuf:"varint,4,rep,name=primary_column_ids,json=primaryColumnIds" json:"primary_column_ids,omitempty"`
	NextReadEngine   EngineType    `protobuf:"varint,5,opt,name=next_read_engine,json=nextReadEngine,enum=tipb.EngineType" json:"next_read_engine"`
	Ranges           []KeyRange    `protobuf:"bytes,6,rep,name=ranges" json:"ranges"`
	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) GetNextReadEngine

func (m *TableScan) GetNextReadEngine() EngineType

func (*TableScan) GetPrimaryColumnIds

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

func (*TableScan) GetRanges

func (m *TableScan) GetRanges() []KeyRange

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"`
	Child            *Executor `protobuf:"bytes,3,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TopN) Descriptor

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

func (*TopN) GetChild

func (m *TopN) GetChild() *Executor

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

type UserIdentity

type UserIdentity struct {
	UserName         string `protobuf:"bytes,1,opt,name=user_name,json=userName" json:"user_name"`
	UserHost         string `protobuf:"bytes,2,opt,name=user_host,json=userHost" json:"user_host"`
	XXX_unrecognized []byte `json:"-"`
}

func (*UserIdentity) Descriptor

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

func (*UserIdentity) GetUserHost

func (m *UserIdentity) GetUserHost() string

func (*UserIdentity) GetUserName

func (m *UserIdentity) GetUserName() string

func (*UserIdentity) Marshal

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

func (*UserIdentity) MarshalTo

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

func (*UserIdentity) ProtoMessage

func (*UserIdentity) ProtoMessage()

func (*UserIdentity) Reset

func (m *UserIdentity) Reset()

func (*UserIdentity) Size

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

func (*UserIdentity) String

func (m *UserIdentity) String() string

func (*UserIdentity) Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL