tipb

package
v0.0.0-...-56b0212 Latest Latest
Warning

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

 Go to latest Published: Mar 24, 2024 License: Apache-2.0 Imports: 8 Imported by: 2,046

Documentation

Overview

Package tipb is a generated protocol buffer package.

It is generated from these files: 

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

It has these top-level messages: 

AnalyzeReq
AnalyzeIndexReq
AnalyzeColumnsReq
AnalyzeMixedResp
AnalyzeColumnGroup
AnalyzeColumnsResp
AnalyzeIndexResp
Bucket
Histogram
FMSketch
SampleCollector
RowSampleCollector
RowSample
CMSketchRow
CMSketchTopN
CMSketch
ChecksumRewriteRule
ChecksumRequest
ChecksumResponse
Executor
ExchangeSender
EncodedBytesSlice
ExchangeReceiver
ANNQueryInfo
TableScan
PartitionTableScan
Join
RuntimeFilter
IndexScan
Selection
Projection
Aggregation
TopN
Limit
Kill
ExecutorExecutionSummary
TiFlashExecutionInfo
TiFlashRegionNumOfInstance
TiFlashScanContext
Sort
WindowFrameBound
WindowFrame
Window
GroupingExpr
GroupingSet
Expand
ExprSlice
Expand2
ExplainData
ExplainOperator
AccessObject
DynamicPartitionAccessObjects
DynamicPartitionAccessObject
ScanAccessObject
IndexAccess
FieldType
Expr
RpnExpr
ByItem
InUnionMetadata
CompareInMetadata
GroupingMark
GroupingFunctionMetadata
ResourceGroupTag
TableInfo
ColumnInfo
IndexInfo
KeyRange
Row
Error
SelectResponse
Chunk
RowMeta
DAGRequest
ChunkMemoryLayout
UserIdentity
StreamResponse
TopSQLRecord
TopSQLRecordItem
SQLMeta
PlanMeta
EmptyResponse
TopSQLSubRequest
TopSQLSubResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAnalyze = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAnalyze   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthChecksum = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowChecksum   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthExecutor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecutor   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthExplain = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExplain   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthExpression = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExpression   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthResourcetag = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourcetag   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchema   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSelect = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSelect   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTopsqlAgent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopsqlAgent   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ANNQueryType_name = map[int32]string{
	0: "InvalidQueryType",
	1: "OrderBy",
}
View Source 
var ANNQueryType_value = map[string]int32{
	"InvalidQueryType": 0,
	"OrderBy":          1,
}
View Source 
var AggFunctionMode_name = map[int32]string{
	0: "CompleteMode",
	1: "FinalMode",
	2: "Partial1Mode",
	3: "Partial2Mode",
	4: "DedupMode",
}
View Source 
var AggFunctionMode_value = map[string]int32{
	"CompleteMode": 0,
	"FinalMode":    1,
	"Partial1Mode": 2,
	"Partial2Mode": 3,
	"DedupMode":    4,
}
View Source 
var AnalyzeType_name = map[int32]string{
	0: "TypeIndex",
	1: "TypeColumn",
	2: "TypeCommonHandle",
	3: "TypeSampleIndex",
	4: "TypeMixed",
	5: "TypeFullSampling",
}
View Source 
var AnalyzeType_value = map[string]int32{
	"TypeIndex":        0,
	"TypeColumn":       1,
	"TypeCommonHandle": 2,
	"TypeSampleIndex":  3,
	"TypeMixed":        4,
	"TypeFullSampling": 5,
}
View Source 
var ChecksumAlgorithm_name = map[int32]string{
	0: "Crc64_Xor",
}
View Source 
var ChecksumAlgorithm_value = map[string]int32{
	"Crc64_Xor": 0,
}
View Source 
var ChecksumScanOn_name = map[int32]string{
	0: "Table",
	1: "Index",
}
View Source 
var ChecksumScanOn_value = map[string]int32{
	"Table": 0,
	"Index": 1,
}
View Source 
var CompressionMode_name = map[int32]string{
	0: "NONE",
	1: "FAST",
	2: "HIGH_COMPRESSION",
}
View Source 
var CompressionMode_value = map[string]int32{
	"NONE":             0,
	"FAST":             1,
	"HIGH_COMPRESSION": 2,
}
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: "TypePartitionTableScan",
	13: "TypeSort",
	14: "TypeWindow",
	15: "TypeExpand",
	16: "TypeExpand2",
}
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,
	"TypePartitionTableScan": 12,
	"TypeSort":               13,
	"TypeWindow":             14,
	"TypeExpand":             15,
	"TypeExpand2":            16,
}
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",
	121:   "TiDBVectorFloat32",
	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",
	4001:  "RowNumber",
	4002:  "Rank",
	4003:  "DenseRank",
	4004:  "CumeDist",
	4005:  "PercentRank",
	4006:  "Ntile",
	4007:  "Lead",
	4008:  "Lag",
	4009:  "FirstValue",
	4010:  "LastValue",
	4011:  "NthValue",
	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,
	"TiDBVectorFloat32":   121,
	"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,
	"RowNumber":           4001,
	"Rank":                4002,
	"DenseRank":           4003,
	"CumeDist":            4004,
	"PercentRank":         4005,
	"Ntile":               4006,
	"Lead":                4007,
	"Lag":                 4008,
	"FirstValue":          4009,
	"LastValue":           4010,
	"NthValue":            4011,
	"ScalarFunc":          10000,
}
View Source 
var GroupingMode_name = map[int32]string{
	1: "ModeBitAnd",
	2: "ModeNumericCmp",
	3: "ModeNumericSet",
}
View Source 
var GroupingMode_value = map[string]int32{
	"ModeBitAnd":     1,
	"ModeNumericCmp": 2,
	"ModeNumericSet": 3,
}
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 OperatorLabel_name = map[int32]string{
	0: "empty",
	1: "buildSide",
	2: "probeSide",
	3: "seedPart",
	4: "recursivePart",
}
View Source 
var OperatorLabel_value = map[string]int32{
	"empty":         0,
	"buildSide":     1,
	"probeSide":     2,
	"seedPart":      3,
	"recursivePart": 4,
}
View Source 
var RangeCmpDataType_name = map[int32]string{
	0: "Int",
	1: "Float",
	2: "Decimal",
	3: "DateTime",
	4: "Duration",
}
View Source 
var RangeCmpDataType_value = map[string]int32{
	"Int":      0,
	"Float":    1,
	"Decimal":  2,
	"DateTime": 3,
	"Duration": 4,
}
View Source 
var ResourceGroupTagLabel_name = map[int32]string{
	0: "ResourceGroupTagLabelUnknown",
	1: "ResourceGroupTagLabelRow",
	2: "ResourceGroupTagLabelIndex",
}
View Source 
var ResourceGroupTagLabel_value = map[string]int32{
	"ResourceGroupTagLabelUnknown": 0,
	"ResourceGroupTagLabelRow":     1,
	"ResourceGroupTagLabelIndex":   2,
}
View Source 
var RuntimeFilterMode_name = map[int32]string{
	0: "LOCAL",
	1: "GLOBAL",
}
View Source 
var RuntimeFilterMode_value = map[string]int32{
	"LOCAL":  0,
	"GLOBAL": 1,
}
View Source 
var RuntimeFilterType_name = map[int32]string{
	0: "IN",
	1: "MIN_MAX",
	2: "BLOOM_FILTER",
}
View Source 
var RuntimeFilterType_value = map[string]int32{
	"IN":           0,
	"MIN_MAX":      1,
	"BLOOM_FILTER": 2,
}
View Source 
var ScalarFuncSig_name = map[int32]string{}/* 623 elements not displayed */
View Source 
var ScalarFuncSig_value = map[string]int32{}/* 623 elements not displayed */
View Source 
var StoreType_name = map[int32]string{
	0: "unspecified",
	1: "tidb",
	2: "tikv",
	3: "tiflash",
}
View Source 
var StoreType_value = map[string]int32{
	"unspecified": 0,
	"tidb":        1,
	"tikv":        2,
	"tiflash":     3,
}
View Source 
var TaskType_name = map[int32]string{
	0: "unknown",
	1: "root",
	2: "cop",
	3: "batchCop",
	4: "mpp",
}
View Source 
var TaskType_value = map[string]int32{
	"unknown":  0,
	"root":     1,
	"cop":      2,
	"batchCop": 3,
	"mpp":      4,
}
View Source 
var VectorDistanceMetric_name = map[int32]string{
	0: "INVALID_DISTANCE_METRIC",
	1: "L1",
	2: "L2",
	3: "COSINE",
	4: "INNER_PRODUCT",
}
View Source 
var VectorDistanceMetric_value = map[string]int32{
	"INVALID_DISTANCE_METRIC": 0,
	"L1":                      1,
	"L2":                      2,
	"COSINE":                  3,
	"INNER_PRODUCT":           4,
}
View Source 
var VectorIndexKind_name = map[int32]string{
	0: "INVALID_INDEX_KIND",
	1: "HNSW",
}
View Source 
var VectorIndexKind_value = map[string]int32{
	"INVALID_INDEX_KIND": 0,
	"HNSW":               1,
}
View Source 
var WindowBoundType_name = map[int32]string{
	0: "Following",
	1: "Preceding",
	2: "CurrentRow",
}
View Source 
var WindowBoundType_value = map[string]int32{
	"Following":  0,
	"Preceding":  1,
	"CurrentRow": 2,
}
View Source 
var WindowFrameType_name = map[int32]string{
	0: "Rows",
	1: "Ranges",
	2: "Groups",
}
View Source 
var WindowFrameType_value = map[string]int32{
	"Rows":   0,
	"Ranges": 1,
	"Groups": 2,
}

Functions

func RegisterTopSQLAgentServer 

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

func RegisterTopSQLPubSubServer 

func RegisterTopSQLPubSubServer(s *grpc.Server, srv TopSQLPubSubServer)

Types

type ANNQueryInfo 

type ANNQueryInfo struct {
	QueryType        ANNQueryType         `protobuf:"varint,1,opt,name=query_type,json=queryType,enum=tipb.ANNQueryType" json:"query_type"`
	DistanceMetric   VectorDistanceMetric `protobuf:"varint,2,opt,name=distance_metric,json=distanceMetric,enum=tipb.VectorDistanceMetric" json:"distance_metric"`
	TopK             uint32               `protobuf:"varint,3,opt,name=top_k,json=topK" json:"top_k"`
	ColumnName       string               `protobuf:"bytes,4,opt,name=column_name,json=columnName" json:"column_name"`
	ColumnId         int64                `protobuf:"varint,5,opt,name=column_id,json=columnId" json:"column_id"`
	RefVecF32        []byte               `protobuf:"bytes,6,opt,name=ref_vec_f32,json=refVecF32" json:"ref_vec_f32,omitempty"`
	MaxDistance      float64              `protobuf:"fixed64,10,opt,name=max_distance,json=maxDistance" json:"max_distance"`
	HnswEfSearch     uint32               `protobuf:"varint,20,opt,name=hnsw_ef_search,json=hnswEfSearch" json:"hnsw_ef_search"`
	XXX_unrecognized []byte               `json:"-"`
}

ANN = Approximate Nearest Neighbor. For some queries, ANN index can be used.

func (*ANNQueryInfo) Descriptor 

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

func (*ANNQueryInfo) GetColumnId 

func (m *ANNQueryInfo) GetColumnId() int64

func (*ANNQueryInfo) GetColumnName 

func (m *ANNQueryInfo) GetColumnName() string

func (*ANNQueryInfo) GetDistanceMetric 

func (m *ANNQueryInfo) GetDistanceMetric() VectorDistanceMetric

func (*ANNQueryInfo) GetHnswEfSearch 

func (m *ANNQueryInfo) GetHnswEfSearch() uint32

func (*ANNQueryInfo) GetMaxDistance 

func (m *ANNQueryInfo) GetMaxDistance() float64

func (*ANNQueryInfo) GetQueryType 

func (m *ANNQueryInfo) GetQueryType() ANNQueryType

func (*ANNQueryInfo) GetRefVecF32 

func (m *ANNQueryInfo) GetRefVecF32() []byte

func (*ANNQueryInfo) GetTopK 

func (m *ANNQueryInfo) GetTopK() uint32

func (*ANNQueryInfo) Marshal 

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

func (*ANNQueryInfo) MarshalTo 

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

func (*ANNQueryInfo) ProtoMessage 

func (*ANNQueryInfo) ProtoMessage()

func (*ANNQueryInfo) Reset 

func (m *ANNQueryInfo) Reset()

func (*ANNQueryInfo) Size 

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

func (*ANNQueryInfo) String 

func (m *ANNQueryInfo) String() string

func (*ANNQueryInfo) Unmarshal 

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

type ANNQueryType 

type ANNQueryType int32
const (
	ANNQueryType_InvalidQueryType ANNQueryType = 0
	ANNQueryType_OrderBy          ANNQueryType = 1
)

func (ANNQueryType) Enum 

func (x ANNQueryType) Enum() *ANNQueryType

func (ANNQueryType) EnumDescriptor 

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

func (ANNQueryType) String 

func (x ANNQueryType) String() string

func (*ANNQueryType) UnmarshalJSON 

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

type AccessObject 

type AccessObject struct {
	// Types that are valid to be assigned to AccessObject:
	//	*AccessObject_ScanObject
	//	*AccessObject_DynamicPartitionObjects
	//	*AccessObject_OtherObject
	AccessObject isAccessObject_AccessObject `protobuf_oneof:"access_object"`
}

func (*AccessObject) Descriptor 

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

func (*AccessObject) GetAccessObject 

func (m *AccessObject) GetAccessObject() isAccessObject_AccessObject

func (*AccessObject) GetDynamicPartitionObjects 

func (m *AccessObject) GetDynamicPartitionObjects() *DynamicPartitionAccessObjects

func (*AccessObject) GetOtherObject 

func (m *AccessObject) GetOtherObject() string

func (*AccessObject) GetScanObject 

func (m *AccessObject) GetScanObject() *ScanAccessObject

func (*AccessObject) Marshal 

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

func (*AccessObject) MarshalTo 

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

func (*AccessObject) ProtoMessage 

func (*AccessObject) ProtoMessage()

func (*AccessObject) Reset 

func (m *AccessObject) Reset()

func (*AccessObject) Size 

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

func (*AccessObject) String 

func (m *AccessObject) String() string

func (*AccessObject) Unmarshal 

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

func (*AccessObject) XXX_OneofFuncs 

func (*AccessObject) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type AccessObject_DynamicPartitionObjects 

type AccessObject_DynamicPartitionObjects struct {
	DynamicPartitionObjects *DynamicPartitionAccessObjects `protobuf:"bytes,2,opt,name=dynamic_partition_objects,json=dynamicPartitionObjects,oneof"`
}

func (*AccessObject_DynamicPartitionObjects) MarshalTo 

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

func (*AccessObject_DynamicPartitionObjects) Size 

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

type AccessObject_OtherObject 

type AccessObject_OtherObject struct {
	OtherObject string `protobuf:"bytes,3,opt,name=other_object,json=otherObject,proto3,oneof"`
}

func (*AccessObject_OtherObject) MarshalTo 

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

func (*AccessObject_OtherObject) Size 

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

type AccessObject_ScanObject 

type AccessObject_ScanObject struct {
	ScanObject *ScanAccessObject `protobuf:"bytes,1,opt,name=scan_object,json=scanObject,oneof"`
}

func (*AccessObject_ScanObject) MarshalTo 

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

func (*AccessObject_ScanObject) Size 

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

type AggFunctionMode 

type AggFunctionMode int32
const (
	AggFunctionMode_CompleteMode AggFunctionMode = 0
	AggFunctionMode_FinalMode    AggFunctionMode = 1
	AggFunctionMode_Partial1Mode AggFunctionMode = 2
	AggFunctionMode_Partial2Mode AggFunctionMode = 3
	AggFunctionMode_DedupMode    AggFunctionMode = 4
)

func (AggFunctionMode) Enum 

func (x AggFunctionMode) Enum() *AggFunctionMode

func (AggFunctionMode) EnumDescriptor 

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

func (AggFunctionMode) String 

func (x AggFunctionMode) String() string

func (*AggFunctionMode) UnmarshalJSON 

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

type Aggregation 

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

func (*Aggregation) Descriptor 

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

func (*Aggregation) GetAggFunc 

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

func (*Aggregation) GetChild 

func (m *Aggregation) GetChild() *Executor

func (*Aggregation) GetGroupBy 

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

func (*Aggregation) GetRpnAggFunc 

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

func (*Aggregation) GetRpnGroupBy 

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

func (*Aggregation) GetStreamed 

func (m *Aggregation) GetStreamed() bool

func (*Aggregation) Marshal 

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

func (*Aggregation) MarshalTo 

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

func (*Aggregation) ProtoMessage 

func (*Aggregation) ProtoMessage()

func (*Aggregation) Reset 

func (m *Aggregation) Reset()

func (*Aggregation) Size 

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

func (*Aggregation) String 

func (m *Aggregation) String() string

func (*Aggregation) Unmarshal 

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

type AnalyzeColumnGroup 

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

func (*AnalyzeColumnGroup) Descriptor 

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

func (*AnalyzeColumnGroup) GetColumnOffsets 

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

func (*AnalyzeColumnGroup) GetPrefixLengths 

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

func (*AnalyzeColumnGroup) Marshal 

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

func (*AnalyzeColumnGroup) MarshalTo 

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

func (*AnalyzeColumnGroup) ProtoMessage 

func (*AnalyzeColumnGroup) ProtoMessage()

func (*AnalyzeColumnGroup) Reset 

func (m *AnalyzeColumnGroup) Reset()

func (*AnalyzeColumnGroup) Size 

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

func (*AnalyzeColumnGroup) String 

func (m *AnalyzeColumnGroup) String() string

func (*AnalyzeColumnGroup) Unmarshal 

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

type AnalyzeColumnsReq 

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

func (*AnalyzeColumnsReq) Descriptor 

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

func (*AnalyzeColumnsReq) GetBucketSize 

func (m *AnalyzeColumnsReq) GetBucketSize() int64

func (*AnalyzeColumnsReq) GetCmsketchDepth 

func (m *AnalyzeColumnsReq) GetCmsketchDepth() int32

func (*AnalyzeColumnsReq) GetCmsketchWidth 

func (m *AnalyzeColumnsReq) GetCmsketchWidth() int32

func (*AnalyzeColumnsReq) GetColumnGroups 

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

func (*AnalyzeColumnsReq) GetColumnsInfo 

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

func (*AnalyzeColumnsReq) GetPrimaryColumnIds 

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

func (*AnalyzeColumnsReq) GetPrimaryPrefixColumnIds 

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

func (*AnalyzeColumnsReq) GetSampleRate 

func (m *AnalyzeColumnsReq) GetSampleRate() float64

func (*AnalyzeColumnsReq) GetSampleSize 

func (m *AnalyzeColumnsReq) GetSampleSize() int64

func (*AnalyzeColumnsReq) GetSketchSize 

func (m *AnalyzeColumnsReq) GetSketchSize() int64

func (*AnalyzeColumnsReq) GetVersion 

func (m *AnalyzeColumnsReq) GetVersion() int32

func (*AnalyzeColumnsReq) Marshal 

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

func (*AnalyzeColumnsReq) MarshalTo 

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

func (*AnalyzeColumnsReq) ProtoMessage 

func (*AnalyzeColumnsReq) ProtoMessage()

func (*AnalyzeColumnsReq) Reset 

func (m *AnalyzeColumnsReq) Reset()

func (*AnalyzeColumnsReq) Size 

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

func (*AnalyzeColumnsReq) String 

func (m *AnalyzeColumnsReq) String() string

func (*AnalyzeColumnsReq) Unmarshal 

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

type AnalyzeColumnsResp 

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

func (*AnalyzeColumnsResp) Descriptor 

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

func (*AnalyzeColumnsResp) GetCollectors 

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

func (*AnalyzeColumnsResp) GetPkHist 

func (m *AnalyzeColumnsResp) GetPkHist() *Histogram

func (*AnalyzeColumnsResp) GetRowCollector 

func (m *AnalyzeColumnsResp) GetRowCollector() *RowSampleCollector

func (*AnalyzeColumnsResp) Marshal 

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

func (*AnalyzeColumnsResp) MarshalTo 

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

func (*AnalyzeColumnsResp) ProtoMessage 

func (*AnalyzeColumnsResp) ProtoMessage()

func (*AnalyzeColumnsResp) Reset 

func (m *AnalyzeColumnsResp) Reset()

func (*AnalyzeColumnsResp) Size 

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

func (*AnalyzeColumnsResp) String 

func (m *AnalyzeColumnsResp) String() string

func (*AnalyzeColumnsResp) Unmarshal 

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

type AnalyzeIndexReq 

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

func (*AnalyzeIndexReq) Descriptor 

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

func (*AnalyzeIndexReq) GetBucketSize 

func (m *AnalyzeIndexReq) GetBucketSize() int64

func (*AnalyzeIndexReq) GetCmsketchDepth 

func (m *AnalyzeIndexReq) GetCmsketchDepth() int32

func (*AnalyzeIndexReq) GetCmsketchWidth 

func (m *AnalyzeIndexReq) GetCmsketchWidth() int32

func (*AnalyzeIndexReq) GetNumColumns 

func (m *AnalyzeIndexReq) GetNumColumns() int32

func (*AnalyzeIndexReq) GetSampleSize 

func (m *AnalyzeIndexReq) GetSampleSize() int64

func (*AnalyzeIndexReq) GetSketchSize 

func (m *AnalyzeIndexReq) GetSketchSize() int64

func (*AnalyzeIndexReq) GetTopNSize 

func (m *AnalyzeIndexReq) GetTopNSize() int32

func (*AnalyzeIndexReq) GetVersion 

func (m *AnalyzeIndexReq) GetVersion() int32

func (*AnalyzeIndexReq) Marshal 

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

func (*AnalyzeIndexReq) MarshalTo 

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

func (*AnalyzeIndexReq) ProtoMessage 

func (*AnalyzeIndexReq) ProtoMessage()

func (*AnalyzeIndexReq) Reset 

func (m *AnalyzeIndexReq) Reset()

func (*AnalyzeIndexReq) Size 

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

func (*AnalyzeIndexReq) String 

func (m *AnalyzeIndexReq) String() string

func (*AnalyzeIndexReq) Unmarshal 

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

type AnalyzeIndexResp 

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

func (*AnalyzeIndexResp) Descriptor 

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

func (*AnalyzeIndexResp) GetCms 

func (m *AnalyzeIndexResp) GetCms() *CMSketch

func (*AnalyzeIndexResp) GetCollector 

func (m *AnalyzeIndexResp) GetCollector() *SampleCollector

func (*AnalyzeIndexResp) GetHist 

func (m *AnalyzeIndexResp) GetHist() *Histogram

func (*AnalyzeIndexResp) Marshal 

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

func (*AnalyzeIndexResp) MarshalTo 

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

func (*AnalyzeIndexResp) ProtoMessage 

func (*AnalyzeIndexResp) ProtoMessage()

func (*AnalyzeIndexResp) Reset 

func (m *AnalyzeIndexResp) Reset()

func (*AnalyzeIndexResp) Size 

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

func (*AnalyzeIndexResp) String 

func (m *AnalyzeIndexResp) String() string

func (*AnalyzeIndexResp) Unmarshal 

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

type AnalyzeMixedResp 

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

func (*AnalyzeMixedResp) Descriptor 

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

func (*AnalyzeMixedResp) GetColumnsResp 

func (m *AnalyzeMixedResp) GetColumnsResp() *AnalyzeColumnsResp

func (*AnalyzeMixedResp) GetIndexResp 

func (m *AnalyzeMixedResp) GetIndexResp() *AnalyzeIndexResp

func (*AnalyzeMixedResp) Marshal 

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

func (*AnalyzeMixedResp) MarshalTo 

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

func (*AnalyzeMixedResp) ProtoMessage 

func (*AnalyzeMixedResp) ProtoMessage()

func (*AnalyzeMixedResp) Reset 

func (m *AnalyzeMixedResp) Reset()

func (*AnalyzeMixedResp) Size 

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

func (*AnalyzeMixedResp) String 

func (m *AnalyzeMixedResp) String() string

func (*AnalyzeMixedResp) Unmarshal 

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

type AnalyzeReq 

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

func (*AnalyzeReq) Descriptor 

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

func (*AnalyzeReq) GetColReq 

func (m *AnalyzeReq) GetColReq() *AnalyzeColumnsReq

func (*AnalyzeReq) GetFlags 

func (m *AnalyzeReq) GetFlags() uint64

func (*AnalyzeReq) GetIdxReq 

func (m *AnalyzeReq) GetIdxReq() *AnalyzeIndexReq

func (*AnalyzeReq) GetStartTsFallback 

func (m *AnalyzeReq) GetStartTsFallback() uint64

func (*AnalyzeReq) GetTimeZoneOffset 

func (m *AnalyzeReq) GetTimeZoneOffset() int64

func (*AnalyzeReq) GetTp 

func (m *AnalyzeReq) GetTp() AnalyzeType

func (*AnalyzeReq) Marshal 

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

func (*AnalyzeReq) MarshalTo 

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

func (*AnalyzeReq) ProtoMessage 

func (*AnalyzeReq) ProtoMessage()

func (*AnalyzeReq) Reset 

func (m *AnalyzeReq) Reset()

func (*AnalyzeReq) Size 

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

func (*AnalyzeReq) String 

func (m *AnalyzeReq) String() string

func (*AnalyzeReq) Unmarshal 

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

type AnalyzeType 

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

func (AnalyzeType) Enum 

func (x AnalyzeType) Enum() *AnalyzeType

func (AnalyzeType) EnumDescriptor 

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

func (AnalyzeType) String 

func (x AnalyzeType) String() string

func (*AnalyzeType) UnmarshalJSON 

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

type Bucket 

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

Bucket is an element of histogram.

func (*Bucket) Descriptor 

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

func (*Bucket) GetCount 

func (m *Bucket) GetCount() int64

func (*Bucket) GetLowerBound 

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

func (*Bucket) GetNdv 

func (m *Bucket) GetNdv() int64

func (*Bucket) GetRepeats 

func (m *Bucket) GetRepeats() int64

func (*Bucket) GetUpperBound 

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

func (*Bucket) Marshal 

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

func (*Bucket) MarshalTo 

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

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) Reset 

func (m *Bucket) Reset()

func (*Bucket) Size 

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

func (*Bucket) String 

func (m *Bucket) String() string

func (*Bucket) Unmarshal 

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

type ByItem 

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

ByItem type for group by and order by.

func (*ByItem) Descriptor 

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

func (*ByItem) GetDesc 

func (m *ByItem) GetDesc() bool

func (*ByItem) GetExpr 

func (m *ByItem) GetExpr() *Expr

func (*ByItem) GetRpnExpr 

func (m *ByItem) GetRpnExpr() *RpnExpr

func (*ByItem) Marshal 

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

func (*ByItem) MarshalTo 

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

func (*ByItem) ProtoMessage 

func (*ByItem) ProtoMessage()

func (*ByItem) Reset 

func (m *ByItem) Reset()

func (*ByItem) Size 

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

func (*ByItem) String 

func (m *ByItem) String() string

func (*ByItem) Unmarshal 

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

type CMSketch 

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

func (*CMSketch) Descriptor 

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

func (*CMSketch) GetDefaultValue 

func (m *CMSketch) GetDefaultValue() uint64

func (*CMSketch) GetRows 

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

func (*CMSketch) GetTopN 

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

func (*CMSketch) Marshal 

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

func (*CMSketch) MarshalTo 

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

func (*CMSketch) ProtoMessage 

func (*CMSketch) ProtoMessage()

func (*CMSketch) Reset 

func (m *CMSketch) Reset()

func (*CMSketch) Size 

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

func (*CMSketch) String 

func (m *CMSketch) String() string

func (*CMSketch) Unmarshal 

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

type CMSketchRow 

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

func (*CMSketchRow) Descriptor 

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

func (*CMSketchRow) GetCounters 

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

func (*CMSketchRow) Marshal 

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

func (*CMSketchRow) MarshalTo 

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

func (*CMSketchRow) ProtoMessage 

func (*CMSketchRow) ProtoMessage()

func (*CMSketchRow) Reset 

func (m *CMSketchRow) Reset()

func (*CMSketchRow) Size 

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

func (*CMSketchRow) String 

func (m *CMSketchRow) String() string

func (*CMSketchRow) Unmarshal 

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

type CMSketchTopN 

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

func (*CMSketchTopN) Descriptor 

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

func (*CMSketchTopN) GetCount 

func (m *CMSketchTopN) GetCount() uint64

func (*CMSketchTopN) GetData 

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

func (*CMSketchTopN) Marshal 

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

func (*CMSketchTopN) MarshalTo 

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

func (*CMSketchTopN) ProtoMessage 

func (*CMSketchTopN) ProtoMessage()

func (*CMSketchTopN) Reset 

func (m *CMSketchTopN) Reset()

func (*CMSketchTopN) Size 

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

func (*CMSketchTopN) String 

func (m *CMSketchTopN) String() string

func (*CMSketchTopN) Unmarshal 

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

type ChecksumAlgorithm 

type ChecksumAlgorithm int32
const (
	ChecksumAlgorithm_Crc64_Xor ChecksumAlgorithm = 0
)

func (ChecksumAlgorithm) Enum 

func (x ChecksumAlgorithm) Enum() *ChecksumAlgorithm

func (ChecksumAlgorithm) EnumDescriptor 

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

func (ChecksumAlgorithm) String 

func (x ChecksumAlgorithm) String() string

func (*ChecksumAlgorithm) UnmarshalJSON 

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

type ChecksumRequest 

type ChecksumRequest struct {
	// 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"`
	Array            bool     `protobuf:"varint,22,opt,name=array" json:"array"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ColumnInfo) Descriptor 

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

func (*ColumnInfo) GetArray 

func (m *ColumnInfo) GetArray() bool

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 CompressionMode 

type CompressionMode int32

Data compression mode 

const (
	CompressionMode_NONE             CompressionMode = 0
	CompressionMode_FAST             CompressionMode = 1
	CompressionMode_HIGH_COMPRESSION CompressionMode = 2
)

func (CompressionMode) Enum 

func (x CompressionMode) Enum() *CompressionMode

func (CompressionMode) EnumDescriptor 

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

func (CompressionMode) String 

func (x CompressionMode) String() string

func (*CompressionMode) UnmarshalJSON 

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

type DAGRequest 

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

func (m *DAGRequest) GetDivPrecisionIncrement() uint32

func (*DAGRequest) GetEncodeType 

func (m *DAGRequest) GetEncodeType() EncodeType

func (*DAGRequest) GetExecutors 

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

func (*DAGRequest) GetFlags 

func (m *DAGRequest) GetFlags() uint64

func (*DAGRequest) GetForceEncodeType 

func (m *DAGRequest) GetForceEncodeType() bool

func (*DAGRequest) GetIsRpnExpr 

func (m *DAGRequest) GetIsRpnExpr() bool

func (*DAGRequest) GetMaxAllowedPacket 

func (m *DAGRequest) GetMaxAllowedPacket() uint64

func (*DAGRequest) GetMaxWarningCount 

func (m *DAGRequest) GetMaxWarningCount() uint64

func (*DAGRequest) GetOutputOffsets 

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

func (*DAGRequest) GetRootExecutor 

func (m *DAGRequest) GetRootExecutor() *Executor

func (*DAGRequest) GetSqlMode 

func (m *DAGRequest) GetSqlMode() uint64

func (*DAGRequest) GetStartTsFallback 

func (m *DAGRequest) GetStartTsFallback() uint64

func (*DAGRequest) GetTimeZoneName 

func (m *DAGRequest) GetTimeZoneName() string

func (*DAGRequest) GetTimeZoneOffset 

func (m *DAGRequest) GetTimeZoneOffset() int64

func (*DAGRequest) GetUser 

func (m *DAGRequest) GetUser() *UserIdentity

func (*DAGRequest) Marshal 

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

func (*DAGRequest) MarshalTo 

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

func (*DAGRequest) ProtoMessage 

func (*DAGRequest) ProtoMessage()

func (*DAGRequest) Reset 

func (m *DAGRequest) Reset()

func (*DAGRequest) Size 

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

func (*DAGRequest) String 

func (m *DAGRequest) String() string

func (*DAGRequest) Unmarshal 

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

type DynamicPartitionAccessObject 

type DynamicPartitionAccessObject struct {
	Database      string   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table         string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	AllPartitions bool     `protobuf:"varint,3,opt,name=all_partitions,json=allPartitions,proto3" json:"all_partitions,omitempty"`
	Partitions    []string `protobuf:"bytes,4,rep,name=partitions" json:"partitions,omitempty"`
}

DynamicPartitionAccessObject represents the partitions accessed by the children of this operator.

func (*DynamicPartitionAccessObject) Descriptor 

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

func (*DynamicPartitionAccessObject) GetAllPartitions 

func (m *DynamicPartitionAccessObject) GetAllPartitions() bool

func (*DynamicPartitionAccessObject) GetDatabase 

func (m *DynamicPartitionAccessObject) GetDatabase() string

func (*DynamicPartitionAccessObject) GetPartitions 

func (m *DynamicPartitionAccessObject) GetPartitions() []string

func (*DynamicPartitionAccessObject) GetTable 

func (m *DynamicPartitionAccessObject) GetTable() string

func (*DynamicPartitionAccessObject) Marshal 

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

func (*DynamicPartitionAccessObject) MarshalTo 

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

func (*DynamicPartitionAccessObject) ProtoMessage 

func (*DynamicPartitionAccessObject) ProtoMessage()

func (*DynamicPartitionAccessObject) Reset 

func (m *DynamicPartitionAccessObject) Reset()

func (*DynamicPartitionAccessObject) Size 

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

func (*DynamicPartitionAccessObject) String 

func (m *DynamicPartitionAccessObject) String() string

func (*DynamicPartitionAccessObject) Unmarshal 

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

type DynamicPartitionAccessObjects 

type DynamicPartitionAccessObjects struct {
	Objects []*DynamicPartitionAccessObject `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"`
}

func (*DynamicPartitionAccessObjects) Descriptor 

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

func (*DynamicPartitionAccessObjects) GetObjects 

func (m *DynamicPartitionAccessObjects) GetObjects() []*DynamicPartitionAccessObject

func (*DynamicPartitionAccessObjects) Marshal 

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

func (*DynamicPartitionAccessObjects) MarshalTo 

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

func (*DynamicPartitionAccessObjects) ProtoMessage 

func (*DynamicPartitionAccessObjects) ProtoMessage()

func (*DynamicPartitionAccessObjects) Reset 

func (m *DynamicPartitionAccessObjects) Reset()

func (*DynamicPartitionAccessObjects) Size 

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

func (*DynamicPartitionAccessObjects) String 

func (m *DynamicPartitionAccessObjects) String() string

func (*DynamicPartitionAccessObjects) Unmarshal 

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

type EmptyResponse 

type EmptyResponse struct {
}

func (*EmptyResponse) Descriptor 

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

func (*EmptyResponse) Marshal 

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

func (*EmptyResponse) MarshalTo 

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

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset 

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size 

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

func (*EmptyResponse) String 

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal 

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

type EncodeType 

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

func (EncodeType) Enum 

func (x EncodeType) Enum() *EncodeType

func (EncodeType) EnumDescriptor 

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

func (EncodeType) String 

func (x EncodeType) String() string

func (*EncodeType) UnmarshalJSON 

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

type EncodedBytesSlice 

type EncodedBytesSlice struct {
	EncodedTasks     [][]byte `protobuf:"bytes,1,rep,name=encoded_tasks,json=encodedTasks" json:"encoded_tasks,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*EncodedBytesSlice) Descriptor 

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

func (*EncodedBytesSlice) GetEncodedTasks 

func (m *EncodedBytesSlice) GetEncodedTasks() [][]byte

func (*EncodedBytesSlice) Marshal 

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

func (*EncodedBytesSlice) MarshalTo 

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

func (*EncodedBytesSlice) ProtoMessage 

func (*EncodedBytesSlice) ProtoMessage()

func (*EncodedBytesSlice) Reset 

func (m *EncodedBytesSlice) Reset()

func (*EncodedBytesSlice) Size 

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

func (*EncodedBytesSlice) String 

func (m *EncodedBytesSlice) String() string

func (*EncodedBytesSlice) Unmarshal 

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

type Endian 

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

func (Endian) Enum 

func (x Endian) Enum() *Endian

func (Endian) EnumDescriptor 

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

func (Endian) String 

func (x Endian) String() string

func (*Endian) UnmarshalJSON 

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

type EngineType 

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

func (EngineType) Enum 

func (x EngineType) Enum() *EngineType

func (EngineType) EnumDescriptor 

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

func (EngineType) String 

func (x EngineType) String() string

func (*EngineType) UnmarshalJSON 

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

type Error 

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

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() int32

func (*Error) GetMsg 

func (m *Error) GetMsg() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

type Event 

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

func (Event) Enum 

func (x Event) Enum() *Event

func (Event) EnumDescriptor 

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

func (Event) String 

func (x Event) String() string

func (*Event) UnmarshalJSON 

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

type ExchangeReceiver 

type ExchangeReceiver struct {
	EncodedTaskMeta             [][]byte      `protobuf:"bytes,1,rep,name=encoded_task_meta,json=encodedTaskMeta" json:"encoded_task_meta,omitempty"`
	FieldTypes                  []*FieldType  `protobuf:"bytes,2,rep,name=field_types,json=fieldTypes" json:"field_types,omitempty"`
	Tp                          *ExchangeType `protobuf:"varint,3,opt,name=tp,enum=tipb.ExchangeType" json:"tp,omitempty"`
	OriginalCtePrdocuerTaskMeta [][]byte      `` /* 141-byte string literal not displayed */
	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) GetOriginalCtePrdocuerTaskMeta 

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

func (*ExchangeReceiver) GetTp 

func (m *ExchangeReceiver) GetTp() ExchangeType

func (*ExchangeReceiver) Marshal 

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

func (*ExchangeReceiver) MarshalTo 

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

func (*ExchangeReceiver) ProtoMessage 

func (*ExchangeReceiver) ProtoMessage()

func (*ExchangeReceiver) Reset 

func (m *ExchangeReceiver) Reset()

func (*ExchangeReceiver) Size 

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

func (*ExchangeReceiver) String 

func (m *ExchangeReceiver) String() string

func (*ExchangeReceiver) Unmarshal 

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

type ExchangeSender 

type ExchangeSender struct {
	Tp                  ExchangeType         `protobuf:"varint,1,opt,name=tp,enum=tipb.ExchangeType" json:"tp"`
	EncodedTaskMeta     [][]byte             `protobuf:"bytes,2,rep,name=encoded_task_meta,json=encodedTaskMeta" json:"encoded_task_meta,omitempty"`
	PartitionKeys       []*Expr              `protobuf:"bytes,3,rep,name=partition_keys,json=partitionKeys" json:"partition_keys,omitempty"`
	Child               *Executor            `protobuf:"bytes,4,opt,name=child" json:"child,omitempty"`
	Types               []*FieldType         `protobuf:"bytes,5,rep,name=types" json:"types,omitempty"`
	AllFieldTypes       []*FieldType         `protobuf:"bytes,6,rep,name=all_field_types,json=allFieldTypes" json:"all_field_types,omitempty"`
	Compression         CompressionMode      `protobuf:"varint,7,opt,name=compression,enum=tipb.CompressionMode" json:"compression"`
	UpstreamCteTaskMeta []*EncodedBytesSlice `protobuf:"bytes,8,rep,name=upstream_cte_task_meta,json=upstreamCteTaskMeta" json:"upstream_cte_task_meta,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

ExchangeSender will build connection with ExchangeReceiver.

func (*ExchangeSender) Descriptor 

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

func (*ExchangeSender) GetAllFieldTypes 

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

func (*ExchangeSender) GetChild 

func (m *ExchangeSender) GetChild() *Executor

func (*ExchangeSender) GetCompression 

func (m *ExchangeSender) GetCompression() CompressionMode

func (*ExchangeSender) GetEncodedTaskMeta 

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

func (*ExchangeSender) GetPartitionKeys 

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

func (*ExchangeSender) GetTp 

func (m *ExchangeSender) GetTp() ExchangeType

func (*ExchangeSender) GetTypes 

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

func (*ExchangeSender) GetUpstreamCteTaskMeta 

func (m *ExchangeSender) GetUpstreamCteTaskMeta() []*EncodedBytesSlice

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_TypePartitionTableScan ExecType = 12
	ExecType_TypeSort               ExecType = 13
	ExecType_TypeWindow             ExecType = 14
	ExecType_TypeExpand             ExecType = 15
	ExecType_TypeExpand2            ExecType = 16
)

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"`
	PartitionTableScan            *PartitionTableScan `protobuf:"bytes,14,opt,name=partition_table_scan,json=partitionTableScan" json:"partition_table_scan,omitempty"`
	Sort                          *Sort               `protobuf:"bytes,15,opt,name=sort" json:"sort,omitempty"`
	Window                        *Window             `protobuf:"bytes,16,opt,name=window" json:"window,omitempty"`
	FineGrainedShuffleStreamCount uint64              `` /* 139-byte string literal not displayed */
	FineGrainedShuffleBatchSize   uint64              `` /* 133-byte string literal not displayed */
	Expand                        *Expand             `protobuf:"bytes,19,opt,name=expand" json:"expand,omitempty"`
	Expand2                       *Expand2            `protobuf:"bytes,20,opt,name=expand2" json:"expand2,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) GetExpand 

func (m *Executor) GetExpand() *Expand

func (*Executor) GetExpand2 

func (m *Executor) GetExpand2() *Expand2

func (*Executor) GetFineGrainedShuffleBatchSize 

func (m *Executor) GetFineGrainedShuffleBatchSize() uint64

func (*Executor) GetFineGrainedShuffleStreamCount 

func (m *Executor) GetFineGrainedShuffleStreamCount() uint64

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

func (m *Executor) GetPartitionTableScan() *PartitionTableScan

func (*Executor) GetProjection 

func (m *Executor) GetProjection() *Projection

func (*Executor) GetSelection 

func (m *Executor) GetSelection() *Selection

func (*Executor) GetSort 

func (m *Executor) GetSort() *Sort

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

func (m *Executor) GetWindow() *Window

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"`
	// Types that are valid to be assigned to DetailInfo:
	//	*ExecutorExecutionSummary_TiflashScanContext
	DetailInfo isExecutorExecutionSummary_DetailInfo `protobuf_oneof:"DetailInfo"`
	// Serialize kvproto resource_manager.Consumption to tell tidb the consumption info. For now it's only for tiflash.
	// And it's the ru consumption of one MPPTask/cop/batchCop instead of one executor.
	RuConsumption    []byte `protobuf:"bytes,7,opt,name=ru_consumption,json=ruConsumption" json:"ru_consumption,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ExecutorExecutionSummary) Descriptor 

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

func (*ExecutorExecutionSummary) GetConcurrency 

func (m *ExecutorExecutionSummary) GetConcurrency() uint64

func (*ExecutorExecutionSummary) GetDetailInfo 

func (m *ExecutorExecutionSummary) GetDetailInfo() isExecutorExecutionSummary_DetailInfo

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

func (m *ExecutorExecutionSummary) GetRuConsumption() []byte

func (*ExecutorExecutionSummary) GetTiflashScanContext 

func (m *ExecutorExecutionSummary) GetTiflashScanContext() *TiFlashScanContext

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

func (*ExecutorExecutionSummary) XXX_OneofFuncs 

func (*ExecutorExecutionSummary) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ExecutorExecutionSummary_TiflashScanContext 

type ExecutorExecutionSummary_TiflashScanContext struct {
	TiflashScanContext *TiFlashScanContext `protobuf:"bytes,6,opt,name=tiflash_scan_context,json=tiflashScanContext,oneof"`
}

func (*ExecutorExecutionSummary_TiflashScanContext) MarshalTo 

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

func (*ExecutorExecutionSummary_TiflashScanContext) Size 

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

type Expand 

type Expand struct {
	GroupingSets     []*GroupingSet `protobuf:"bytes,1,rep,name=grouping_sets,json=groupingSets" json:"grouping_sets,omitempty"`
	Child            *Executor      `protobuf:"bytes,2,opt,name=child" json:"child,omitempty"`
	Version          *uint64        `protobuf:"varint,3,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

Deprecated in the nearly feature usage

func (*Expand) Descriptor 

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

func (*Expand) GetChild 

func (m *Expand) GetChild() *Executor

func (*Expand) GetGroupingSets 

func (m *Expand) GetGroupingSets() []*GroupingSet

func (*Expand) GetVersion 

func (m *Expand) GetVersion() uint64

func (*Expand) Marshal 

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

func (*Expand) MarshalTo 

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

func (*Expand) ProtoMessage 

func (*Expand) ProtoMessage()

func (*Expand) Reset 

func (m *Expand) Reset()

func (*Expand) Size 

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

func (*Expand) String 

func (m *Expand) String() string

func (*Expand) Unmarshal 

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

type Expand2 

type Expand2 struct {
	ProjExprs            []*ExprSlice `protobuf:"bytes,1,rep,name=proj_exprs,json=projExprs" json:"proj_exprs,omitempty"`
	GeneratedOutputNames []string     `protobuf:"bytes,2,rep,name=generated_output_names,json=generatedOutputNames" json:"generated_output_names,omitempty"`
	Child                *Executor    `protobuf:"bytes,3,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized     []byte       `json:"-"`
}

func (*Expand2) Descriptor 

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

func (*Expand2) GetChild 

func (m *Expand2) GetChild() *Executor

func (*Expand2) GetGeneratedOutputNames 

func (m *Expand2) GetGeneratedOutputNames() []string

func (*Expand2) GetProjExprs 

func (m *Expand2) GetProjExprs() []*ExprSlice

func (*Expand2) Marshal 

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

func (*Expand2) MarshalTo 

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

func (*Expand2) ProtoMessage 

func (*Expand2) ProtoMessage()

func (*Expand2) Reset 

func (m *Expand2) Reset()

func (*Expand2) Size 

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

func (*Expand2) String 

func (m *Expand2) String() string

func (*Expand2) Unmarshal 

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

type ExplainData 

type ExplainData struct {
	Main *ExplainOperator   `protobuf:"bytes,1,opt,name=main" json:"main,omitempty"`
	Ctes []*ExplainOperator `protobuf:"bytes,2,rep,name=ctes" json:"ctes,omitempty"`
	// with_runtime_stats represents if runtime stats are available.
	// If not available, the act_rows, *_exec_info, memory_bytes and disk_bytes should not be used.
	WithRuntimeStats bool `protobuf:"varint,3,opt,name=with_runtime_stats,json=withRuntimeStats,proto3" json:"with_runtime_stats,omitempty"`
	// If discarded_due_to_too_long is true. The main and ctes fields should be empty and should not be used.
	// This field can be changed to a enum or int if we need to represent more states in the future.
	DiscardedDueToTooLong bool `` /* 131-byte string literal not displayed */
}

func (*ExplainData) Descriptor 

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

func (*ExplainData) GetCtes 

func (m *ExplainData) GetCtes() []*ExplainOperator

func (*ExplainData) GetDiscardedDueToTooLong 

func (m *ExplainData) GetDiscardedDueToTooLong() bool

func (*ExplainData) GetMain 

func (m *ExplainData) GetMain() *ExplainOperator

func (*ExplainData) GetWithRuntimeStats 

func (m *ExplainData) GetWithRuntimeStats() bool

func (*ExplainData) Marshal 

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

func (*ExplainData) MarshalTo 

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

func (*ExplainData) ProtoMessage 

func (*ExplainData) ProtoMessage()

func (*ExplainData) Reset 

func (m *ExplainData) Reset()

func (*ExplainData) Size 

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

func (*ExplainData) String 

func (m *ExplainData) String() string

func (*ExplainData) Unmarshal 

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

type ExplainOperator 

type ExplainOperator struct {
	Name     string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Children []*ExplainOperator `protobuf:"bytes,2,rep,name=children" json:"children,omitempty"`
	Labels   []OperatorLabel    `protobuf:"varint,3,rep,packed,name=labels,enum=tipb.OperatorLabel" json:"labels,omitempty"`
	// the cost of the current operator
	Cost      float64   `protobuf:"fixed64,4,opt,name=cost,proto3" json:"cost,omitempty"`
	EstRows   float64   `protobuf:"fixed64,5,opt,name=est_rows,json=estRows,proto3" json:"est_rows,omitempty"`
	ActRows   uint64    `protobuf:"varint,6,opt,name=act_rows,json=actRows,proto3" json:"act_rows,omitempty"`
	TaskType  TaskType  `protobuf:"varint,7,opt,name=task_type,json=taskType,proto3,enum=tipb.TaskType" json:"task_type,omitempty"`
	StoreType StoreType `protobuf:"varint,8,opt,name=store_type,json=storeType,proto3,enum=tipb.StoreType" json:"store_type,omitempty"`
	// The XXXReader/XXXScan/MemTable/PointGet/BatchPointGet may use this
	AccessObjects     []*AccessObject `protobuf:"bytes,9,rep,name=access_objects,json=accessObjects" json:"access_objects,omitempty"`
	OperatorInfo      string          `protobuf:"bytes,10,opt,name=operator_info,json=operatorInfo,proto3" json:"operator_info,omitempty"`
	RootBasicExecInfo string          `protobuf:"bytes,11,opt,name=root_basic_exec_info,json=rootBasicExecInfo,proto3" json:"root_basic_exec_info,omitempty"`
	RootGroupExecInfo []string        `protobuf:"bytes,12,rep,name=root_group_exec_info,json=rootGroupExecInfo" json:"root_group_exec_info,omitempty"`
	CopExecInfo       string          `protobuf:"bytes,13,opt,name=cop_exec_info,json=copExecInfo,proto3" json:"cop_exec_info,omitempty"`
	// memory_bytes and disk_bytes are expected to be displayed as "N/A" when they are -1,
	// this will be consistent with the result of EXPLAIN ANALYZE.
	MemoryBytes int64 `protobuf:"varint,14,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	DiskBytes   int64 `protobuf:"varint,15,opt,name=disk_bytes,json=diskBytes,proto3" json:"disk_bytes,omitempty"`
}

func (*ExplainOperator) Descriptor 

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

func (*ExplainOperator) GetAccessObjects 

func (m *ExplainOperator) GetAccessObjects() []*AccessObject

func (*ExplainOperator) GetActRows 

func (m *ExplainOperator) GetActRows() uint64

func (*ExplainOperator) GetChildren 

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

func (*ExplainOperator) GetCopExecInfo 

func (m *ExplainOperator) GetCopExecInfo() string

func (*ExplainOperator) GetCost 

func (m *ExplainOperator) GetCost() float64

func (*ExplainOperator) GetDiskBytes 

func (m *ExplainOperator) GetDiskBytes() int64

func (*ExplainOperator) GetEstRows 

func (m *ExplainOperator) GetEstRows() float64

func (*ExplainOperator) GetLabels 

func (m *ExplainOperator) GetLabels() []OperatorLabel

func (*ExplainOperator) GetMemoryBytes 

func (m *ExplainOperator) GetMemoryBytes() int64

func (*ExplainOperator) GetName 

func (m *ExplainOperator) GetName() string

func (*ExplainOperator) GetOperatorInfo 

func (m *ExplainOperator) GetOperatorInfo() string

func (*ExplainOperator) GetRootBasicExecInfo 

func (m *ExplainOperator) GetRootBasicExecInfo() string

func (*ExplainOperator) GetRootGroupExecInfo 

func (m *ExplainOperator) GetRootGroupExecInfo() []string

func (*ExplainOperator) GetStoreType 

func (m *ExplainOperator) GetStoreType() StoreType

func (*ExplainOperator) GetTaskType 

func (m *ExplainOperator) GetTaskType() TaskType

func (*ExplainOperator) Marshal 

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

func (*ExplainOperator) MarshalTo 

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

func (*ExplainOperator) ProtoMessage 

func (*ExplainOperator) ProtoMessage()

func (*ExplainOperator) Reset 

func (m *ExplainOperator) Reset()

func (*ExplainOperator) Size 

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

func (*ExplainOperator) String 

func (m *ExplainOperator) String() string

func (*ExplainOperator) Unmarshal 

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

type Expr 

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

Evaluators should implement evaluation functions for every expression type.

func (*Expr) Descriptor 

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

func (*Expr) GetAggFuncMode 

func (m *Expr) GetAggFuncMode() AggFunctionMode

func (*Expr) GetChildren 

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

func (*Expr) GetFieldType 

func (m *Expr) GetFieldType() *FieldType

func (*Expr) GetHasDistinct 

func (m *Expr) GetHasDistinct() bool

func (*Expr) GetOrderBy 

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

func (*Expr) GetRpnArgsLen 

func (m *Expr) GetRpnArgsLen() uint32

func (*Expr) GetSig 

func (m *Expr) GetSig() ScalarFuncSig

func (*Expr) GetTp 

func (m *Expr) GetTp() ExprType

func (*Expr) GetVal 

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

func (*Expr) Marshal 

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

func (*Expr) MarshalTo 

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

func (*Expr) ProtoMessage 

func (*Expr) ProtoMessage()

func (*Expr) Reset 

func (m *Expr) Reset()

func (*Expr) Size 

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

func (*Expr) String 

func (m *Expr) String() string

func (*Expr) Unmarshal 

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

type ExprSlice 

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

func (*ExprSlice) Descriptor 

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

func (*ExprSlice) GetExprs 

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

func (*ExprSlice) Marshal 

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

func (*ExprSlice) MarshalTo 

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

func (*ExprSlice) ProtoMessage 

func (*ExprSlice) ProtoMessage()

func (*ExprSlice) Reset 

func (m *ExprSlice) Reset()

func (*ExprSlice) Size 

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

func (*ExprSlice) String 

func (m *ExprSlice) String() string

func (*ExprSlice) Unmarshal 

func (m *ExprSlice) 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
	ExprType_TiDBVectorFloat32 ExprType = 121
	// 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
	// Window functions
	ExprType_RowNumber   ExprType = 4001
	ExprType_Rank        ExprType = 4002
	ExprType_DenseRank   ExprType = 4003
	ExprType_CumeDist    ExprType = 4004
	ExprType_PercentRank ExprType = 4005
	ExprType_Ntile       ExprType = 4006
	ExprType_Lead        ExprType = 4007
	ExprType_Lag         ExprType = 4008
	ExprType_FirstValue  ExprType = 4009
	ExprType_LastValue   ExprType = 4010
	ExprType_NthValue    ExprType = 4011
	// Scalar Function
	ExprType_ScalarFunc ExprType = 10000
)

func (ExprType) Enum 

func (x ExprType) Enum() *ExprType

func (ExprType) EnumDescriptor 

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

func (ExprType) String 

func (x ExprType) String() string

func (*ExprType) UnmarshalJSON 

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

type FMSketch 

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

FMSketch is used to count distinct values for columns.

func (*FMSketch) Descriptor 

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

func (*FMSketch) GetHashset 

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

func (*FMSketch) GetMask 

func (m *FMSketch) GetMask() uint64

func (*FMSketch) Marshal 

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

func (*FMSketch) MarshalTo 

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

func (*FMSketch) ProtoMessage 

func (*FMSketch) ProtoMessage()

func (*FMSketch) Reset 

func (m *FMSketch) Reset()

func (*FMSketch) Size 

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

func (*FMSketch) String 

func (m *FMSketch) String() string

func (*FMSketch) Unmarshal 

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

type FieldType 

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

func (*FieldType) Descriptor 

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

func (*FieldType) GetArray 

func (m *FieldType) GetArray() bool

func (*FieldType) GetCharset 

func (m *FieldType) GetCharset() string

func (*FieldType) GetCollate 

func (m *FieldType) GetCollate() int32

func (*FieldType) GetDecimal 

func (m *FieldType) GetDecimal() int32

func (*FieldType) GetElems 

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

func (*FieldType) GetFlag 

func (m *FieldType) GetFlag() uint32

func (*FieldType) GetFlen 

func (m *FieldType) GetFlen() int32

func (*FieldType) GetTp 

func (m *FieldType) GetTp() int32

func (*FieldType) Marshal 

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

func (*FieldType) MarshalTo 

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

func (*FieldType) ProtoMessage 

func (*FieldType) ProtoMessage()

func (*FieldType) Reset 

func (m *FieldType) Reset()

func (*FieldType) Size 

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

func (*FieldType) String 

func (m *FieldType) String() string

func (*FieldType) Unmarshal 

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

type GroupingExpr 

type GroupingExpr struct {
	GroupingExpr     []*Expr `protobuf:"bytes,1,rep,name=grouping_expr,json=groupingExpr" json:"grouping_expr,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GroupingExpr) Descriptor 

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

func (*GroupingExpr) GetGroupingExpr 

func (m *GroupingExpr) GetGroupingExpr() []*Expr

func (*GroupingExpr) Marshal 

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

func (*GroupingExpr) MarshalTo 

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

func (*GroupingExpr) ProtoMessage 

func (*GroupingExpr) ProtoMessage()

func (*GroupingExpr) Reset 

func (m *GroupingExpr) Reset()

func (*GroupingExpr) Size 

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

func (*GroupingExpr) String 

func (m *GroupingExpr) String() string

func (*GroupingExpr) Unmarshal 

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

type GroupingFunctionMetadata 

type GroupingFunctionMetadata struct {
	Mode *GroupingMode `protobuf:"varint,1,req,name=mode,enum=tipb.GroupingMode" json:"mode,omitempty"`
	// 2 dimension here, out-most dimension is for grouping(a,b) = grouping(a) << 1 + grouping(b); we should maintain a slice of grouping mark.
	GroupingMarks    []*GroupingMark `protobuf:"bytes,2,rep,name=grouping_marks,json=groupingMarks" json:"grouping_marks,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*GroupingFunctionMetadata) Descriptor 

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

func (*GroupingFunctionMetadata) GetGroupingMarks 

func (m *GroupingFunctionMetadata) GetGroupingMarks() []*GroupingMark

func (*GroupingFunctionMetadata) GetMode 

func (m *GroupingFunctionMetadata) GetMode() GroupingMode

func (*GroupingFunctionMetadata) Marshal 

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

func (*GroupingFunctionMetadata) MarshalTo 

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

func (*GroupingFunctionMetadata) ProtoMessage 

func (*GroupingFunctionMetadata) ProtoMessage()

func (*GroupingFunctionMetadata) Reset 

func (m *GroupingFunctionMetadata) Reset()

func (*GroupingFunctionMetadata) Size 

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

func (*GroupingFunctionMetadata) String 

func (m *GroupingFunctionMetadata) String() string

func (*GroupingFunctionMetadata) Unmarshal 

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

type GroupingMark 

type GroupingMark struct {
	GroupingNums     []uint64 `protobuf:"varint,1,rep,name=grouping_nums,json=groupingNums" json:"grouping_nums,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GroupingMark) Descriptor 

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

func (*GroupingMark) GetGroupingNums 

func (m *GroupingMark) GetGroupingNums() []uint64

func (*GroupingMark) Marshal 

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

func (*GroupingMark) MarshalTo 

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

func (*GroupingMark) ProtoMessage 

func (*GroupingMark) ProtoMessage()

func (*GroupingMark) Reset 

func (m *GroupingMark) Reset()

func (*GroupingMark) Size 

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

func (*GroupingMark) String 

func (m *GroupingMark) String() string

func (*GroupingMark) Unmarshal 

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

type GroupingMode 

type GroupingMode int32
const (
	GroupingMode_ModeBitAnd     GroupingMode = 1
	GroupingMode_ModeNumericCmp GroupingMode = 2
	GroupingMode_ModeNumericSet GroupingMode = 3
)

func (GroupingMode) Enum 

func (x GroupingMode) Enum() *GroupingMode

func (GroupingMode) EnumDescriptor 

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

func (GroupingMode) String 

func (x GroupingMode) String() string

func (*GroupingMode) UnmarshalJSON 

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

type GroupingSet 

type GroupingSet struct {
	GroupingExprs    []*GroupingExpr `protobuf:"bytes,1,rep,name=grouping_exprs,json=groupingExprs" json:"grouping_exprs,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*GroupingSet) Descriptor 

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

func (*GroupingSet) GetGroupingExprs 

func (m *GroupingSet) GetGroupingExprs() []*GroupingExpr

func (*GroupingSet) Marshal 

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

func (*GroupingSet) MarshalTo 

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

func (*GroupingSet) ProtoMessage 

func (*GroupingSet) ProtoMessage()

func (*GroupingSet) Reset 

func (m *GroupingSet) Reset()

func (*GroupingSet) Size 

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

func (*GroupingSet) String 

func (m *GroupingSet) String() string

func (*GroupingSet) Unmarshal 

func (m *GroupingSet) 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 IndexAccess 

type IndexAccess struct {
	Name             string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Cols             []string `protobuf:"bytes,2,rep,name=cols" json:"cols,omitempty"`
	IsClusteredIndex bool     `protobuf:"varint,3,opt,name=is_clustered_index,json=isClusteredIndex,proto3" json:"is_clustered_index,omitempty"`
}

func (*IndexAccess) Descriptor 

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

func (*IndexAccess) GetCols 

func (m *IndexAccess) GetCols() []string

func (*IndexAccess) GetIsClusteredIndex 

func (m *IndexAccess) GetIsClusteredIndex() bool

func (*IndexAccess) GetName 

func (m *IndexAccess) GetName() string

func (*IndexAccess) Marshal 

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

func (*IndexAccess) MarshalTo 

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

func (*IndexAccess) ProtoMessage 

func (*IndexAccess) ProtoMessage()

func (*IndexAccess) Reset 

func (m *IndexAccess) Reset()

func (*IndexAccess) Size 

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

func (*IndexAccess) String 

func (m *IndexAccess) String() string

func (*IndexAccess) Unmarshal 

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

type IndexInfo 

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

func (*IndexInfo) Descriptor 

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

func (*IndexInfo) GetColumns 

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

func (*IndexInfo) GetIndexId 

func (m *IndexInfo) GetIndexId() int64

func (*IndexInfo) GetTableId 

func (m *IndexInfo) GetTableId() int64

func (*IndexInfo) GetUnique 

func (m *IndexInfo) GetUnique() bool

func (*IndexInfo) Marshal 

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

func (*IndexInfo) MarshalTo 

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

func (*IndexInfo) ProtoMessage 

func (*IndexInfo) ProtoMessage()

func (*IndexInfo) Reset 

func (m *IndexInfo) Reset()

func (*IndexInfo) Size 

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

func (*IndexInfo) String 

func (m *IndexInfo) String() string

func (*IndexInfo) Unmarshal 

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

type IndexScan 

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

func (*IndexScan) Descriptor 

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

func (*IndexScan) GetColumns 

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

func (*IndexScan) GetDesc 

func (m *IndexScan) GetDesc() bool

func (*IndexScan) GetIndexId 

func (m *IndexScan) GetIndexId() int64

func (*IndexScan) GetPrimaryColumnIds 

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

func (*IndexScan) GetTableId 

func (m *IndexScan) GetTableId() int64

func (*IndexScan) GetUnique 

func (m *IndexScan) GetUnique() bool

func (*IndexScan) Marshal 

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

func (*IndexScan) MarshalTo 

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

func (*IndexScan) ProtoMessage 

func (*IndexScan) ProtoMessage()

func (*IndexScan) Reset 

func (m *IndexScan) Reset()

func (*IndexScan) Size 

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

func (*IndexScan) String 

func (m *IndexScan) String() string

func (*IndexScan) Unmarshal 

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

type Join 

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

func (m *Join) GetIsNullAwareSemiJoin() bool

func (*Join) GetJoinExecType 

func (m *Join) GetJoinExecType() JoinExecType

func (*Join) GetJoinType 

func (m *Join) GetJoinType() JoinType

func (*Join) GetLeftConditions 

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

func (*Join) GetLeftJoinKeys 

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

func (*Join) GetOtherConditions 

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

func (*Join) GetOtherEqConditionsFromIn 

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

func (*Join) GetProbeTypes 

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

func (*Join) GetRightConditions 

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

func (*Join) GetRightJoinKeys 

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

func (*Join) GetRuntimeFilterList 

func (m *Join) GetRuntimeFilterList() []*RuntimeFilter

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"`
	// If partition_by is not empty, it means need to return limitN of each partition.
	// Generally used in sqls like `where row_number() over (partition by ...) < X`
	PartitionBy      []*ByItem `protobuf:"bytes,3,rep,name=partition_by,json=partitionBy" json:"partition_by,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) GetPartitionBy 

func (m *Limit) GetPartitionBy() []*ByItem

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 OperatorLabel 

type OperatorLabel int32
const (
	// empty is not expected to be used.
	OperatorLabel_empty         OperatorLabel = 0
	OperatorLabel_buildSide     OperatorLabel = 1
	OperatorLabel_probeSide     OperatorLabel = 2
	OperatorLabel_seedPart      OperatorLabel = 3
	OperatorLabel_recursivePart OperatorLabel = 4
)

func (OperatorLabel) EnumDescriptor 

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

func (OperatorLabel) String 

func (x OperatorLabel) String() string

type PartitionTableScan 

type PartitionTableScan 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"`
	PrimaryPrefixColumnIds     []int64          `protobuf:"varint,5,rep,name=primary_prefix_column_ids,json=primaryPrefixColumnIds" json:"primary_prefix_column_ids,omitempty"`
	PartitionIds               []int64          `protobuf:"varint,6,rep,name=partition_ids,json=partitionIds" json:"partition_ids,omitempty"`
	IsFastScan                 *bool            `protobuf:"varint,7,opt,name=is_fast_scan,json=isFastScan" json:"is_fast_scan,omitempty"`
	PushedDownFilterConditions []*Expr          `` /* 136-byte string literal not displayed */
	AnnQuery                   *ANNQueryInfo    `protobuf:"bytes,11,opt,name=ann_query,json=annQuery" json:"ann_query,omitempty"`
	RuntimeFilterList          []*RuntimeFilter `protobuf:"bytes,9,rep,name=runtime_filter_list,json=runtimeFilterList" json:"runtime_filter_list,omitempty"`
	MaxWaitTimeMs              int32            `protobuf:"varint,10,opt,name=max_wait_time_ms,json=maxWaitTimeMs" json:"max_wait_time_ms"`
	XXX_unrecognized           []byte           `json:"-"`
}

func (*PartitionTableScan) Descriptor 

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

func (*PartitionTableScan) GetAnnQuery 

func (m *PartitionTableScan) GetAnnQuery() *ANNQueryInfo

func (*PartitionTableScan) GetColumns 

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

func (*PartitionTableScan) GetDesc 

func (m *PartitionTableScan) GetDesc() bool

func (*PartitionTableScan) GetIsFastScan 

func (m *PartitionTableScan) GetIsFastScan() bool

func (*PartitionTableScan) GetMaxWaitTimeMs 

func (m *PartitionTableScan) GetMaxWaitTimeMs() int32

func (*PartitionTableScan) GetPartitionIds 

func (m *PartitionTableScan) GetPartitionIds() []int64

func (*PartitionTableScan) GetPrimaryColumnIds 

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

func (*PartitionTableScan) GetPrimaryPrefixColumnIds 

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

func (*PartitionTableScan) GetPushedDownFilterConditions 

func (m *PartitionTableScan) GetPushedDownFilterConditions() []*Expr

func (*PartitionTableScan) GetRuntimeFilterList 

func (m *PartitionTableScan) GetRuntimeFilterList() []*RuntimeFilter

func (*PartitionTableScan) GetTableId 

func (m *PartitionTableScan) GetTableId() int64

func (*PartitionTableScan) Marshal 

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

func (*PartitionTableScan) MarshalTo 

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

func (*PartitionTableScan) ProtoMessage 

func (*PartitionTableScan) ProtoMessage()

func (*PartitionTableScan) Reset 

func (m *PartitionTableScan) Reset()

func (*PartitionTableScan) Size 

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

func (*PartitionTableScan) String 

func (m *PartitionTableScan) String() string

func (*PartitionTableScan) Unmarshal 

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

type PlanMeta 

type PlanMeta struct {
	PlanDigest []byte `protobuf:"bytes,1,opt,name=plan_digest,json=planDigest,proto3" json:"plan_digest,omitempty"`
	// Plan text with sensitive fields trimmed.
	//
	// Producers should limit the size to less than 4KiB. Consider use `encoded_normalized_plan` if the size exceeds.
	NormalizedPlan string `protobuf:"bytes,2,opt,name=normalized_plan,json=normalizedPlan,proto3" json:"normalized_plan,omitempty"`
	// If `normalized_plan` is unacceptably large, set `encoded_normalized_plan` instead.
	//
	// The textual normalized plan is expected to get by following steps:
	// 1. decode from base64
	// 2. decode from snappy
	// 3. decode from github.com/pingcap/tidb/util/plancodec.DecodeNormalizedPlan
	EncodedNormalizedPlan string `` /* 126-byte string literal not displayed */
}

func (*PlanMeta) Descriptor 

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

func (*PlanMeta) GetEncodedNormalizedPlan 

func (m *PlanMeta) GetEncodedNormalizedPlan() string

func (*PlanMeta) GetNormalizedPlan 

func (m *PlanMeta) GetNormalizedPlan() string

func (*PlanMeta) GetPlanDigest 

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

func (*PlanMeta) Marshal 

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

func (*PlanMeta) MarshalTo 

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

func (*PlanMeta) ProtoMessage 

func (*PlanMeta) ProtoMessage()

func (*PlanMeta) Reset 

func (m *PlanMeta) Reset()

func (*PlanMeta) Size 

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

func (*PlanMeta) String 

func (m *PlanMeta) String() string

func (*PlanMeta) Unmarshal 

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

type Projection 

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

func (*Projection) Descriptor 

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

func (*Projection) GetChild 

func (m *Projection) GetChild() *Executor

func (*Projection) GetExprs 

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

func (*Projection) GetRpnExprs 

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

func (*Projection) Marshal 

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

func (*Projection) MarshalTo 

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

func (*Projection) ProtoMessage 

func (*Projection) ProtoMessage()

func (*Projection) Reset 

func (m *Projection) Reset()

func (*Projection) Size 

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

func (*Projection) String 

func (m *Projection) String() string

func (*Projection) Unmarshal 

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

type RangeCmpDataType 

type RangeCmpDataType int32

Used for range frame's comparison when finding frame's boundary 

const (
	RangeCmpDataType_Int      RangeCmpDataType = 0
	RangeCmpDataType_Float    RangeCmpDataType = 1
	RangeCmpDataType_Decimal  RangeCmpDataType = 2
	RangeCmpDataType_DateTime RangeCmpDataType = 3
	RangeCmpDataType_Duration RangeCmpDataType = 4
)

func (RangeCmpDataType) Enum 

func (x RangeCmpDataType) Enum() *RangeCmpDataType

func (RangeCmpDataType) EnumDescriptor 

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

func (RangeCmpDataType) String 

func (x RangeCmpDataType) String() string

func (*RangeCmpDataType) UnmarshalJSON 

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

type ResourceGroupTag 

type ResourceGroupTag struct {
	SqlDigest  []byte `protobuf:"bytes,1,opt,name=sql_digest,json=sqlDigest" json:"sql_digest,omitempty"`
	PlanDigest []byte `protobuf:"bytes,2,opt,name=plan_digest,json=planDigest" json:"plan_digest,omitempty"`
	// Use to label the handling kv type of the request.
	// This is for TiKV resource_metering to collect execution information by the key label.
	Label            *ResourceGroupTagLabel `protobuf:"varint,3,opt,name=label,enum=tipb.ResourceGroupTagLabel" json:"label,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*ResourceGroupTag) Descriptor 

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

func (*ResourceGroupTag) GetLabel 

func (m *ResourceGroupTag) GetLabel() ResourceGroupTagLabel

func (*ResourceGroupTag) GetPlanDigest 

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

func (*ResourceGroupTag) GetSqlDigest 

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

func (*ResourceGroupTag) Marshal 

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

func (*ResourceGroupTag) MarshalTo 

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

func (*ResourceGroupTag) ProtoMessage 

func (*ResourceGroupTag) ProtoMessage()

func (*ResourceGroupTag) Reset 

func (m *ResourceGroupTag) Reset()

func (*ResourceGroupTag) Size 

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

func (*ResourceGroupTag) String 

func (m *ResourceGroupTag) String() string

func (*ResourceGroupTag) Unmarshal 

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

type ResourceGroupTagLabel 

type ResourceGroupTagLabel int32
const (
	ResourceGroupTagLabel_ResourceGroupTagLabelUnknown ResourceGroupTagLabel = 0
	ResourceGroupTagLabel_ResourceGroupTagLabelRow     ResourceGroupTagLabel = 1
	ResourceGroupTagLabel_ResourceGroupTagLabelIndex   ResourceGroupTagLabel = 2
)

func (ResourceGroupTagLabel) Enum 

func (x ResourceGroupTagLabel) Enum() *ResourceGroupTagLabel

func (ResourceGroupTagLabel) EnumDescriptor 

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

func (ResourceGroupTagLabel) String 

func (x ResourceGroupTagLabel) String() string

func (*ResourceGroupTagLabel) UnmarshalJSON 

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

type Row 

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

values are all in text format.

func (*Row) Descriptor 

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

func (*Row) GetData 

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

func (*Row) GetHandle 

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

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

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

func (*Row) String 

func (m *Row) String() string

func (*Row) Unmarshal 

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

type RowMeta 

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

RowMeta contains row handle and length of a row.

func (*RowMeta) Descriptor 

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

func (*RowMeta) GetHandle 

func (m *RowMeta) GetHandle() int64

func (*RowMeta) GetLength 

func (m *RowMeta) GetLength() int64

func (*RowMeta) Marshal 

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

func (*RowMeta) MarshalTo 

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

func (*RowMeta) ProtoMessage 

func (*RowMeta) ProtoMessage()

func (*RowMeta) Reset 

func (m *RowMeta) Reset()

func (*RowMeta) Size 

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

func (*RowMeta) String 

func (m *RowMeta) String() string

func (*RowMeta) Unmarshal 

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

type RowSample 

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

func (*RowSample) Descriptor 

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

func (*RowSample) GetRow 

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

func (*RowSample) GetWeight 

func (m *RowSample) GetWeight() int64

func (*RowSample) Marshal 

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

func (*RowSample) MarshalTo 

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

func (*RowSample) ProtoMessage 

func (*RowSample) ProtoMessage()

func (*RowSample) Reset 

func (m *RowSample) Reset()

func (*RowSample) Size 

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

func (*RowSample) String 

func (m *RowSample) String() string

func (*RowSample) Unmarshal 

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

type RowSampleCollector 

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

func (*RowSampleCollector) Descriptor 

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

func (*RowSampleCollector) GetCount 

func (m *RowSampleCollector) GetCount() int64

func (*RowSampleCollector) GetFmSketch 

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

func (*RowSampleCollector) GetNullCounts 

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

func (*RowSampleCollector) GetSamples 

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

func (*RowSampleCollector) GetTotalSize 

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

func (*RowSampleCollector) Marshal 

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

func (*RowSampleCollector) MarshalTo 

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

func (*RowSampleCollector) ProtoMessage 

func (*RowSampleCollector) ProtoMessage()

func (*RowSampleCollector) Reset 

func (m *RowSampleCollector) Reset()

func (*RowSampleCollector) Size 

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

func (*RowSampleCollector) String 

func (m *RowSampleCollector) String() string

func (*RowSampleCollector) Unmarshal 

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

type RpnExpr 

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

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

func (*RpnExpr) Descriptor 

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

func (*RpnExpr) GetExprs 

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

func (*RpnExpr) Marshal 

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

func (*RpnExpr) MarshalTo 

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

func (*RpnExpr) ProtoMessage 

func (*RpnExpr) ProtoMessage()

func (*RpnExpr) Reset 

func (m *RpnExpr) Reset()

func (*RpnExpr) Size 

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

func (*RpnExpr) String 

func (m *RpnExpr) String() string

func (*RpnExpr) Unmarshal 

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

type RuntimeFilter 

type RuntimeFilter struct {
	Id               int32             `protobuf:"varint,1,opt,name=id" json:"id"`
	SourceExprList   []*Expr           `protobuf:"bytes,2,rep,name=source_expr_list,json=sourceExprList" json:"source_expr_list,omitempty"`
	TargetExprList   []*Expr           `protobuf:"bytes,3,rep,name=target_expr_list,json=targetExprList" json:"target_expr_list,omitempty"`
	SourceExecutorId string            `protobuf:"bytes,4,opt,name=source_executor_id,json=sourceExecutorId" json:"source_executor_id"`
	TargetExecutorId string            `protobuf:"bytes,5,opt,name=target_executor_id,json=targetExecutorId" json:"target_executor_id"`
	RfType           RuntimeFilterType `protobuf:"varint,6,opt,name=rf_type,json=rfType,enum=tipb.RuntimeFilterType" json:"rf_type"`
	RfMode           RuntimeFilterMode `protobuf:"varint,7,opt,name=rf_mode,json=rfMode,enum=tipb.RuntimeFilterMode" json:"rf_mode"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*RuntimeFilter) Descriptor 

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

func (*RuntimeFilter) GetId 

func (m *RuntimeFilter) GetId() int32

func (*RuntimeFilter) GetRfMode 

func (m *RuntimeFilter) GetRfMode() RuntimeFilterMode

func (*RuntimeFilter) GetRfType 

func (m *RuntimeFilter) GetRfType() RuntimeFilterType

func (*RuntimeFilter) GetSourceExecutorId 

func (m *RuntimeFilter) GetSourceExecutorId() string

func (*RuntimeFilter) GetSourceExprList 

func (m *RuntimeFilter) GetSourceExprList() []*Expr

func (*RuntimeFilter) GetTargetExecutorId 

func (m *RuntimeFilter) GetTargetExecutorId() string

func (*RuntimeFilter) GetTargetExprList 

func (m *RuntimeFilter) GetTargetExprList() []*Expr

func (*RuntimeFilter) Marshal 

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

func (*RuntimeFilter) MarshalTo 

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

func (*RuntimeFilter) ProtoMessage 

func (*RuntimeFilter) ProtoMessage()

func (*RuntimeFilter) Reset 

func (m *RuntimeFilter) Reset()

func (*RuntimeFilter) Size 

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

func (*RuntimeFilter) String 

func (m *RuntimeFilter) String() string

func (*RuntimeFilter) Unmarshal 

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

type RuntimeFilterMode 

type RuntimeFilterMode int32
const (
	RuntimeFilterMode_LOCAL  RuntimeFilterMode = 0
	RuntimeFilterMode_GLOBAL RuntimeFilterMode = 1
)

func (RuntimeFilterMode) Enum 

func (x RuntimeFilterMode) Enum() *RuntimeFilterMode

func (RuntimeFilterMode) EnumDescriptor 

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

func (RuntimeFilterMode) String 

func (x RuntimeFilterMode) String() string

func (*RuntimeFilterMode) UnmarshalJSON 

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

type RuntimeFilterType 

type RuntimeFilterType int32
const (
	RuntimeFilterType_IN           RuntimeFilterType = 0
	RuntimeFilterType_MIN_MAX      RuntimeFilterType = 1
	RuntimeFilterType_BLOOM_FILTER RuntimeFilterType = 2
)

func (RuntimeFilterType) Enum 

func (x RuntimeFilterType) Enum() *RuntimeFilterType

func (RuntimeFilterType) EnumDescriptor 

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

func (RuntimeFilterType) String 

func (x RuntimeFilterType) String() string

func (*RuntimeFilterType) UnmarshalJSON 

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

type SQLMeta 

type SQLMeta struct {
	SqlDigest []byte `protobuf:"bytes,1,opt,name=sql_digest,json=sqlDigest,proto3" json:"sql_digest,omitempty"`
	// SQL text with sensitive fields trimmed.
	//
	// Producers should limit the size to less than 4KiB. Truncation can be chosen to reduce size.
	NormalizedSql string `protobuf:"bytes,2,opt,name=normalized_sql,json=normalizedSql,proto3" json:"normalized_sql,omitempty"`
	// If true, this sql and plan is internally generated by tidb itself, not user.
	IsInternalSql bool `protobuf:"varint,3,opt,name=is_internal_sql,json=isInternalSql,proto3" json:"is_internal_sql,omitempty"`
}

func (*SQLMeta) Descriptor 

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

func (*SQLMeta) GetIsInternalSql 

func (m *SQLMeta) GetIsInternalSql() bool

func (*SQLMeta) GetNormalizedSql 

func (m *SQLMeta) GetNormalizedSql() string

func (*SQLMeta) GetSqlDigest 

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

func (*SQLMeta) Marshal 

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

func (*SQLMeta) MarshalTo 

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

func (*SQLMeta) ProtoMessage 

func (*SQLMeta) ProtoMessage()

func (*SQLMeta) Reset 

func (m *SQLMeta) Reset()

func (*SQLMeta) Size 

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

func (*SQLMeta) String 

func (m *SQLMeta) String() string

func (*SQLMeta) Unmarshal 

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

type SampleCollector 

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

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

func (*SampleCollector) Descriptor 

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

func (*SampleCollector) GetCmSketch 

func (m *SampleCollector) GetCmSketch() *CMSketch

func (*SampleCollector) GetCount 

func (m *SampleCollector) GetCount() int64

func (*SampleCollector) GetFmSketch 

func (m *SampleCollector) GetFmSketch() *FMSketch

func (*SampleCollector) GetNullCount 

func (m *SampleCollector) GetNullCount() int64

func (*SampleCollector) GetSamples 

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

func (*SampleCollector) GetTotalSize 

func (m *SampleCollector) GetTotalSize() int64

func (*SampleCollector) Marshal 

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

func (*SampleCollector) MarshalTo 

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

func (*SampleCollector) ProtoMessage 

func (*SampleCollector) ProtoMessage()

func (*SampleCollector) Reset 

func (m *SampleCollector) Reset()

func (*SampleCollector) Size 

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

func (*SampleCollector) String 

func (m *SampleCollector) String() string

func (*SampleCollector) Unmarshal 

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

type ScalarFuncSig 

type ScalarFuncSig int32
const (
	ScalarFuncSig_Unspecified ScalarFuncSig = 0
	// Casting
	ScalarFuncSig_CastIntAsInt           ScalarFuncSig = 1
	ScalarFuncSig_CastIntAsReal          ScalarFuncSig = 2
	ScalarFuncSig_CastIntAsString        ScalarFuncSig = 3
	ScalarFuncSig_CastIntAsDecimal       ScalarFuncSig = 4
	ScalarFuncSig_CastIntAsTime          ScalarFuncSig = 5
	ScalarFuncSig_CastIntAsDuration      ScalarFuncSig = 6
	ScalarFuncSig_CastIntAsJson          ScalarFuncSig = 7
	ScalarFuncSig_CastRealAsInt          ScalarFuncSig = 10
	ScalarFuncSig_CastRealAsReal         ScalarFuncSig = 11
	ScalarFuncSig_CastRealAsString       ScalarFuncSig = 12
	ScalarFuncSig_CastRealAsDecimal      ScalarFuncSig = 13
	ScalarFuncSig_CastRealAsTime         ScalarFuncSig = 14
	ScalarFuncSig_CastRealAsDuration     ScalarFuncSig = 15
	ScalarFuncSig_CastRealAsJson         ScalarFuncSig = 16
	ScalarFuncSig_CastDecimalAsInt       ScalarFuncSig = 20
	ScalarFuncSig_CastDecimalAsReal      ScalarFuncSig = 21
	ScalarFuncSig_CastDecimalAsString    ScalarFuncSig = 22
	ScalarFuncSig_CastDecimalAsDecimal   ScalarFuncSig = 23
	ScalarFuncSig_CastDecimalAsTime      ScalarFuncSig = 24
	ScalarFuncSig_CastDecimalAsDuration  ScalarFuncSig = 25
	ScalarFuncSig_CastDecimalAsJson      ScalarFuncSig = 26
	ScalarFuncSig_CastStringAsInt        ScalarFuncSig = 30
	ScalarFuncSig_CastStringAsReal       ScalarFuncSig = 31
	ScalarFuncSig_CastStringAsString     ScalarFuncSig = 32
	ScalarFuncSig_CastStringAsDecimal    ScalarFuncSig = 33
	ScalarFuncSig_CastStringAsTime       ScalarFuncSig = 34
	ScalarFuncSig_CastStringAsDuration   ScalarFuncSig = 35
	ScalarFuncSig_CastStringAsJson       ScalarFuncSig = 36
	ScalarFuncSig_CastTimeAsInt          ScalarFuncSig = 40
	ScalarFuncSig_CastTimeAsReal         ScalarFuncSig = 41
	ScalarFuncSig_CastTimeAsString       ScalarFuncSig = 42
	ScalarFuncSig_CastTimeAsDecimal      ScalarFuncSig = 43
	ScalarFuncSig_CastTimeAsTime         ScalarFuncSig = 44
	ScalarFuncSig_CastTimeAsDuration     ScalarFuncSig = 45
	ScalarFuncSig_CastTimeAsJson         ScalarFuncSig = 46
	ScalarFuncSig_CastDurationAsInt      ScalarFuncSig = 50
	ScalarFuncSig_CastDurationAsReal     ScalarFuncSig = 51
	ScalarFuncSig_CastDurationAsString   ScalarFuncSig = 52
	ScalarFuncSig_CastDurationAsDecimal  ScalarFuncSig = 53
	ScalarFuncSig_CastDurationAsTime     ScalarFuncSig = 54
	ScalarFuncSig_CastDurationAsDuration ScalarFuncSig = 55
	ScalarFuncSig_CastDurationAsJson     ScalarFuncSig = 56
	ScalarFuncSig_CastJsonAsInt          ScalarFuncSig = 60
	ScalarFuncSig_CastJsonAsReal         ScalarFuncSig = 61
	ScalarFuncSig_CastJsonAsString       ScalarFuncSig = 62
	ScalarFuncSig_CastJsonAsDecimal      ScalarFuncSig = 63
	ScalarFuncSig_CastJsonAsTime         ScalarFuncSig = 64
	ScalarFuncSig_CastJsonAsDuration     ScalarFuncSig = 65
	ScalarFuncSig_CastJsonAsJson         ScalarFuncSig = 66
	// compare
	ScalarFuncSig_CoalesceInt      ScalarFuncSig = 4201
	ScalarFuncSig_CoalesceReal     ScalarFuncSig = 4202
	ScalarFuncSig_CoalesceDecimal  ScalarFuncSig = 4203
	ScalarFuncSig_CoalesceString   ScalarFuncSig = 4204
	ScalarFuncSig_CoalesceTime     ScalarFuncSig = 4205
	ScalarFuncSig_CoalesceDuration ScalarFuncSig = 4206
	// unimplemented in tidb
	ScalarFuncSig_CoalesceJson    ScalarFuncSig = 4207
	ScalarFuncSig_LTInt           ScalarFuncSig = 100
	ScalarFuncSig_LTReal          ScalarFuncSig = 101
	ScalarFuncSig_LTDecimal       ScalarFuncSig = 102
	ScalarFuncSig_LTString        ScalarFuncSig = 103
	ScalarFuncSig_LTTime          ScalarFuncSig = 104
	ScalarFuncSig_LTDuration      ScalarFuncSig = 105
	ScalarFuncSig_LTJson          ScalarFuncSig = 106
	ScalarFuncSig_LEInt           ScalarFuncSig = 110
	ScalarFuncSig_LEReal          ScalarFuncSig = 111
	ScalarFuncSig_LEDecimal       ScalarFuncSig = 112
	ScalarFuncSig_LEString        ScalarFuncSig = 113
	ScalarFuncSig_LETime          ScalarFuncSig = 114
	ScalarFuncSig_LEDuration      ScalarFuncSig = 115
	ScalarFuncSig_LEJson          ScalarFuncSig = 116
	ScalarFuncSig_GTInt           ScalarFuncSig = 120
	ScalarFuncSig_GTReal          ScalarFuncSig = 121
	ScalarFuncSig_GTDecimal       ScalarFuncSig = 122
	ScalarFuncSig_GTString        ScalarFuncSig = 123
	ScalarFuncSig_GTTime          ScalarFuncSig = 124
	ScalarFuncSig_GTDuration      ScalarFuncSig = 125
	ScalarFuncSig_GTJson          ScalarFuncSig = 126
	ScalarFuncSig_GreatestInt     ScalarFuncSig = 4215
	ScalarFuncSig_GreatestReal    ScalarFuncSig = 4216
	ScalarFuncSig_GreatestDecimal ScalarFuncSig = 4217
	ScalarFuncSig_GreatestString  ScalarFuncSig = 4218
	ScalarFuncSig_GreatestTime    ScalarFuncSig = 4219
	ScalarFuncSig_LeastInt        ScalarFuncSig = 4220
	ScalarFuncSig_LeastReal       ScalarFuncSig = 4221
	ScalarFuncSig_LeastDecimal    ScalarFuncSig = 4222
	ScalarFuncSig_LeastString     ScalarFuncSig = 4223
	ScalarFuncSig_LeastTime       ScalarFuncSig = 4224
	ScalarFuncSig_IntervalInt     ScalarFuncSig = 4225
	ScalarFuncSig_IntervalReal    ScalarFuncSig = 4226
	ScalarFuncSig_GEInt           ScalarFuncSig = 130
	ScalarFuncSig_GEReal          ScalarFuncSig = 131
	ScalarFuncSig_GEDecimal       ScalarFuncSig = 132
	ScalarFuncSig_GEString        ScalarFuncSig = 133
	ScalarFuncSig_GETime          ScalarFuncSig = 134
	ScalarFuncSig_GEDuration      ScalarFuncSig = 135
	ScalarFuncSig_GEJson          ScalarFuncSig = 136
	ScalarFuncSig_EQInt           ScalarFuncSig = 140
	ScalarFuncSig_EQReal          ScalarFuncSig = 141
	ScalarFuncSig_EQDecimal       ScalarFuncSig = 142
	ScalarFuncSig_EQString        ScalarFuncSig = 143
	ScalarFuncSig_EQTime          ScalarFuncSig = 144
	ScalarFuncSig_EQDuration      ScalarFuncSig = 145
	ScalarFuncSig_EQJson          ScalarFuncSig = 146
	ScalarFuncSig_NEInt           ScalarFuncSig = 150
	ScalarFuncSig_NEReal          ScalarFuncSig = 151
	ScalarFuncSig_NEDecimal       ScalarFuncSig = 152
	ScalarFuncSig_NEString        ScalarFuncSig = 153
	ScalarFuncSig_NETime          ScalarFuncSig = 154
	ScalarFuncSig_NEDuration      ScalarFuncSig = 155
	ScalarFuncSig_NEJson          ScalarFuncSig = 156
	ScalarFuncSig_NullEQInt       ScalarFuncSig = 160
	ScalarFuncSig_NullEQReal      ScalarFuncSig = 161
	ScalarFuncSig_NullEQDecimal   ScalarFuncSig = 162
	ScalarFuncSig_NullEQString    ScalarFuncSig = 163
	ScalarFuncSig_NullEQTime      ScalarFuncSig = 164
	ScalarFuncSig_NullEQDuration  ScalarFuncSig = 165
	ScalarFuncSig_NullEQJson      ScalarFuncSig = 166
	// arithmetic
	ScalarFuncSig_PlusReal                       ScalarFuncSig = 200
	ScalarFuncSig_PlusDecimal                    ScalarFuncSig = 201
	ScalarFuncSig_PlusInt                        ScalarFuncSig = 203
	ScalarFuncSig_MinusReal                      ScalarFuncSig = 204
	ScalarFuncSig_MinusDecimal                   ScalarFuncSig = 205
	ScalarFuncSig_MinusInt                       ScalarFuncSig = 207
	ScalarFuncSig_MultiplyReal                   ScalarFuncSig = 208
	ScalarFuncSig_MultiplyDecimal                ScalarFuncSig = 209
	ScalarFuncSig_MultiplyInt                    ScalarFuncSig = 210
	ScalarFuncSig_DivideReal                     ScalarFuncSig = 211
	ScalarFuncSig_DivideDecimal                  ScalarFuncSig = 212
	ScalarFuncSig_IntDivideInt                   ScalarFuncSig = 213
	ScalarFuncSig_IntDivideDecimal               ScalarFuncSig = 214
	ScalarFuncSig_ModReal                        ScalarFuncSig = 215
	ScalarFuncSig_ModDecimal                     ScalarFuncSig = 216
	ScalarFuncSig_ModInt                         ScalarFuncSig = 217
	ScalarFuncSig_MultiplyIntUnsigned            ScalarFuncSig = 218
	ScalarFuncSig_PlusIntUnsignedUnsigned        ScalarFuncSig = 219
	ScalarFuncSig_PlusIntUnsignedSigned          ScalarFuncSig = 220
	ScalarFuncSig_PlusIntSignedUnsigned          ScalarFuncSig = 221
	ScalarFuncSig_PlusIntSignedSigned            ScalarFuncSig = 222
	ScalarFuncSig_ModIntUnsignedUnsigned         ScalarFuncSig = 223
	ScalarFuncSig_ModIntUnsignedSigned           ScalarFuncSig = 224
	ScalarFuncSig_ModIntSignedUnsigned           ScalarFuncSig = 225
	ScalarFuncSig_ModIntSignedSigned             ScalarFuncSig = 226
	ScalarFuncSig_MinusIntUnsignedUnsigned       ScalarFuncSig = 227
	ScalarFuncSig_MinusIntUnsignedSigned         ScalarFuncSig = 228
	ScalarFuncSig_MinusIntSignedUnsigned         ScalarFuncSig = 229
	ScalarFuncSig_MinusIntSignedSigned           ScalarFuncSig = 230
	ScalarFuncSig_MinusIntForcedUnsignedUnsigned ScalarFuncSig = 231
	ScalarFuncSig_MinusIntForcedUnsignedSigned   ScalarFuncSig = 232
	ScalarFuncSig_MinusIntForcedSignedUnsigned   ScalarFuncSig = 233
	ScalarFuncSig_IntDivideIntUnsignedUnsigned   ScalarFuncSig = 234
	ScalarFuncSig_IntDivideIntUnsignedSigned     ScalarFuncSig = 235
	ScalarFuncSig_IntDivideIntSignedSigned       ScalarFuncSig = 236
	ScalarFuncSig_IntDivideIntSignedUnsigned     ScalarFuncSig = 237
	// math
	ScalarFuncSig_AbsInt               ScalarFuncSig = 2101
	ScalarFuncSig_AbsUInt              ScalarFuncSig = 2102
	ScalarFuncSig_AbsReal              ScalarFuncSig = 2103
	ScalarFuncSig_AbsDecimal           ScalarFuncSig = 2104
	ScalarFuncSig_CeilIntToDec         ScalarFuncSig = 2105
	ScalarFuncSig_CeilIntToInt         ScalarFuncSig = 2106
	ScalarFuncSig_CeilDecToInt         ScalarFuncSig = 2107
	ScalarFuncSig_CeilDecToDec         ScalarFuncSig = 2108
	ScalarFuncSig_CeilReal             ScalarFuncSig = 2109
	ScalarFuncSig_FloorIntToDec        ScalarFuncSig = 2110
	ScalarFuncSig_FloorIntToInt        ScalarFuncSig = 2111
	ScalarFuncSig_FloorDecToInt        ScalarFuncSig = 2112
	ScalarFuncSig_FloorDecToDec        ScalarFuncSig = 2113
	ScalarFuncSig_FloorReal            ScalarFuncSig = 2114
	ScalarFuncSig_RoundReal            ScalarFuncSig = 2121
	ScalarFuncSig_RoundInt             ScalarFuncSig = 2122
	ScalarFuncSig_RoundDec             ScalarFuncSig = 2123
	ScalarFuncSig_RoundWithFracReal    ScalarFuncSig = 2124
	ScalarFuncSig_RoundWithFracInt     ScalarFuncSig = 2125
	ScalarFuncSig_RoundWithFracDec     ScalarFuncSig = 2126
	ScalarFuncSig_Log1Arg              ScalarFuncSig = 2131
	ScalarFuncSig_Log2Args             ScalarFuncSig = 2132
	ScalarFuncSig_Log2                 ScalarFuncSig = 2133
	ScalarFuncSig_Log10                ScalarFuncSig = 2134
	ScalarFuncSig_Rand                 ScalarFuncSig = 2135
	ScalarFuncSig_RandWithSeedFirstGen ScalarFuncSig = 2136
	ScalarFuncSig_Pow                  ScalarFuncSig = 2137
	ScalarFuncSig_Conv                 ScalarFuncSig = 2138
	ScalarFuncSig_CRC32                ScalarFuncSig = 2139
	ScalarFuncSig_Sign                 ScalarFuncSig = 2140
	ScalarFuncSig_Sqrt                 ScalarFuncSig = 2141
	ScalarFuncSig_Acos                 ScalarFuncSig = 2142
	ScalarFuncSig_Asin                 ScalarFuncSig = 2143
	ScalarFuncSig_Atan1Arg             ScalarFuncSig = 2144
	ScalarFuncSig_Atan2Args            ScalarFuncSig = 2145
	ScalarFuncSig_Cos                  ScalarFuncSig = 2146
	ScalarFuncSig_Cot                  ScalarFuncSig = 2147
	ScalarFuncSig_Degrees              ScalarFuncSig = 2148
	ScalarFuncSig_Exp                  ScalarFuncSig = 2149
	ScalarFuncSig_PI                   ScalarFuncSig = 2150
	ScalarFuncSig_Radians              ScalarFuncSig = 2151
	ScalarFuncSig_Sin                  ScalarFuncSig = 2152
	ScalarFuncSig_Tan                  ScalarFuncSig = 2153
	ScalarFuncSig_TruncateInt          ScalarFuncSig = 2154
	ScalarFuncSig_TruncateReal         ScalarFuncSig = 2155
	ScalarFuncSig_TruncateDecimal      ScalarFuncSig = 2156
	ScalarFuncSig_TruncateUint         ScalarFuncSig = 2157
	// op
	ScalarFuncSig_LogicalAnd        ScalarFuncSig = 3101
	ScalarFuncSig_LogicalOr         ScalarFuncSig = 3102
	ScalarFuncSig_LogicalXor        ScalarFuncSig = 3103
	ScalarFuncSig_UnaryNotInt       ScalarFuncSig = 3104
	ScalarFuncSig_UnaryNotDecimal   ScalarFuncSig = 3105
	ScalarFuncSig_UnaryNotReal      ScalarFuncSig = 3106
	ScalarFuncSig_UnaryNotJSON      ScalarFuncSig = 3107
	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
	ScalarFuncSig_SM3                ScalarFuncSig = 4515
	// info
	ScalarFuncSig_Database           ScalarFuncSig = 4521
	ScalarFuncSig_FoundRows          ScalarFuncSig = 4522
	ScalarFuncSig_CurrentUser        ScalarFuncSig = 4523
	ScalarFuncSig_User               ScalarFuncSig = 4524
	ScalarFuncSig_ConnectionID       ScalarFuncSig = 4525
	ScalarFuncSig_LastInsertID       ScalarFuncSig = 4526
	ScalarFuncSig_LastInsertIDWithID ScalarFuncSig = 4527
	ScalarFuncSig_Version            ScalarFuncSig = 4528
	ScalarFuncSig_TiDBVersion        ScalarFuncSig = 4529
	ScalarFuncSig_RowCount           ScalarFuncSig = 4530
	// miscellaneous
	ScalarFuncSig_Sleep            ScalarFuncSig = 4551
	ScalarFuncSig_Lock             ScalarFuncSig = 4552
	ScalarFuncSig_ReleaseLock      ScalarFuncSig = 4553
	ScalarFuncSig_DecimalAnyValue  ScalarFuncSig = 4554
	ScalarFuncSig_DurationAnyValue ScalarFuncSig = 4555
	ScalarFuncSig_IntAnyValue      ScalarFuncSig = 4556
	ScalarFuncSig_JSONAnyValue     ScalarFuncSig = 4557
	ScalarFuncSig_RealAnyValue     ScalarFuncSig = 4558
	ScalarFuncSig_StringAnyValue   ScalarFuncSig = 4559
	ScalarFuncSig_TimeAnyValue     ScalarFuncSig = 4560
	ScalarFuncSig_InetAton         ScalarFuncSig = 4561
	ScalarFuncSig_InetNtoa         ScalarFuncSig = 4562
	ScalarFuncSig_Inet6Aton        ScalarFuncSig = 4563
	ScalarFuncSig_Inet6Ntoa        ScalarFuncSig = 4564
	ScalarFuncSig_IsIPv4           ScalarFuncSig = 4565
	ScalarFuncSig_IsIPv4Compat     ScalarFuncSig = 4566
	ScalarFuncSig_IsIPv4Mapped     ScalarFuncSig = 4567
	ScalarFuncSig_IsIPv6           ScalarFuncSig = 4568
	ScalarFuncSig_UUID             ScalarFuncSig = 4569
	ScalarFuncSig_VitessHash       ScalarFuncSig = 4570
	ScalarFuncSig_IsUUID           ScalarFuncSig = 4571
	ScalarFuncSig_TiDBShard        ScalarFuncSig = 4572
	ScalarFuncSig_GroupingSig      ScalarFuncSig = 4573
	// like
	ScalarFuncSig_IlikeSig             ScalarFuncSig = 4309
	ScalarFuncSig_LikeSig              ScalarFuncSig = 4310
	ScalarFuncSig_RegexpSig            ScalarFuncSig = 4311
	ScalarFuncSig_RegexpUTF8Sig        ScalarFuncSig = 4312
	ScalarFuncSig_RegexpLikeSig        ScalarFuncSig = 4313
	ScalarFuncSig_RegexpLikeUTF8Sig    ScalarFuncSig = 4314
	ScalarFuncSig_RegexpInStrSig       ScalarFuncSig = 4315
	ScalarFuncSig_RegexpInStrUTF8Sig   ScalarFuncSig = 4316
	ScalarFuncSig_RegexpReplaceSig     ScalarFuncSig = 4317
	ScalarFuncSig_RegexpReplaceUTF8Sig ScalarFuncSig = 4318
	ScalarFuncSig_RegexpSubstrSig      ScalarFuncSig = 4319
	ScalarFuncSig_RegexpSubstrUTF8Sig  ScalarFuncSig = 4320
	// json
	ScalarFuncSig_JsonExtractSig       ScalarFuncSig = 5001
	ScalarFuncSig_JsonUnquoteSig       ScalarFuncSig = 5002
	ScalarFuncSig_JsonTypeSig          ScalarFuncSig = 5003
	ScalarFuncSig_JsonSetSig           ScalarFuncSig = 5004
	ScalarFuncSig_JsonInsertSig        ScalarFuncSig = 5005
	ScalarFuncSig_JsonReplaceSig       ScalarFuncSig = 5006
	ScalarFuncSig_JsonRemoveSig        ScalarFuncSig = 5007
	ScalarFuncSig_JsonMergeSig         ScalarFuncSig = 5008
	ScalarFuncSig_JsonObjectSig        ScalarFuncSig = 5009
	ScalarFuncSig_JsonArraySig         ScalarFuncSig = 5010
	ScalarFuncSig_JsonValidJsonSig     ScalarFuncSig = 5011
	ScalarFuncSig_JsonContainsSig      ScalarFuncSig = 5012
	ScalarFuncSig_JsonArrayAppendSig   ScalarFuncSig = 5013
	ScalarFuncSig_JsonArrayInsertSig   ScalarFuncSig = 5014
	ScalarFuncSig_JsonMergePatchSig    ScalarFuncSig = 5015
	ScalarFuncSig_JsonMergePreserveSig ScalarFuncSig = 5016
	ScalarFuncSig_JsonContainsPathSig  ScalarFuncSig = 5017
	ScalarFuncSig_JsonPrettySig        ScalarFuncSig = 5018
	ScalarFuncSig_JsonQuoteSig         ScalarFuncSig = 5019
	ScalarFuncSig_JsonSearchSig        ScalarFuncSig = 5020
	ScalarFuncSig_JsonStorageSizeSig   ScalarFuncSig = 5021
	ScalarFuncSig_JsonDepthSig         ScalarFuncSig = 5022
	ScalarFuncSig_JsonKeysSig          ScalarFuncSig = 5023
	ScalarFuncSig_JsonLengthSig        ScalarFuncSig = 5024
	ScalarFuncSig_JsonKeys2ArgsSig     ScalarFuncSig = 5025
	ScalarFuncSig_JsonValidStringSig   ScalarFuncSig = 5026
	ScalarFuncSig_JsonValidOthersSig   ScalarFuncSig = 5027
	ScalarFuncSig_JsonStorageFreeSig   ScalarFuncSig = 5028
	ScalarFuncSig_JsonMemberOfSig      ScalarFuncSig = 5029
	// vector
	ScalarFuncSig_VecAsTextSig                     ScalarFuncSig = 5110
	ScalarFuncSig_VecFromTextSig                   ScalarFuncSig = 5111
	ScalarFuncSig_VecDimsSig                       ScalarFuncSig = 5112
	ScalarFuncSig_VecL1DistanceSig                 ScalarFuncSig = 5113
	ScalarFuncSig_VecL2DistanceSig                 ScalarFuncSig = 5114
	ScalarFuncSig_VecNegativeInnerProductSig       ScalarFuncSig = 5115
	ScalarFuncSig_VecCosineDistanceSig             ScalarFuncSig = 5116
	ScalarFuncSig_VecL2NormSig                     ScalarFuncSig = 5117
	ScalarFuncSig_CastStringAsVectorFloat32        ScalarFuncSig = 5180
	ScalarFuncSig_CastVectorFloat32AsInt           ScalarFuncSig = 5181
	ScalarFuncSig_CastVectorFloat32AsReal          ScalarFuncSig = 5182
	ScalarFuncSig_CastVectorFloat32AsString        ScalarFuncSig = 5183
	ScalarFuncSig_CastVectorFloat32AsDecimal       ScalarFuncSig = 5184
	ScalarFuncSig_CastVectorFloat32AsTime          ScalarFuncSig = 5185
	ScalarFuncSig_CastVectorFloat32AsDuration      ScalarFuncSig = 5186
	ScalarFuncSig_CastVectorFloat32AsJson          ScalarFuncSig = 5187
	ScalarFuncSig_CastVectorFloat32AsVectorFloat32 ScalarFuncSig = 5188
	ScalarFuncSig_PlusVectorFloat32                ScalarFuncSig = 5141
	ScalarFuncSig_MinusVectorFloat32               ScalarFuncSig = 5142
	ScalarFuncSig_MultiplyVectorFloat32            ScalarFuncSig = 5143
	ScalarFuncSig_VectorFloat32AnyValue            ScalarFuncSig = 5144
	ScalarFuncSig_CoalesceVectorFloat32            ScalarFuncSig = 5145
	ScalarFuncSig_LTVectorFloat32                  ScalarFuncSig = 5146
	ScalarFuncSig_LEVectorFloat32                  ScalarFuncSig = 5147
	ScalarFuncSig_GTVectorFloat32                  ScalarFuncSig = 5148
	ScalarFuncSig_GreatestVectorFloat32            ScalarFuncSig = 5149
	ScalarFuncSig_LeastVectorFloat32               ScalarFuncSig = 5150
	ScalarFuncSig_GEVectorFloat32                  ScalarFuncSig = 5151
	ScalarFuncSig_EQVectorFloat32                  ScalarFuncSig = 5152
	ScalarFuncSig_NEVectorFloat32                  ScalarFuncSig = 5153
	ScalarFuncSig_NullEQVectorFloat32              ScalarFuncSig = 5154
	ScalarFuncSig_VectorFloat32IsNull              ScalarFuncSig = 5155
	ScalarFuncSig_VectorFloat32IsTrue              ScalarFuncSig = 5156
	ScalarFuncSig_VectorFloat32IsFalse             ScalarFuncSig = 5157
	ScalarFuncSig_VectorFloat32IsTrueWithNull      ScalarFuncSig = 5158
	ScalarFuncSig_VectorFloat32IsFalseWithNull     ScalarFuncSig = 5159
	ScalarFuncSig_IfNullVectorFloat32              ScalarFuncSig = 5160
	ScalarFuncSig_IfVectorFloat32                  ScalarFuncSig = 5161
	ScalarFuncSig_CaseWhenVectorFloat32            ScalarFuncSig = 5162
	// time
	ScalarFuncSig_DateFormatSig             ScalarFuncSig = 6001
	ScalarFuncSig_DateLiteral               ScalarFuncSig = 6002
	ScalarFuncSig_DateDiff                  ScalarFuncSig = 6003
	ScalarFuncSig_NullTimeDiff              ScalarFuncSig = 6004
	ScalarFuncSig_TimeStringTimeDiff        ScalarFuncSig = 6005
	ScalarFuncSig_DurationStringTimeDiff    ScalarFuncSig = 6006
	ScalarFuncSig_DurationDurationTimeDiff  ScalarFuncSig = 6007
	ScalarFuncSig_StringTimeTimeDiff        ScalarFuncSig = 6008
	ScalarFuncSig_StringDurationTimeDiff    ScalarFuncSig = 6009
	ScalarFuncSig_StringStringTimeDiff      ScalarFuncSig = 6010
	ScalarFuncSig_TimeTimeTimeDiff          ScalarFuncSig = 6011
	ScalarFuncSig_Date                      ScalarFuncSig = 6012
	ScalarFuncSig_Hour                      ScalarFuncSig = 6013
	ScalarFuncSig_Minute                    ScalarFuncSig = 6014
	ScalarFuncSig_Second                    ScalarFuncSig = 6015
	ScalarFuncSig_MicroSecond               ScalarFuncSig = 6016
	ScalarFuncSig_Month                     ScalarFuncSig = 6017
	ScalarFuncSig_MonthName                 ScalarFuncSig = 6018
	ScalarFuncSig_NowWithArg                ScalarFuncSig = 6019
	ScalarFuncSig_NowWithoutArg             ScalarFuncSig = 6020
	ScalarFuncSig_DayName                   ScalarFuncSig = 6021
	ScalarFuncSig_DayOfMonth                ScalarFuncSig = 6022
	ScalarFuncSig_DayOfWeek                 ScalarFuncSig = 6023
	ScalarFuncSig_DayOfYear                 ScalarFuncSig = 6024
	ScalarFuncSig_WeekWithMode              ScalarFuncSig = 6025
	ScalarFuncSig_WeekWithoutMode           ScalarFuncSig = 6026
	ScalarFuncSig_WeekDay                   ScalarFuncSig = 6027
	ScalarFuncSig_WeekOfYear                ScalarFuncSig = 6028
	ScalarFuncSig_Year                      ScalarFuncSig = 6029
	ScalarFuncSig_YearWeekWithMode          ScalarFuncSig = 6030
	ScalarFuncSig_YearWeekWithoutMode       ScalarFuncSig = 6031
	ScalarFuncSig_GetFormat                 ScalarFuncSig = 6032
	ScalarFuncSig_SysDateWithFsp            ScalarFuncSig = 6033
	ScalarFuncSig_SysDateWithoutFsp         ScalarFuncSig = 6034
	ScalarFuncSig_CurrentDate               ScalarFuncSig = 6035
	ScalarFuncSig_CurrentTime0Arg           ScalarFuncSig = 6036
	ScalarFuncSig_CurrentTime1Arg           ScalarFuncSig = 6037
	ScalarFuncSig_Time                      ScalarFuncSig = 6038
	ScalarFuncSig_TimeLiteral               ScalarFuncSig = 6039
	ScalarFuncSig_UTCDate                   ScalarFuncSig = 6040
	ScalarFuncSig_UTCTimestampWithArg       ScalarFuncSig = 6041
	ScalarFuncSig_UTCTimestampWithoutArg    ScalarFuncSig = 6042
	ScalarFuncSig_AddDatetimeAndDuration    ScalarFuncSig = 6043
	ScalarFuncSig_AddDatetimeAndString      ScalarFuncSig = 6044
	ScalarFuncSig_AddTimeDateTimeNull       ScalarFuncSig = 6045
	ScalarFuncSig_AddStringAndDuration      ScalarFuncSig = 6046
	ScalarFuncSig_AddStringAndString        ScalarFuncSig = 6047
	ScalarFuncSig_AddTimeStringNull         ScalarFuncSig = 6048
	ScalarFuncSig_AddDurationAndDuration    ScalarFuncSig = 6049
	ScalarFuncSig_AddDurationAndString      ScalarFuncSig = 6050
	ScalarFuncSig_AddTimeDurationNull       ScalarFuncSig = 6051
	ScalarFuncSig_AddDateAndDuration        ScalarFuncSig = 6052
	ScalarFuncSig_AddDateAndString          ScalarFuncSig = 6053
	ScalarFuncSig_SubDatetimeAndDuration    ScalarFuncSig = 6054
	ScalarFuncSig_SubDatetimeAndString      ScalarFuncSig = 6055
	ScalarFuncSig_SubTimeDateTimeNull       ScalarFuncSig = 6056
	ScalarFuncSig_SubStringAndDuration      ScalarFuncSig = 6057
	ScalarFuncSig_SubStringAndString        ScalarFuncSig = 6058
	ScalarFuncSig_SubTimeStringNull         ScalarFuncSig = 6059
	ScalarFuncSig_SubDurationAndDuration    ScalarFuncSig = 6060
	ScalarFuncSig_SubDurationAndString      ScalarFuncSig = 6061
	ScalarFuncSig_SubTimeDurationNull       ScalarFuncSig = 6062
	ScalarFuncSig_SubDateAndDuration        ScalarFuncSig = 6063
	ScalarFuncSig_SubDateAndString          ScalarFuncSig = 6064
	ScalarFuncSig_UnixTimestampCurrent      ScalarFuncSig = 6065
	ScalarFuncSig_UnixTimestampInt          ScalarFuncSig = 6066
	ScalarFuncSig_UnixTimestampDec          ScalarFuncSig = 6067
	ScalarFuncSig_ConvertTz                 ScalarFuncSig = 6068
	ScalarFuncSig_MakeDate                  ScalarFuncSig = 6069
	ScalarFuncSig_MakeTime                  ScalarFuncSig = 6070
	ScalarFuncSig_PeriodAdd                 ScalarFuncSig = 6071
	ScalarFuncSig_PeriodDiff                ScalarFuncSig = 6072
	ScalarFuncSig_Quarter                   ScalarFuncSig = 6073
	ScalarFuncSig_SecToTime                 ScalarFuncSig = 6074
	ScalarFuncSig_TimeToSec                 ScalarFuncSig = 6075
	ScalarFuncSig_TimestampAdd              ScalarFuncSig = 6076
	ScalarFuncSig_ToDays                    ScalarFuncSig = 6077
	ScalarFuncSig_ToSeconds                 ScalarFuncSig = 6078
	ScalarFuncSig_UTCTimeWithArg            ScalarFuncSig = 6079
	ScalarFuncSig_UTCTimeWithoutArg         ScalarFuncSig = 6080
	ScalarFuncSig_Timestamp1Arg             ScalarFuncSig = 6081
	ScalarFuncSig_Timestamp2Args            ScalarFuncSig = 6082
	ScalarFuncSig_TimestampLiteral          ScalarFuncSig = 6083
	ScalarFuncSig_LastDay                   ScalarFuncSig = 6084
	ScalarFuncSig_StrToDateDate             ScalarFuncSig = 6085
	ScalarFuncSig_StrToDateDatetime         ScalarFuncSig = 6086
	ScalarFuncSig_StrToDateDuration         ScalarFuncSig = 6087
	ScalarFuncSig_FromUnixTime1Arg          ScalarFuncSig = 6088
	ScalarFuncSig_FromUnixTime2Arg          ScalarFuncSig = 6089
	ScalarFuncSig_ExtractDatetime           ScalarFuncSig = 6090
	ScalarFuncSig_ExtractDuration           ScalarFuncSig = 6091
	ScalarFuncSig_AddDateStringString       ScalarFuncSig = 6092
	ScalarFuncSig_AddDateStringInt          ScalarFuncSig = 6093
	ScalarFuncSig_AddDateStringDecimal      ScalarFuncSig = 6094
	ScalarFuncSig_AddDateIntString          ScalarFuncSig = 6095
	ScalarFuncSig_AddDateIntInt             ScalarFuncSig = 6096
	ScalarFuncSig_AddDateDatetimeString     ScalarFuncSig = 6097
	ScalarFuncSig_AddDateDatetimeInt        ScalarFuncSig = 6098
	ScalarFuncSig_SubDateStringString       ScalarFuncSig = 6099
	ScalarFuncSig_SubDateStringInt          ScalarFuncSig = 6100
	ScalarFuncSig_SubDateStringDecimal      ScalarFuncSig = 6101
	ScalarFuncSig_SubDateIntString          ScalarFuncSig = 6102
	ScalarFuncSig_SubDateIntInt             ScalarFuncSig = 6103
	ScalarFuncSig_SubDateDatetimeString     ScalarFuncSig = 6104
	ScalarFuncSig_SubDateDatetimeInt        ScalarFuncSig = 6105
	ScalarFuncSig_FromDays                  ScalarFuncSig = 6106
	ScalarFuncSig_TimeFormat                ScalarFuncSig = 6107
	ScalarFuncSig_TimestampDiff             ScalarFuncSig = 6108
	ScalarFuncSig_SubDateStringReal         ScalarFuncSig = 6109
	ScalarFuncSig_SubDateIntReal            ScalarFuncSig = 6110
	ScalarFuncSig_SubDateIntDecimal         ScalarFuncSig = 6111
	ScalarFuncSig_SubDateDatetimeReal       ScalarFuncSig = 6112
	ScalarFuncSig_SubDateDatetimeDecimal    ScalarFuncSig = 6113
	ScalarFuncSig_SubDateDurationString     ScalarFuncSig = 6114
	ScalarFuncSig_SubDateDurationInt        ScalarFuncSig = 6115
	ScalarFuncSig_SubDateDurationReal       ScalarFuncSig = 6116
	ScalarFuncSig_SubDateDurationDecimal    ScalarFuncSig = 6117
	ScalarFuncSig_AddDateStringReal         ScalarFuncSig = 6118
	ScalarFuncSig_AddDateIntReal            ScalarFuncSig = 6119
	ScalarFuncSig_AddDateIntDecimal         ScalarFuncSig = 6120
	ScalarFuncSig_AddDateDatetimeReal       ScalarFuncSig = 6121
	ScalarFuncSig_AddDateDatetimeDecimal    ScalarFuncSig = 6122
	ScalarFuncSig_AddDateDurationString     ScalarFuncSig = 6123
	ScalarFuncSig_AddDateDurationInt        ScalarFuncSig = 6124
	ScalarFuncSig_AddDateDurationReal       ScalarFuncSig = 6125
	ScalarFuncSig_AddDateDurationDecimal    ScalarFuncSig = 6126
	ScalarFuncSig_ExtractDatetimeFromString ScalarFuncSig = 6127
	ScalarFuncSig_AddDateRealString         ScalarFuncSig = 6128
	ScalarFuncSig_AddDateRealInt            ScalarFuncSig = 6129
	ScalarFuncSig_AddDateRealReal           ScalarFuncSig = 6130
	ScalarFuncSig_AddDateRealDecimal        ScalarFuncSig = 6131
	ScalarFuncSig_AddDateDecimalString      ScalarFuncSig = 6132
	ScalarFuncSig_AddDateDecimalInt         ScalarFuncSig = 6133
	ScalarFuncSig_AddDateDecimalReal        ScalarFuncSig = 6134
	ScalarFuncSig_AddDateDecimalDecimal     ScalarFuncSig = 6135
	ScalarFuncSig_SubDateRealString         ScalarFuncSig = 6136
	ScalarFuncSig_SubDateRealInt            ScalarFuncSig = 6137
	ScalarFuncSig_SubDateRealReal           ScalarFuncSig = 6138
	ScalarFuncSig_SubDateRealDecimal        ScalarFuncSig = 6139
	ScalarFuncSig_SubDateDecimalString      ScalarFuncSig = 6140
	ScalarFuncSig_SubDateDecimalInt         ScalarFuncSig = 6141
	ScalarFuncSig_SubDateDecimalReal        ScalarFuncSig = 6142
	ScalarFuncSig_SubDateDecimalDecimal     ScalarFuncSig = 6143
	// String functions
	ScalarFuncSig_BitLength               ScalarFuncSig = 7001
	ScalarFuncSig_Bin                     ScalarFuncSig = 7002
	ScalarFuncSig_ASCII                   ScalarFuncSig = 7003
	ScalarFuncSig_Char                    ScalarFuncSig = 7004
	ScalarFuncSig_CharLengthUTF8          ScalarFuncSig = 7005
	ScalarFuncSig_Concat                  ScalarFuncSig = 7006
	ScalarFuncSig_ConcatWS                ScalarFuncSig = 7007
	ScalarFuncSig_Convert                 ScalarFuncSig = 7008
	ScalarFuncSig_Elt                     ScalarFuncSig = 7009
	ScalarFuncSig_ExportSet3Arg           ScalarFuncSig = 7010
	ScalarFuncSig_ExportSet4Arg           ScalarFuncSig = 7011
	ScalarFuncSig_ExportSet5Arg           ScalarFuncSig = 7012
	ScalarFuncSig_FieldInt                ScalarFuncSig = 7013
	ScalarFuncSig_FieldReal               ScalarFuncSig = 7014
	ScalarFuncSig_FieldString             ScalarFuncSig = 7015
	ScalarFuncSig_FindInSet               ScalarFuncSig = 7016
	ScalarFuncSig_Format                  ScalarFuncSig = 7017
	ScalarFuncSig_FormatWithLocale        ScalarFuncSig = 7018
	ScalarFuncSig_FromBase64              ScalarFuncSig = 7019
	ScalarFuncSig_HexIntArg               ScalarFuncSig = 7020
	ScalarFuncSig_HexStrArg               ScalarFuncSig = 7021
	ScalarFuncSig_InsertUTF8              ScalarFuncSig = 7022
	ScalarFuncSig_Insert                  ScalarFuncSig = 7023
	ScalarFuncSig_InstrUTF8               ScalarFuncSig = 7024
	ScalarFuncSig_Instr                   ScalarFuncSig = 7025
	ScalarFuncSig_LTrim                   ScalarFuncSig = 7026
	ScalarFuncSig_LeftUTF8                ScalarFuncSig = 7027
	ScalarFuncSig_Left                    ScalarFuncSig = 7028
	ScalarFuncSig_Length                  ScalarFuncSig = 7029
	ScalarFuncSig_Locate2ArgsUTF8         ScalarFuncSig = 7030
	ScalarFuncSig_Locate3ArgsUTF8         ScalarFuncSig = 7031
	ScalarFuncSig_Locate2Args             ScalarFuncSig = 7032
	ScalarFuncSig_Locate3Args             ScalarFuncSig = 7033
	ScalarFuncSig_Lower                   ScalarFuncSig = 7034
	ScalarFuncSig_LpadUTF8                ScalarFuncSig = 7035
	ScalarFuncSig_Lpad                    ScalarFuncSig = 7036
	ScalarFuncSig_MakeSet                 ScalarFuncSig = 7037
	ScalarFuncSig_OctInt                  ScalarFuncSig = 7038
	ScalarFuncSig_OctString               ScalarFuncSig = 7039
	ScalarFuncSig_Ord                     ScalarFuncSig = 7040
	ScalarFuncSig_Quote                   ScalarFuncSig = 7041
	ScalarFuncSig_RTrim                   ScalarFuncSig = 7042
	ScalarFuncSig_Repeat                  ScalarFuncSig = 7043
	ScalarFuncSig_Replace                 ScalarFuncSig = 7044
	ScalarFuncSig_ReverseUTF8             ScalarFuncSig = 7045
	ScalarFuncSig_Reverse                 ScalarFuncSig = 7046
	ScalarFuncSig_RightUTF8               ScalarFuncSig = 7047
	ScalarFuncSig_Right                   ScalarFuncSig = 7048
	ScalarFuncSig_RpadUTF8                ScalarFuncSig = 7049
	ScalarFuncSig_Rpad                    ScalarFuncSig = 7050
	ScalarFuncSig_Space                   ScalarFuncSig = 7051
	ScalarFuncSig_Strcmp                  ScalarFuncSig = 7052
	ScalarFuncSig_Substring2ArgsUTF8      ScalarFuncSig = 7053
	ScalarFuncSig_Substring3ArgsUTF8      ScalarFuncSig = 7054
	ScalarFuncSig_Substring2Args          ScalarFuncSig = 7055
	ScalarFuncSig_Substring3Args          ScalarFuncSig = 7056
	ScalarFuncSig_SubstringIndex          ScalarFuncSig = 7057
	ScalarFuncSig_ToBase64                ScalarFuncSig = 7058
	ScalarFuncSig_Trim1Arg                ScalarFuncSig = 7059
	ScalarFuncSig_Trim2Args               ScalarFuncSig = 7060
	ScalarFuncSig_Trim3Args               ScalarFuncSig = 7061
	ScalarFuncSig_UnHex                   ScalarFuncSig = 7062
	ScalarFuncSig_UpperUTF8               ScalarFuncSig = 7063
	ScalarFuncSig_Upper                   ScalarFuncSig = 7064
	ScalarFuncSig_CharLength              ScalarFuncSig = 7065
	ScalarFuncSig_LowerUTF8               ScalarFuncSig = 7066
	ScalarFuncSig_GreatestDuration        ScalarFuncSig = 7067
	ScalarFuncSig_GreatestCmpStringAsTime ScalarFuncSig = 7068
	ScalarFuncSig_LeastDuration           ScalarFuncSig = 7069
	ScalarFuncSig_LeastCmpStringAsTime    ScalarFuncSig = 7070
	ScalarFuncSig_ToBinary                ScalarFuncSig = 7071
	ScalarFuncSig_FromBinary              ScalarFuncSig = 7072
	ScalarFuncSig_GreatestCmpStringAsDate ScalarFuncSig = 7073
	ScalarFuncSig_LeastCmpStringAsDate    ScalarFuncSig = 7074
	ScalarFuncSig_GreatestDate            ScalarFuncSig = 7075
	ScalarFuncSig_LeastDate               ScalarFuncSig = 7076
)

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 ScanAccessObject 

type ScanAccessObject struct {
	Database   string         `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table      string         `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Indexes    []*IndexAccess `protobuf:"bytes,3,rep,name=indexes" json:"indexes,omitempty"`
	Partitions []string       `protobuf:"bytes,4,rep,name=partitions" json:"partitions,omitempty"`
}

ScanAccessObject represents the access to a single table. It may contain multiple indexes and multiple partitions.

func (*ScanAccessObject) Descriptor 

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

func (*ScanAccessObject) GetDatabase 

func (m *ScanAccessObject) GetDatabase() string

func (*ScanAccessObject) GetIndexes 

func (m *ScanAccessObject) GetIndexes() []*IndexAccess

func (*ScanAccessObject) GetPartitions 

func (m *ScanAccessObject) GetPartitions() []string

func (*ScanAccessObject) GetTable 

func (m *ScanAccessObject) GetTable() string

func (*ScanAccessObject) Marshal 

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

func (*ScanAccessObject) MarshalTo 

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

func (*ScanAccessObject) ProtoMessage 

func (*ScanAccessObject) ProtoMessage()

func (*ScanAccessObject) Reset 

func (m *ScanAccessObject) Reset()

func (*ScanAccessObject) Size 

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

func (*ScanAccessObject) String 

func (m *ScanAccessObject) String() string

func (*ScanAccessObject) Unmarshal 

func (m *ScanAccessObject) Unmarshal(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 Sort 

type Sort struct {
	ByItems          []*ByItem `protobuf:"bytes,1,rep,name=byItems" json:"byItems,omitempty"`
	IsPartialSort    *bool     `protobuf:"varint,2,opt,name=isPartialSort" json:"isPartialSort,omitempty"`
	Child            *Executor `protobuf:"bytes,3,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*Sort) Descriptor 

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

func (*Sort) GetByItems 

func (m *Sort) GetByItems() []*ByItem

func (*Sort) GetChild 

func (m *Sort) GetChild() *Executor

func (*Sort) GetIsPartialSort 

func (m *Sort) GetIsPartialSort() bool

func (*Sort) Marshal 

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

func (*Sort) MarshalTo 

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

func (*Sort) ProtoMessage 

func (*Sort) ProtoMessage()

func (*Sort) Reset 

func (m *Sort) Reset()

func (*Sort) Size 

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

func (*Sort) String 

func (m *Sort) String() string

func (*Sort) Unmarshal 

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

type StoreType 

type StoreType int32
const (
	StoreType_unspecified StoreType = 0
	StoreType_tidb        StoreType = 1
	StoreType_tikv        StoreType = 2
	StoreType_tiflash     StoreType = 3
)

func (StoreType) EnumDescriptor 

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

func (StoreType) String 

func (x StoreType) String() string

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"`
	PrimaryPrefixColumnIds     []int64          `protobuf:"varint,7,rep,name=primary_prefix_column_ids,json=primaryPrefixColumnIds" json:"primary_prefix_column_ids,omitempty"`
	KeepOrder                  *bool            `protobuf:"varint,8,opt,name=keep_order,json=keepOrder" json:"keep_order,omitempty"`
	IsFastScan                 *bool            `protobuf:"varint,9,opt,name=is_fast_scan,json=isFastScan" json:"is_fast_scan,omitempty"`
	PushedDownFilterConditions []*Expr          `` /* 137-byte string literal not displayed */
	AnnQuery                   *ANNQueryInfo    `protobuf:"bytes,13,opt,name=ann_query,json=annQuery" json:"ann_query,omitempty"`
	RuntimeFilterList          []*RuntimeFilter `protobuf:"bytes,11,rep,name=runtime_filter_list,json=runtimeFilterList" json:"runtime_filter_list,omitempty"`
	MaxWaitTimeMs              int32            `protobuf:"varint,12,opt,name=max_wait_time_ms,json=maxWaitTimeMs" json:"max_wait_time_ms"`
	XXX_unrecognized           []byte           `json:"-"`
}

func (*TableScan) Descriptor 

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

func (*TableScan) GetAnnQuery 

func (m *TableScan) GetAnnQuery() *ANNQueryInfo

func (*TableScan) GetColumns 

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

func (*TableScan) GetDesc 

func (m *TableScan) GetDesc() bool

func (*TableScan) GetIsFastScan 

func (m *TableScan) GetIsFastScan() bool

func (*TableScan) GetKeepOrder 

func (m *TableScan) GetKeepOrder() bool

func (*TableScan) GetMaxWaitTimeMs 

func (m *TableScan) GetMaxWaitTimeMs() int32

func (*TableScan) GetNextReadEngine 

func (m *TableScan) GetNextReadEngine() EngineType

func (*TableScan) GetPrimaryColumnIds 

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

func (*TableScan) GetPrimaryPrefixColumnIds 

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

func (*TableScan) GetPushedDownFilterConditions 

func (m *TableScan) GetPushedDownFilterConditions() []*Expr

func (*TableScan) GetRanges 

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

func (*TableScan) GetRuntimeFilterList 

func (m *TableScan) GetRuntimeFilterList() []*RuntimeFilter

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 TaskType 

type TaskType int32
const (
	TaskType_unknown  TaskType = 0
	TaskType_root     TaskType = 1
	TaskType_cop      TaskType = 2
	TaskType_batchCop TaskType = 3
	TaskType_mpp      TaskType = 4
)

func (TaskType) EnumDescriptor 

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

func (TaskType) String 

func (x TaskType) String() string

type TiFlashExecutionInfo 

type TiFlashExecutionInfo struct {
	// The execution summary of each executor, no order limitation.
	ExecutionSummaries []*ExecutorExecutionSummary `protobuf:"bytes,1,rep,name=execution_summaries,json=executionSummaries" json:"execution_summaries,omitempty"`
	XXX_unrecognized   []byte                      `json:"-"`
}

func (*TiFlashExecutionInfo) Descriptor 

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

func (*TiFlashExecutionInfo) GetExecutionSummaries 

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

func (*TiFlashExecutionInfo) Marshal 

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

func (*TiFlashExecutionInfo) MarshalTo 

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

func (*TiFlashExecutionInfo) ProtoMessage 

func (*TiFlashExecutionInfo) ProtoMessage()

func (*TiFlashExecutionInfo) Reset 

func (m *TiFlashExecutionInfo) Reset()

func (*TiFlashExecutionInfo) Size 

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

func (*TiFlashExecutionInfo) String 

func (m *TiFlashExecutionInfo) String() string

func (*TiFlashExecutionInfo) Unmarshal 

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

type TiFlashRegionNumOfInstance 

type TiFlashRegionNumOfInstance struct {
	InstanceId       *string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId" json:"instance_id,omitempty"`
	RegionNum        *uint64 `protobuf:"varint,2,opt,name=region_num,json=regionNum" json:"region_num,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TiFlashRegionNumOfInstance) Descriptor 

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

func (*TiFlashRegionNumOfInstance) GetInstanceId 

func (m *TiFlashRegionNumOfInstance) GetInstanceId() string

func (*TiFlashRegionNumOfInstance) GetRegionNum 

func (m *TiFlashRegionNumOfInstance) GetRegionNum() uint64

func (*TiFlashRegionNumOfInstance) Marshal 

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

func (*TiFlashRegionNumOfInstance) MarshalTo 

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

func (*TiFlashRegionNumOfInstance) ProtoMessage 

func (*TiFlashRegionNumOfInstance) ProtoMessage()

func (*TiFlashRegionNumOfInstance) Reset 

func (m *TiFlashRegionNumOfInstance) Reset()

func (*TiFlashRegionNumOfInstance) Size 

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

func (*TiFlashRegionNumOfInstance) String 

func (m *TiFlashRegionNumOfInstance) String() string

func (*TiFlashRegionNumOfInstance) Unmarshal 

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

type TiFlashScanContext 

type TiFlashScanContext struct {
	DmfileScannedPacks                 *uint64                       `protobuf:"varint,1,opt,name=dmfile_scanned_packs,json=dmfileScannedPacks" json:"dmfile_scanned_packs,omitempty"`
	DmfileSkippedPacks                 *uint64                       `protobuf:"varint,2,opt,name=dmfile_skipped_packs,json=dmfileSkippedPacks" json:"dmfile_skipped_packs,omitempty"`
	DmfileDataScannedRows              *uint64                       `protobuf:"varint,3,opt,name=dmfile_data_scanned_rows,json=dmfileDataScannedRows" json:"dmfile_data_scanned_rows,omitempty"`
	DmfileDataSkippedRows              *uint64                       `protobuf:"varint,4,opt,name=dmfile_data_skipped_rows,json=dmfileDataSkippedRows" json:"dmfile_data_skipped_rows,omitempty"`
	TotalDmfileRsLoadMs                *uint64                       `protobuf:"varint,5,opt,name=total_dmfile_rs_load_ms,json=totalDmfileRsLoadMs" json:"total_dmfile_rs_load_ms,omitempty"`
	TotalDmfileReadMs                  *uint64                       `protobuf:"varint,6,opt,name=total_dmfile_read_ms,json=totalDmfileReadMs" json:"total_dmfile_read_ms,omitempty"`
	TotalBuildSnapshotMs               *uint64                       `protobuf:"varint,7,opt,name=total_build_snapshot_ms,json=totalBuildSnapshotMs" json:"total_build_snapshot_ms,omitempty"`
	LocalRegions                       *uint64                       `protobuf:"varint,8,opt,name=local_regions,json=localRegions" json:"local_regions,omitempty"`
	RemoteRegions                      *uint64                       `protobuf:"varint,9,opt,name=remote_regions,json=remoteRegions" json:"remote_regions,omitempty"`
	UserReadBytes                      *uint64                       `protobuf:"varint,10,opt,name=user_read_bytes,json=userReadBytes" json:"user_read_bytes,omitempty"`
	TotalLearnerReadMs                 *uint64                       `protobuf:"varint,11,opt,name=total_learner_read_ms,json=totalLearnerReadMs" json:"total_learner_read_ms,omitempty"`
	DisaggReadCacheHitBytes            *uint64                       `` /* 131-byte string literal not displayed */
	DisaggReadCacheMissBytes           *uint64                       `` /* 134-byte string literal not displayed */
	TotalDmfileRsCheckMs               *uint64                       `protobuf:"varint,14,opt,name=total_dmfile_rs_check_ms,json=totalDmfileRsCheckMs" json:"total_dmfile_rs_check_ms,omitempty"`
	StaleReadRegions                   *uint64                       `protobuf:"varint,15,opt,name=stale_read_regions,json=staleReadRegions" json:"stale_read_regions,omitempty"`
	Segments                           *uint64                       `protobuf:"varint,16,opt,name=segments" json:"segments,omitempty"`
	ReadTasks                          *uint64                       `protobuf:"varint,17,opt,name=read_tasks,json=readTasks" json:"read_tasks,omitempty"`
	DeltaRows                          *uint64                       `protobuf:"varint,18,opt,name=delta_rows,json=deltaRows" json:"delta_rows,omitempty"`
	DeltaBytes                         *uint64                       `protobuf:"varint,19,opt,name=delta_bytes,json=deltaBytes" json:"delta_bytes,omitempty"`
	MvccInputRows                      *uint64                       `protobuf:"varint,20,opt,name=mvcc_input_rows,json=mvccInputRows" json:"mvcc_input_rows,omitempty"`
	MvccInputBytes                     *uint64                       `protobuf:"varint,21,opt,name=mvcc_input_bytes,json=mvccInputBytes" json:"mvcc_input_bytes,omitempty"`
	MvccOutputRows                     *uint64                       `protobuf:"varint,22,opt,name=mvcc_output_rows,json=mvccOutputRows" json:"mvcc_output_rows,omitempty"`
	LmSkipRows                         *uint64                       `protobuf:"varint,23,opt,name=lm_skip_rows,json=lmSkipRows" json:"lm_skip_rows,omitempty"`
	TotalBuildInputstreamMs            *uint64                       `` /* 129-byte string literal not displayed */
	TotalBuildBitmapMs                 *uint64                       `protobuf:"varint,25,opt,name=total_build_bitmap_ms,json=totalBuildBitmapMs" json:"total_build_bitmap_ms,omitempty"`
	MinLocalStreamMs                   *uint64                       `protobuf:"varint,26,opt,name=min_local_stream_ms,json=minLocalStreamMs" json:"min_local_stream_ms,omitempty"`
	MaxLocalStreamMs                   *uint64                       `protobuf:"varint,27,opt,name=max_local_stream_ms,json=maxLocalStreamMs" json:"max_local_stream_ms,omitempty"`
	MinRemoteStreamMs                  *uint64                       `protobuf:"varint,28,opt,name=min_remote_stream_ms,json=minRemoteStreamMs" json:"min_remote_stream_ms,omitempty"`
	MaxRemoteStreamMs                  *uint64                       `protobuf:"varint,29,opt,name=max_remote_stream_ms,json=maxRemoteStreamMs" json:"max_remote_stream_ms,omitempty"`
	RegionsOfInstance                  []*TiFlashRegionNumOfInstance `protobuf:"bytes,30,rep,name=regions_of_instance,json=regionsOfInstance" json:"regions_of_instance,omitempty"`
	DmfileMvccScannedRows              *uint64                       `protobuf:"varint,31,opt,name=dmfile_mvcc_scanned_rows,json=dmfileMvccScannedRows" json:"dmfile_mvcc_scanned_rows,omitempty"`
	DmfileMvccSkippedRows              *uint64                       `protobuf:"varint,32,opt,name=dmfile_mvcc_skipped_rows,json=dmfileMvccSkippedRows" json:"dmfile_mvcc_skipped_rows,omitempty"`
	DmfileLmFilterScannedRows          *uint64                       `` /* 137-byte string literal not displayed */
	DmfileLmFilterSkippedRows          *uint64                       `` /* 137-byte string literal not displayed */
	TotalVectorIdxLoadFromS3           *uint64                       `` /* 137-byte string literal not displayed */
	TotalVectorIdxLoadFromDisk         *uint64                       `` /* 143-byte string literal not displayed */
	TotalVectorIdxLoadFromCache        *uint64                       `` /* 146-byte string literal not displayed */
	TotalVectorIdxLoadTimeMs           *uint64                       `` /* 137-byte string literal not displayed */
	TotalVectorIdxSearchTimeMs         *uint64                       `` /* 143-byte string literal not displayed */
	TotalVectorIdxSearchVisitedNodes   *uint64                       `` /* 161-byte string literal not displayed */
	TotalVectorIdxSearchDiscardedNodes *uint64                       `` /* 167-byte string literal not displayed */
	TotalVectorIdxReadVecTimeMs        *uint64                       `` /* 148-byte string literal not displayed */
	TotalVectorIdxReadOthersTimeMs     *uint64                       `` /* 157-byte string literal not displayed */
	XXX_unrecognized                   []byte                        `json:"-"`
}

func (*TiFlashScanContext) Descriptor 

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

func (*TiFlashScanContext) GetDeltaBytes 

func (m *TiFlashScanContext) GetDeltaBytes() uint64

func (*TiFlashScanContext) GetDeltaRows 

func (m *TiFlashScanContext) GetDeltaRows() uint64

func (*TiFlashScanContext) GetDisaggReadCacheHitBytes 

func (m *TiFlashScanContext) GetDisaggReadCacheHitBytes() uint64

func (*TiFlashScanContext) GetDisaggReadCacheMissBytes 

func (m *TiFlashScanContext) GetDisaggReadCacheMissBytes() uint64

func (*TiFlashScanContext) GetDmfileDataScannedRows 

func (m *TiFlashScanContext) GetDmfileDataScannedRows() uint64

func (*TiFlashScanContext) GetDmfileDataSkippedRows 

func (m *TiFlashScanContext) GetDmfileDataSkippedRows() uint64

func (*TiFlashScanContext) GetDmfileLmFilterScannedRows 

func (m *TiFlashScanContext) GetDmfileLmFilterScannedRows() uint64

func (*TiFlashScanContext) GetDmfileLmFilterSkippedRows 

func (m *TiFlashScanContext) GetDmfileLmFilterSkippedRows() uint64

func (*TiFlashScanContext) GetDmfileMvccScannedRows 

func (m *TiFlashScanContext) GetDmfileMvccScannedRows() uint64

func (*TiFlashScanContext) GetDmfileMvccSkippedRows 

func (m *TiFlashScanContext) GetDmfileMvccSkippedRows() uint64

func (*TiFlashScanContext) GetDmfileScannedPacks 

func (m *TiFlashScanContext) GetDmfileScannedPacks() uint64

func (*TiFlashScanContext) GetDmfileSkippedPacks 

func (m *TiFlashScanContext) GetDmfileSkippedPacks() uint64

func (*TiFlashScanContext) GetLmSkipRows 

func (m *TiFlashScanContext) GetLmSkipRows() uint64

func (*TiFlashScanContext) GetLocalRegions 

func (m *TiFlashScanContext) GetLocalRegions() uint64

func (*TiFlashScanContext) GetMaxLocalStreamMs 

func (m *TiFlashScanContext) GetMaxLocalStreamMs() uint64

func (*TiFlashScanContext) GetMaxRemoteStreamMs 

func (m *TiFlashScanContext) GetMaxRemoteStreamMs() uint64

func (*TiFlashScanContext) GetMinLocalStreamMs 

func (m *TiFlashScanContext) GetMinLocalStreamMs() uint64

func (*TiFlashScanContext) GetMinRemoteStreamMs 

func (m *TiFlashScanContext) GetMinRemoteStreamMs() uint64

func (*TiFlashScanContext) GetMvccInputBytes 

func (m *TiFlashScanContext) GetMvccInputBytes() uint64

func (*TiFlashScanContext) GetMvccInputRows 

func (m *TiFlashScanContext) GetMvccInputRows() uint64

func (*TiFlashScanContext) GetMvccOutputRows 

func (m *TiFlashScanContext) GetMvccOutputRows() uint64

func (*TiFlashScanContext) GetReadTasks 

func (m *TiFlashScanContext) GetReadTasks() uint64

func (*TiFlashScanContext) GetRegionsOfInstance 

func (m *TiFlashScanContext) GetRegionsOfInstance() []*TiFlashRegionNumOfInstance

func (*TiFlashScanContext) GetRemoteRegions 

func (m *TiFlashScanContext) GetRemoteRegions() uint64

func (*TiFlashScanContext) GetSegments 

func (m *TiFlashScanContext) GetSegments() uint64

func (*TiFlashScanContext) GetStaleReadRegions 

func (m *TiFlashScanContext) GetStaleReadRegions() uint64

func (*TiFlashScanContext) GetTotalBuildBitmapMs 

func (m *TiFlashScanContext) GetTotalBuildBitmapMs() uint64

func (*TiFlashScanContext) GetTotalBuildInputstreamMs 

func (m *TiFlashScanContext) GetTotalBuildInputstreamMs() uint64

func (*TiFlashScanContext) GetTotalBuildSnapshotMs 

func (m *TiFlashScanContext) GetTotalBuildSnapshotMs() uint64

func (*TiFlashScanContext) GetTotalDmfileReadMs 

func (m *TiFlashScanContext) GetTotalDmfileReadMs() uint64

func (*TiFlashScanContext) GetTotalDmfileRsCheckMs 

func (m *TiFlashScanContext) GetTotalDmfileRsCheckMs() uint64

func (*TiFlashScanContext) GetTotalDmfileRsLoadMs 

func (m *TiFlashScanContext) GetTotalDmfileRsLoadMs() uint64

func (*TiFlashScanContext) GetTotalLearnerReadMs 

func (m *TiFlashScanContext) GetTotalLearnerReadMs() uint64

func (*TiFlashScanContext) GetTotalVectorIdxLoadFromCache 

func (m *TiFlashScanContext) GetTotalVectorIdxLoadFromCache() uint64

func (*TiFlashScanContext) GetTotalVectorIdxLoadFromDisk 

func (m *TiFlashScanContext) GetTotalVectorIdxLoadFromDisk() uint64

func (*TiFlashScanContext) GetTotalVectorIdxLoadFromS3 

func (m *TiFlashScanContext) GetTotalVectorIdxLoadFromS3() uint64

func (*TiFlashScanContext) GetTotalVectorIdxLoadTimeMs 

func (m *TiFlashScanContext) GetTotalVectorIdxLoadTimeMs() uint64

func (*TiFlashScanContext) GetTotalVectorIdxReadOthersTimeMs 

func (m *TiFlashScanContext) GetTotalVectorIdxReadOthersTimeMs() uint64

func (*TiFlashScanContext) GetTotalVectorIdxReadVecTimeMs 

func (m *TiFlashScanContext) GetTotalVectorIdxReadVecTimeMs() uint64

func (*TiFlashScanContext) GetTotalVectorIdxSearchDiscardedNodes 

func (m *TiFlashScanContext) GetTotalVectorIdxSearchDiscardedNodes() uint64

func (*TiFlashScanContext) GetTotalVectorIdxSearchTimeMs 

func (m *TiFlashScanContext) GetTotalVectorIdxSearchTimeMs() uint64

func (*TiFlashScanContext) GetTotalVectorIdxSearchVisitedNodes 

func (m *TiFlashScanContext) GetTotalVectorIdxSearchVisitedNodes() uint64

func (*TiFlashScanContext) GetUserReadBytes 

func (m *TiFlashScanContext) GetUserReadBytes() uint64

func (*TiFlashScanContext) Marshal 

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

func (*TiFlashScanContext) MarshalTo 

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

func (*TiFlashScanContext) ProtoMessage 

func (*TiFlashScanContext) ProtoMessage()

func (*TiFlashScanContext) Reset 

func (m *TiFlashScanContext) Reset()

func (*TiFlashScanContext) Size 

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

func (*TiFlashScanContext) String 

func (m *TiFlashScanContext) String() string

func (*TiFlashScanContext) Unmarshal 

func (m *TiFlashScanContext) 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"`
	// If partition_by is not empty, it means need to return topN of each partition.
	// Generally used in sqls like `where row_number() over (partition by ... order by ...) < X`
	PartitionBy      []*ByItem `protobuf:"bytes,4,rep,name=partition_by,json=partitionBy" json:"partition_by,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) GetPartitionBy 

func (m *TopN) GetPartitionBy() []*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 TopSQLAgentClient 

type TopSQLAgentClient interface {
	// ReportTopSQLRecords is called periodically (e.g. per minute) to save the in-memory TopSQL records
	ReportTopSQLRecords(ctx context.Context, opts ...grpc.CallOption) (TopSQLAgent_ReportTopSQLRecordsClient, error)
	// ReportSQLMeta reports SQL meta to the agent.
	// The agent should ensure that the SQL meta exists before sending the SQL CPU time records to the remote database.
	ReportSQLMeta(ctx context.Context, opts ...grpc.CallOption) (TopSQLAgent_ReportSQLMetaClient, error)
	// ReportPlanMeta reports plan meta to the agent.
	// The agent should deal with plan meta similarly to SQL meta.
	ReportPlanMeta(ctx context.Context, opts ...grpc.CallOption) (TopSQLAgent_ReportPlanMetaClient, error)
}

func NewTopSQLAgentClient 

func NewTopSQLAgentClient(cc *grpc.ClientConn) TopSQLAgentClient

type TopSQLAgentServer 

type TopSQLAgentServer interface {
	// ReportTopSQLRecords is called periodically (e.g. per minute) to save the in-memory TopSQL records
	ReportTopSQLRecords(TopSQLAgent_ReportTopSQLRecordsServer) error
	// ReportSQLMeta reports SQL meta to the agent.
	// The agent should ensure that the SQL meta exists before sending the SQL CPU time records to the remote database.
	ReportSQLMeta(TopSQLAgent_ReportSQLMetaServer) error
	// ReportPlanMeta reports plan meta to the agent.
	// The agent should deal with plan meta similarly to SQL meta.
	ReportPlanMeta(TopSQLAgent_ReportPlanMetaServer) error
}

type TopSQLAgent_ReportPlanMetaClient 

type TopSQLAgent_ReportPlanMetaClient interface {
	Send(*PlanMeta) error
	CloseAndRecv() (*EmptyResponse, error)
	grpc.ClientStream
}

type TopSQLAgent_ReportPlanMetaServer 

type TopSQLAgent_ReportPlanMetaServer interface {
	SendAndClose(*EmptyResponse) error
	Recv() (*PlanMeta, error)
	grpc.ServerStream
}

type TopSQLAgent_ReportSQLMetaClient 

type TopSQLAgent_ReportSQLMetaClient interface {
	Send(*SQLMeta) error
	CloseAndRecv() (*EmptyResponse, error)
	grpc.ClientStream
}

type TopSQLAgent_ReportSQLMetaServer 

type TopSQLAgent_ReportSQLMetaServer interface {
	SendAndClose(*EmptyResponse) error
	Recv() (*SQLMeta, error)
	grpc.ServerStream
}

type TopSQLAgent_ReportTopSQLRecordsClient 

type TopSQLAgent_ReportTopSQLRecordsClient interface {
	Send(*TopSQLRecord) error
	CloseAndRecv() (*EmptyResponse, error)
	grpc.ClientStream
}

type TopSQLAgent_ReportTopSQLRecordsServer 

type TopSQLAgent_ReportTopSQLRecordsServer interface {
	SendAndClose(*EmptyResponse) error
	Recv() (*TopSQLRecord, error)
	grpc.ServerStream
}

type TopSQLPubSubClient 

type TopSQLPubSubClient interface {
	// Clients subscribe to TopSQL data through this RPC, and TiDB periodically (e.g. per minute)
	// publishes TopSQL data to clients via gRPC stream.
	Subscribe(ctx context.Context, in *TopSQLSubRequest, opts ...grpc.CallOption) (TopSQLPubSub_SubscribeClient, error)
}

func NewTopSQLPubSubClient 

func NewTopSQLPubSubClient(cc *grpc.ClientConn) TopSQLPubSubClient

type TopSQLPubSubServer 

type TopSQLPubSubServer interface {
	// Clients subscribe to TopSQL data through this RPC, and TiDB periodically (e.g. per minute)
	// publishes TopSQL data to clients via gRPC stream.
	Subscribe(*TopSQLSubRequest, TopSQLPubSub_SubscribeServer) error
}

type TopSQLPubSub_SubscribeClient 

type TopSQLPubSub_SubscribeClient interface {
	Recv() (*TopSQLSubResponse, error)
	grpc.ClientStream
}

type TopSQLPubSub_SubscribeServer 

type TopSQLPubSub_SubscribeServer interface {
	Send(*TopSQLSubResponse) error
	grpc.ServerStream
}

type TopSQLRecord 

type TopSQLRecord struct {
	SqlDigest  []byte              `protobuf:"bytes,1,opt,name=sql_digest,json=sqlDigest,proto3" json:"sql_digest,omitempty"`
	PlanDigest []byte              `protobuf:"bytes,2,opt,name=plan_digest,json=planDigest,proto3" json:"plan_digest,omitempty"`
	Items      []*TopSQLRecordItem `protobuf:"bytes,3,rep,name=items" json:"items,omitempty"`
}

func (*TopSQLRecord) Descriptor 

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

func (*TopSQLRecord) GetItems 

func (m *TopSQLRecord) GetItems() []*TopSQLRecordItem

func (*TopSQLRecord) GetPlanDigest 

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

func (*TopSQLRecord) GetSqlDigest 

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

func (*TopSQLRecord) Marshal 

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

func (*TopSQLRecord) MarshalTo 

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

func (*TopSQLRecord) ProtoMessage 

func (*TopSQLRecord) ProtoMessage()

func (*TopSQLRecord) Reset 

func (m *TopSQLRecord) Reset()

func (*TopSQLRecord) Size 

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

func (*TopSQLRecord) String 

func (m *TopSQLRecord) String() string

func (*TopSQLRecord) Unmarshal 

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

type TopSQLRecordItem 

type TopSQLRecordItem struct {
	TimestampSec      uint64            `protobuf:"varint,1,opt,name=timestamp_sec,json=timestampSec,proto3" json:"timestamp_sec,omitempty"`
	CpuTimeMs         uint32            `protobuf:"varint,2,opt,name=cpu_time_ms,json=cpuTimeMs,proto3" json:"cpu_time_ms,omitempty"`
	StmtExecCount     uint64            `protobuf:"varint,3,opt,name=stmt_exec_count,json=stmtExecCount,proto3" json:"stmt_exec_count,omitempty"`
	StmtKvExecCount   map[string]uint64 `` /* 192-byte string literal not displayed */
	StmtDurationSumNs uint64            `protobuf:"varint,5,opt,name=stmt_duration_sum_ns,json=stmtDurationSumNs,proto3" json:"stmt_duration_sum_ns,omitempty"`
	StmtDurationCount uint64            `protobuf:"varint,6,opt,name=stmt_duration_count,json=stmtDurationCount,proto3" json:"stmt_duration_count,omitempty"`
}

func (*TopSQLRecordItem) Descriptor 

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

func (*TopSQLRecordItem) GetCpuTimeMs 

func (m *TopSQLRecordItem) GetCpuTimeMs() uint32

func (*TopSQLRecordItem) GetStmtDurationCount 

func (m *TopSQLRecordItem) GetStmtDurationCount() uint64

func (*TopSQLRecordItem) GetStmtDurationSumNs 

func (m *TopSQLRecordItem) GetStmtDurationSumNs() uint64

func (*TopSQLRecordItem) GetStmtExecCount 

func (m *TopSQLRecordItem) GetStmtExecCount() uint64

func (*TopSQLRecordItem) GetStmtKvExecCount 

func (m *TopSQLRecordItem) GetStmtKvExecCount() map[string]uint64

func (*TopSQLRecordItem) GetTimestampSec 

func (m *TopSQLRecordItem) GetTimestampSec() uint64

func (*TopSQLRecordItem) Marshal 

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

func (*TopSQLRecordItem) MarshalTo 

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

func (*TopSQLRecordItem) ProtoMessage 

func (*TopSQLRecordItem) ProtoMessage()

func (*TopSQLRecordItem) Reset 

func (m *TopSQLRecordItem) Reset()

func (*TopSQLRecordItem) Size 

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

func (*TopSQLRecordItem) String 

func (m *TopSQLRecordItem) String() string

func (*TopSQLRecordItem) Unmarshal 

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

type TopSQLSubRequest 

type TopSQLSubRequest struct {
}

func (*TopSQLSubRequest) Descriptor 

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

func (*TopSQLSubRequest) Marshal 

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

func (*TopSQLSubRequest) MarshalTo 

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

func (*TopSQLSubRequest) ProtoMessage 

func (*TopSQLSubRequest) ProtoMessage()

func (*TopSQLSubRequest) Reset 

func (m *TopSQLSubRequest) Reset()

func (*TopSQLSubRequest) Size 

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

func (*TopSQLSubRequest) String 

func (m *TopSQLSubRequest) String() string

func (*TopSQLSubRequest) Unmarshal 

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

type TopSQLSubResponse 

type TopSQLSubResponse struct {
	// Types that are valid to be assigned to RespOneof:
	//	*TopSQLSubResponse_Record
	//	*TopSQLSubResponse_SqlMeta
	//	*TopSQLSubResponse_PlanMeta
	RespOneof isTopSQLSubResponse_RespOneof `protobuf_oneof:"resp_oneof"`
}

func (*TopSQLSubResponse) Descriptor 

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

func (*TopSQLSubResponse) GetPlanMeta 

func (m *TopSQLSubResponse) GetPlanMeta() *PlanMeta

func (*TopSQLSubResponse) GetRecord 

func (m *TopSQLSubResponse) GetRecord() *TopSQLRecord

func (*TopSQLSubResponse) GetRespOneof 

func (m *TopSQLSubResponse) GetRespOneof() isTopSQLSubResponse_RespOneof

func (*TopSQLSubResponse) GetSqlMeta 

func (m *TopSQLSubResponse) GetSqlMeta() *SQLMeta

func (*TopSQLSubResponse) Marshal 

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

func (*TopSQLSubResponse) MarshalTo 

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

func (*TopSQLSubResponse) ProtoMessage 

func (*TopSQLSubResponse) ProtoMessage()

func (*TopSQLSubResponse) Reset 

func (m *TopSQLSubResponse) Reset()

func (*TopSQLSubResponse) Size 

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

func (*TopSQLSubResponse) String 

func (m *TopSQLSubResponse) String() string

func (*TopSQLSubResponse) Unmarshal 

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

func (*TopSQLSubResponse) XXX_OneofFuncs 

func (*TopSQLSubResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type TopSQLSubResponse_PlanMeta 

type TopSQLSubResponse_PlanMeta struct {
	PlanMeta *PlanMeta `protobuf:"bytes,3,opt,name=plan_meta,json=planMeta,oneof"`
}

func (*TopSQLSubResponse_PlanMeta) MarshalTo 

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

func (*TopSQLSubResponse_PlanMeta) Size 

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

type TopSQLSubResponse_Record 

type TopSQLSubResponse_Record struct {
	Record *TopSQLRecord `protobuf:"bytes,1,opt,name=record,oneof"`
}

func (*TopSQLSubResponse_Record) MarshalTo 

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

func (*TopSQLSubResponse_Record) Size 

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

type TopSQLSubResponse_SqlMeta 

type TopSQLSubResponse_SqlMeta struct {
	SqlMeta *SQLMeta `protobuf:"bytes,2,opt,name=sql_meta,json=sqlMeta,oneof"`
}

func (*TopSQLSubResponse_SqlMeta) MarshalTo 

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

func (*TopSQLSubResponse_SqlMeta) Size 

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

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

type VectorDistanceMetric 

type VectorDistanceMetric int32

Note: The name of the enum is intentionally aligned with tidb/parser/index_vector.go. 

const (
	VectorDistanceMetric_INVALID_DISTANCE_METRIC VectorDistanceMetric = 0
	VectorDistanceMetric_L1                      VectorDistanceMetric = 1
	VectorDistanceMetric_L2                      VectorDistanceMetric = 2
	VectorDistanceMetric_COSINE                  VectorDistanceMetric = 3
	VectorDistanceMetric_INNER_PRODUCT           VectorDistanceMetric = 4
)

func (VectorDistanceMetric) Enum 

func (x VectorDistanceMetric) Enum() *VectorDistanceMetric

func (VectorDistanceMetric) EnumDescriptor 

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

func (VectorDistanceMetric) String 

func (x VectorDistanceMetric) String() string

func (*VectorDistanceMetric) UnmarshalJSON 

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

type VectorIndexKind 

type VectorIndexKind int32

Note: The name of the enum is intentionally aligned with tidb/parser/index_vector.go. 

const (
	VectorIndexKind_INVALID_INDEX_KIND VectorIndexKind = 0
	VectorIndexKind_HNSW               VectorIndexKind = 1
)

func (VectorIndexKind) Enum 

func (x VectorIndexKind) Enum() *VectorIndexKind

func (VectorIndexKind) EnumDescriptor 

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

func (VectorIndexKind) String 

func (x VectorIndexKind) String() string

func (*VectorIndexKind) UnmarshalJSON 

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

type Window 

type Window struct {
	FuncDesc         []*Expr      `protobuf:"bytes,1,rep,name=func_desc,json=funcDesc" json:"func_desc,omitempty"`
	PartitionBy      []*ByItem    `protobuf:"bytes,2,rep,name=partition_by,json=partitionBy" json:"partition_by,omitempty"`
	OrderBy          []*ByItem    `protobuf:"bytes,3,rep,name=order_by,json=orderBy" json:"order_by,omitempty"`
	Frame            *WindowFrame `protobuf:"bytes,4,opt,name=frame" json:"frame,omitempty"`
	Child            *Executor    `protobuf:"bytes,5,opt,name=child" json:"child,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*Window) Descriptor 

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

func (*Window) GetChild 

func (m *Window) GetChild() *Executor

func (*Window) GetFrame 

func (m *Window) GetFrame() *WindowFrame

func (*Window) GetFuncDesc 

func (m *Window) GetFuncDesc() []*Expr

func (*Window) GetOrderBy 

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

func (*Window) GetPartitionBy 

func (m *Window) GetPartitionBy() []*ByItem

func (*Window) Marshal 

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

func (*Window) MarshalTo 

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

func (*Window) ProtoMessage 

func (*Window) ProtoMessage()

func (*Window) Reset 

func (m *Window) Reset()

func (*Window) Size 

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

func (*Window) String 

func (m *Window) String() string

func (*Window) Unmarshal 

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

type WindowBoundType 

type WindowBoundType int32
const (
	WindowBoundType_Following  WindowBoundType = 0
	WindowBoundType_Preceding  WindowBoundType = 1
	WindowBoundType_CurrentRow WindowBoundType = 2
)

func (WindowBoundType) Enum 

func (x WindowBoundType) Enum() *WindowBoundType

func (WindowBoundType) EnumDescriptor 

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

func (WindowBoundType) String 

func (x WindowBoundType) String() string

func (*WindowBoundType) UnmarshalJSON 

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

type WindowFrame 

type WindowFrame struct {
	Type             WindowFrameType   `protobuf:"varint,1,opt,name=type,enum=tipb.WindowFrameType" json:"type"`
	Start            *WindowFrameBound `protobuf:"bytes,2,opt,name=start" json:"start,omitempty"`
	End              *WindowFrameBound `protobuf:"bytes,3,opt,name=end" json:"end,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*WindowFrame) Descriptor 

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

func (*WindowFrame) GetEnd 

func (m *WindowFrame) GetEnd() *WindowFrameBound

func (*WindowFrame) GetStart 

func (m *WindowFrame) GetStart() *WindowFrameBound

func (*WindowFrame) GetType 

func (m *WindowFrame) GetType() WindowFrameType

func (*WindowFrame) Marshal 

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

func (*WindowFrame) MarshalTo 

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

func (*WindowFrame) ProtoMessage 

func (*WindowFrame) ProtoMessage()

func (*WindowFrame) Reset 

func (m *WindowFrame) Reset()

func (*WindowFrame) Size 

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

func (*WindowFrame) String 

func (m *WindowFrame) String() string

func (*WindowFrame) Unmarshal 

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

type WindowFrameBound 

type WindowFrameBound struct {
	Type             WindowBoundType   `protobuf:"varint,1,opt,name=type,enum=tipb.WindowBoundType" json:"type"`
	Unbounded        bool              `protobuf:"varint,2,opt,name=unbounded" json:"unbounded"`
	Offset           *uint64           `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	CalcFuncs        []*Expr           `protobuf:"bytes,4,rep,name=calcFuncs" json:"calcFuncs,omitempty"`
	FrameRange       *Expr             `protobuf:"bytes,5,opt,name=frame_range,json=frameRange" json:"frame_range,omitempty"`
	CmpDataType      *RangeCmpDataType `protobuf:"varint,6,opt,name=cmp_data_type,json=cmpDataType,enum=tipb.RangeCmpDataType" json:"cmp_data_type,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*WindowFrameBound) Descriptor 

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

func (*WindowFrameBound) GetCalcFuncs 

func (m *WindowFrameBound) GetCalcFuncs() []*Expr

func (*WindowFrameBound) GetCmpDataType 

func (m *WindowFrameBound) GetCmpDataType() RangeCmpDataType

func (*WindowFrameBound) GetFrameRange 

func (m *WindowFrameBound) GetFrameRange() *Expr

func (*WindowFrameBound) GetOffset 

func (m *WindowFrameBound) GetOffset() uint64

func (*WindowFrameBound) GetType 

func (m *WindowFrameBound) GetType() WindowBoundType

func (*WindowFrameBound) GetUnbounded 

func (m *WindowFrameBound) GetUnbounded() bool

func (*WindowFrameBound) Marshal 

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

func (*WindowFrameBound) MarshalTo 

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

func (*WindowFrameBound) ProtoMessage 

func (*WindowFrameBound) ProtoMessage()

func (*WindowFrameBound) Reset 

func (m *WindowFrameBound) Reset()

func (*WindowFrameBound) Size 

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

func (*WindowFrameBound) String 

func (m *WindowFrameBound) String() string

func (*WindowFrameBound) Unmarshal 

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

type WindowFrameType 

type WindowFrameType int32
const (
	WindowFrameType_Rows   WindowFrameType = 0
	WindowFrameType_Ranges WindowFrameType = 1
	WindowFrameType_Groups WindowFrameType = 2
)

func (WindowFrameType) Enum 

func (x WindowFrameType) Enum() *WindowFrameType

func (WindowFrameType) EnumDescriptor 

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

func (WindowFrameType) String 

func (x WindowFrameType) String() string

func (*WindowFrameType) UnmarshalJSON 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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