tipb

package
v0.0.0-...-c822141 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

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")
	ErrUnexpectedEndOfGroupAnalyze = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthChecksum        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowChecksum          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupChecksum = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthExecutor        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecutor          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExecutor = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthExplain        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExplain          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExplain = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthExpression        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExpression          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExpression = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthResourcetag        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourcetag          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResourcetag = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSchema        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchema          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSchema = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSelect        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSelect          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSelect = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTopsqlAgent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopsqlAgent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTopsqlAgent = fmt.Errorf("proto: unexpected end of group")
)
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 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",
}
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,
}
View Source 
var ExprType_name = map[int32]string{
	0:     "Null",
	1:     "Int64",
	2:     "Uint64",
	3:     "Float32",
	4:     "Float64",
	5:     "String",
	6:     "Bytes",
	101:   "MysqlBit",
	102:   "MysqlDecimal",
	103:   "MysqlDuration",
	104:   "MysqlEnum",
	105:   "MysqlHex",
	106:   "MysqlSet",
	107:   "MysqlTime",
	108:   "MysqlJson",
	151:   "ValueList",
	201:   "ColumnRef",
	3001:  "Count",
	3002:  "Sum",
	3003:  "Avg",
	3004:  "Min",
	3005:  "Max",
	3006:  "First",
	3007:  "GroupConcat",
	3008:  "Agg_BitAnd",
	3009:  "Agg_BitOr",
	3010:  "Agg_BitXor",
	3011:  "Std",
	3012:  "Stddev",
	3013:  "StddevPop",
	3014:  "StddevSamp",
	3015:  "VarPop",
	3016:  "VarSamp",
	3017:  "Variance",
	3018:  "JsonArrayAgg",
	3019:  "JsonObjectAgg",
	3020:  "ApproxCountDistinct",
	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,
	"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 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 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 ScalarFuncSig_name = map[int32]string{}/* 580 elements not displayed */
View Source 
var ScalarFuncSig_value = map[string]int32{}/* 580 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 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 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"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

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

func (m *AccessObject) MarshalToSizedBuffer(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_DiscardUnknown 

func (m *AccessObject) XXX_DiscardUnknown()

func (*AccessObject) XXX_Marshal 

func (m *AccessObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccessObject) XXX_Merge 

func (m *AccessObject) XXX_Merge(src proto.Message)

func (*AccessObject) XXX_OneofWrappers 

func (*AccessObject) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AccessObject) XXX_Size 

func (m *AccessObject) XXX_Size() int

func (*AccessObject) XXX_Unmarshal 

func (m *AccessObject) XXX_Unmarshal(b []byte) error

type AccessObject_DynamicPartitionObjects 

type AccessObject_DynamicPartitionObjects struct {
	DynamicPartitionObjects *DynamicPartitionAccessObjects `` /* 138-byte string literal not displayed */
}

func (*AccessObject_DynamicPartitionObjects) MarshalTo 

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

func (*AccessObject_DynamicPartitionObjects) MarshalToSizedBuffer 

func (m *AccessObject_DynamicPartitionObjects) MarshalToSizedBuffer(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" json:"other_object,omitempty"`
}

func (*AccessObject_OtherObject) MarshalTo 

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

func (*AccessObject_OtherObject) MarshalToSizedBuffer 

func (m *AccessObject_OtherObject) MarshalToSizedBuffer(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,proto3,oneof" json:"scan_object,omitempty"`
}

func (*AccessObject_ScanObject) MarshalTo 

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

func (*AccessObject_ScanObject) MarshalToSizedBuffer 

func (m *AccessObject_ScanObject) MarshalToSizedBuffer(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_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `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) MarshalToSizedBuffer 

func (m *Aggregation) MarshalToSizedBuffer(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

func (*Aggregation) XXX_DiscardUnknown 

func (m *Aggregation) XXX_DiscardUnknown()

func (*Aggregation) XXX_Marshal 

func (m *Aggregation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Aggregation) XXX_Merge 

func (m *Aggregation) XXX_Merge(src proto.Message)

func (*Aggregation) XXX_Size 

func (m *Aggregation) XXX_Size() int

func (*Aggregation) XXX_Unmarshal 

func (m *Aggregation) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *AnalyzeColumnGroup) MarshalToSizedBuffer(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

func (*AnalyzeColumnGroup) XXX_DiscardUnknown 

func (m *AnalyzeColumnGroup) XXX_DiscardUnknown()

func (*AnalyzeColumnGroup) XXX_Marshal 

func (m *AnalyzeColumnGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalyzeColumnGroup) XXX_Merge 

func (m *AnalyzeColumnGroup) XXX_Merge(src proto.Message)

func (*AnalyzeColumnGroup) XXX_Size 

func (m *AnalyzeColumnGroup) XXX_Size() int

func (*AnalyzeColumnGroup) XXX_Unmarshal 

func (m *AnalyzeColumnGroup) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *AnalyzeColumnsReq) MarshalToSizedBuffer(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

func (*AnalyzeColumnsReq) XXX_DiscardUnknown 

func (m *AnalyzeColumnsReq) XXX_DiscardUnknown()

func (*AnalyzeColumnsReq) XXX_Marshal 

func (m *AnalyzeColumnsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalyzeColumnsReq) XXX_Merge 

func (m *AnalyzeColumnsReq) XXX_Merge(src proto.Message)

func (*AnalyzeColumnsReq) XXX_Size 

func (m *AnalyzeColumnsReq) XXX_Size() int

func (*AnalyzeColumnsReq) XXX_Unmarshal 

func (m *AnalyzeColumnsReq) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `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) MarshalToSizedBuffer 

func (m *AnalyzeColumnsResp) MarshalToSizedBuffer(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

func (*AnalyzeColumnsResp) XXX_DiscardUnknown 

func (m *AnalyzeColumnsResp) XXX_DiscardUnknown()

func (*AnalyzeColumnsResp) XXX_Marshal 

func (m *AnalyzeColumnsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalyzeColumnsResp) XXX_Merge 

func (m *AnalyzeColumnsResp) XXX_Merge(src proto.Message)

func (*AnalyzeColumnsResp) XXX_Size 

func (m *AnalyzeColumnsResp) XXX_Size() int

func (*AnalyzeColumnsResp) XXX_Unmarshal 

func (m *AnalyzeColumnsResp) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *AnalyzeIndexReq) MarshalToSizedBuffer(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

func (*AnalyzeIndexReq) XXX_DiscardUnknown 

func (m *AnalyzeIndexReq) XXX_DiscardUnknown()

func (*AnalyzeIndexReq) XXX_Marshal 

func (m *AnalyzeIndexReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalyzeIndexReq) XXX_Merge 

func (m *AnalyzeIndexReq) XXX_Merge(src proto.Message)

func (*AnalyzeIndexReq) XXX_Size 

func (m *AnalyzeIndexReq) XXX_Size() int

func (*AnalyzeIndexReq) XXX_Unmarshal 

func (m *AnalyzeIndexReq) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `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) MarshalToSizedBuffer 

func (m *AnalyzeIndexResp) MarshalToSizedBuffer(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

func (*AnalyzeIndexResp) XXX_DiscardUnknown 

func (m *AnalyzeIndexResp) XXX_DiscardUnknown()

func (*AnalyzeIndexResp) XXX_Marshal 

func (m *AnalyzeIndexResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalyzeIndexResp) XXX_Merge 

func (m *AnalyzeIndexResp) XXX_Merge(src proto.Message)

func (*AnalyzeIndexResp) XXX_Size 

func (m *AnalyzeIndexResp) XXX_Size() int

func (*AnalyzeIndexResp) XXX_Unmarshal 

func (m *AnalyzeIndexResp) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `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) MarshalToSizedBuffer 

func (m *AnalyzeMixedResp) MarshalToSizedBuffer(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

func (*AnalyzeMixedResp) XXX_DiscardUnknown 

func (m *AnalyzeMixedResp) XXX_DiscardUnknown()

func (*AnalyzeMixedResp) XXX_Marshal 

func (m *AnalyzeMixedResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalyzeMixedResp) XXX_Merge 

func (m *AnalyzeMixedResp) XXX_Merge(src proto.Message)

func (*AnalyzeMixedResp) XXX_Size 

func (m *AnalyzeMixedResp) XXX_Size() int

func (*AnalyzeMixedResp) XXX_Unmarshal 

func (m *AnalyzeMixedResp) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `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) MarshalToSizedBuffer 

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

func (*AnalyzeReq) XXX_DiscardUnknown 

func (m *AnalyzeReq) XXX_DiscardUnknown()

func (*AnalyzeReq) XXX_Marshal 

func (m *AnalyzeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalyzeReq) XXX_Merge 

func (m *AnalyzeReq) XXX_Merge(src proto.Message)

func (*AnalyzeReq) XXX_Size 

func (m *AnalyzeReq) XXX_Size() int

func (*AnalyzeReq) XXX_Unmarshal 

func (m *AnalyzeReq) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *Bucket) MarshalToSizedBuffer(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

func (*Bucket) XXX_DiscardUnknown 

func (m *Bucket) XXX_DiscardUnknown()

func (*Bucket) XXX_Marshal 

func (m *Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Bucket) XXX_Merge 

func (m *Bucket) XXX_Merge(src proto.Message)

func (*Bucket) XXX_Size 

func (m *Bucket) XXX_Size() int

func (*Bucket) XXX_Unmarshal 

func (m *Bucket) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *ByItem) MarshalToSizedBuffer(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

func (*ByItem) XXX_DiscardUnknown 

func (m *ByItem) XXX_DiscardUnknown()

func (*ByItem) XXX_Marshal 

func (m *ByItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ByItem) XXX_Merge 

func (m *ByItem) XXX_Merge(src proto.Message)

func (*ByItem) XXX_Size 

func (m *ByItem) XXX_Size() int

func (*ByItem) XXX_Unmarshal 

func (m *ByItem) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `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) MarshalToSizedBuffer 

func (m *CMSketch) MarshalToSizedBuffer(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

func (*CMSketch) XXX_DiscardUnknown 

func (m *CMSketch) XXX_DiscardUnknown()

func (*CMSketch) XXX_Marshal 

func (m *CMSketch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CMSketch) XXX_Merge 

func (m *CMSketch) XXX_Merge(src proto.Message)

func (*CMSketch) XXX_Size 

func (m *CMSketch) XXX_Size() int

func (*CMSketch) XXX_Unmarshal 

func (m *CMSketch) XXX_Unmarshal(b []byte) error

type CMSketchRow 

type CMSketchRow struct {
	Counters             []uint32 `protobuf:"varint,1,rep,name=counters" json:"counters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *CMSketchRow) MarshalToSizedBuffer(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

func (*CMSketchRow) XXX_DiscardUnknown 

func (m *CMSketchRow) XXX_DiscardUnknown()

func (*CMSketchRow) XXX_Marshal 

func (m *CMSketchRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CMSketchRow) XXX_Merge 

func (m *CMSketchRow) XXX_Merge(src proto.Message)

func (*CMSketchRow) XXX_Size 

func (m *CMSketchRow) XXX_Size() int

func (*CMSketchRow) XXX_Unmarshal 

func (m *CMSketchRow) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *CMSketchTopN) MarshalToSizedBuffer(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

func (*CMSketchTopN) XXX_DiscardUnknown 

func (m *CMSketchTopN) XXX_DiscardUnknown()

func (*CMSketchTopN) XXX_Marshal 

func (m *CMSketchTopN) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CMSketchTopN) XXX_Merge 

func (m *CMSketchTopN) XXX_Merge(src proto.Message)

func (*CMSketchTopN) XXX_Size 

func (m *CMSketchTopN) XXX_Size() int

func (*CMSketchTopN) XXX_Unmarshal 

func (m *CMSketchTopN) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `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) MarshalToSizedBuffer 

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

func (*ChecksumRequest) XXX_DiscardUnknown 

func (m *ChecksumRequest) XXX_DiscardUnknown()

func (*ChecksumRequest) XXX_Marshal 

func (m *ChecksumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChecksumRequest) XXX_Merge 

func (m *ChecksumRequest) XXX_Merge(src proto.Message)

func (*ChecksumRequest) XXX_Size 

func (m *ChecksumRequest) XXX_Size() int

func (*ChecksumRequest) XXX_Unmarshal 

func (m *ChecksumRequest) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *ChecksumResponse) MarshalToSizedBuffer(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

func (*ChecksumResponse) XXX_DiscardUnknown 

func (m *ChecksumResponse) XXX_DiscardUnknown()

func (*ChecksumResponse) XXX_Marshal 

func (m *ChecksumResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChecksumResponse) XXX_Merge 

func (m *ChecksumResponse) XXX_Merge(src proto.Message)

func (*ChecksumResponse) XXX_Size 

func (m *ChecksumResponse) XXX_Size() int

func (*ChecksumResponse) XXX_Unmarshal 

func (m *ChecksumResponse) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *ChecksumRewriteRule) MarshalToSizedBuffer(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

func (*ChecksumRewriteRule) XXX_DiscardUnknown 

func (m *ChecksumRewriteRule) XXX_DiscardUnknown()

func (*ChecksumRewriteRule) XXX_Marshal 

func (m *ChecksumRewriteRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChecksumRewriteRule) XXX_Merge 

func (m *ChecksumRewriteRule) XXX_Merge(src proto.Message)

func (*ChecksumRewriteRule) XXX_Size 

func (m *ChecksumRewriteRule) XXX_Size() int

func (*ChecksumRewriteRule) XXX_Unmarshal 

func (m *ChecksumRewriteRule) XXX_Unmarshal(b []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_ab111404212_tipb_sharedbytes.SharedBytes `` /* 131-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_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `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) MarshalToSizedBuffer 

func (m *Chunk) MarshalToSizedBuffer(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

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chunk) XXX_Merge 

func (m *Chunk) XXX_Merge(src proto.Message)

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

func (m *Chunk) XXX_Unmarshal(b []byte) error

type ChunkMemoryLayout 

type ChunkMemoryLayout struct {
	// Represents the endian.
	Endian               Endian   `protobuf:"varint,1,opt,name=endian,enum=tipb.Endian" json:"endian"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *ChunkMemoryLayout) MarshalToSizedBuffer(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

func (*ChunkMemoryLayout) XXX_DiscardUnknown 

func (m *ChunkMemoryLayout) XXX_DiscardUnknown()

func (*ChunkMemoryLayout) XXX_Marshal 

func (m *ChunkMemoryLayout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChunkMemoryLayout) XXX_Merge 

func (m *ChunkMemoryLayout) XXX_Merge(src proto.Message)

func (*ChunkMemoryLayout) XXX_Size 

func (m *ChunkMemoryLayout) XXX_Size() int

func (*ChunkMemoryLayout) XXX_Unmarshal 

func (m *ChunkMemoryLayout) XXX_Unmarshal(b []byte) error

type ColumnInfo 

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

func (*ColumnInfo) Descriptor 

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

func (*ColumnInfo) GetCollation 

func (m *ColumnInfo) GetCollation() int32

func (*ColumnInfo) GetColumnId 

func (m *ColumnInfo) GetColumnId() int64

func (*ColumnInfo) GetColumnLen 

func (m *ColumnInfo) GetColumnLen() int32

func (*ColumnInfo) GetDecimal 

func (m *ColumnInfo) GetDecimal() int32

func (*ColumnInfo) GetDefaultVal 

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

func (*ColumnInfo) GetElems 

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

func (*ColumnInfo) GetFlag 

func (m *ColumnInfo) GetFlag() int32

func (*ColumnInfo) GetPkHandle 

func (m *ColumnInfo) GetPkHandle() bool

func (*ColumnInfo) GetTp 

func (m *ColumnInfo) GetTp() int32

func (*ColumnInfo) Marshal 

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

func (*ColumnInfo) MarshalTo 

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

func (*ColumnInfo) MarshalToSizedBuffer 

func (m *ColumnInfo) MarshalToSizedBuffer(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

func (*ColumnInfo) XXX_DiscardUnknown 

func (m *ColumnInfo) XXX_DiscardUnknown()

func (*ColumnInfo) XXX_Marshal 

func (m *ColumnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnInfo) XXX_Merge 

func (m *ColumnInfo) XXX_Merge(src proto.Message)

func (*ColumnInfo) XXX_Size 

func (m *ColumnInfo) XXX_Size() int

func (*ColumnInfo) XXX_Unmarshal 

func (m *ColumnInfo) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *CompareInMetadata) MarshalToSizedBuffer(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

func (*CompareInMetadata) XXX_DiscardUnknown 

func (m *CompareInMetadata) XXX_DiscardUnknown()

func (*CompareInMetadata) XXX_Marshal 

func (m *CompareInMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompareInMetadata) XXX_Merge 

func (m *CompareInMetadata) XXX_Merge(src proto.Message)

func (*CompareInMetadata) XXX_Size 

func (m *CompareInMetadata) XXX_Size() int

func (*CompareInMetadata) XXX_Unmarshal 

func (m *CompareInMetadata) XXX_Unmarshal(b []byte) error

type DAGRequest 

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

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

func (*DAGRequest) Descriptor 

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

func (*DAGRequest) GetChunkMemoryLayout 

func (m *DAGRequest) GetChunkMemoryLayout() *ChunkMemoryLayout

func (*DAGRequest) GetCollectExecutionSummaries 

func (m *DAGRequest) GetCollectExecutionSummaries() bool

func (*DAGRequest) GetCollectRangeCounts 

func (m *DAGRequest) GetCollectRangeCounts() bool

func (*DAGRequest) GetEncodeType 

func (m *DAGRequest) GetEncodeType() EncodeType

func (*DAGRequest) GetExecutors 

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

func (*DAGRequest) GetFlags 

func (m *DAGRequest) GetFlags() uint64

func (*DAGRequest) GetForceEncodeType 

func (m *DAGRequest) GetForceEncodeType() bool

func (*DAGRequest) GetIsRpnExpr 

func (m *DAGRequest) GetIsRpnExpr() bool

func (*DAGRequest) GetMaxAllowedPacket 

func (m *DAGRequest) GetMaxAllowedPacket() uint64

func (*DAGRequest) GetMaxWarningCount 

func (m *DAGRequest) GetMaxWarningCount() uint64

func (*DAGRequest) GetOutputOffsets 

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

func (*DAGRequest) GetRootExecutor 

func (m *DAGRequest) GetRootExecutor() *Executor

func (*DAGRequest) GetSqlMode 

func (m *DAGRequest) GetSqlMode() uint64

func (*DAGRequest) GetStartTsFallback 

func (m *DAGRequest) GetStartTsFallback() uint64

func (*DAGRequest) GetTimeZoneName 

func (m *DAGRequest) GetTimeZoneName() string

func (*DAGRequest) GetTimeZoneOffset 

func (m *DAGRequest) GetTimeZoneOffset() int64

func (*DAGRequest) GetUser 

func (m *DAGRequest) GetUser() *UserIdentity

func (*DAGRequest) Marshal 

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

func (*DAGRequest) MarshalTo 

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

func (*DAGRequest) MarshalToSizedBuffer 

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

func (*DAGRequest) XXX_DiscardUnknown 

func (m *DAGRequest) XXX_DiscardUnknown()

func (*DAGRequest) XXX_Marshal 

func (m *DAGRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DAGRequest) XXX_Merge 

func (m *DAGRequest) XXX_Merge(src proto.Message)

func (*DAGRequest) XXX_Size 

func (m *DAGRequest) XXX_Size() int

func (*DAGRequest) XXX_Unmarshal 

func (m *DAGRequest) XXX_Unmarshal(b []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,proto3" json:"partitions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (m *DynamicPartitionAccessObject) MarshalToSizedBuffer(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

func (*DynamicPartitionAccessObject) XXX_DiscardUnknown 

func (m *DynamicPartitionAccessObject) XXX_DiscardUnknown()

func (*DynamicPartitionAccessObject) XXX_Marshal 

func (m *DynamicPartitionAccessObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DynamicPartitionAccessObject) XXX_Merge 

func (m *DynamicPartitionAccessObject) XXX_Merge(src proto.Message)

func (*DynamicPartitionAccessObject) XXX_Size 

func (m *DynamicPartitionAccessObject) XXX_Size() int

func (*DynamicPartitionAccessObject) XXX_Unmarshal 

func (m *DynamicPartitionAccessObject) XXX_Unmarshal(b []byte) error

type DynamicPartitionAccessObjects 

type DynamicPartitionAccessObjects struct {
	Objects              []*DynamicPartitionAccessObject `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

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

func (m *DynamicPartitionAccessObjects) MarshalToSizedBuffer(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

func (*DynamicPartitionAccessObjects) XXX_DiscardUnknown 

func (m *DynamicPartitionAccessObjects) XXX_DiscardUnknown()

func (*DynamicPartitionAccessObjects) XXX_Marshal 

func (m *DynamicPartitionAccessObjects) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DynamicPartitionAccessObjects) XXX_Merge 

func (m *DynamicPartitionAccessObjects) XXX_Merge(src proto.Message)

func (*DynamicPartitionAccessObjects) XXX_Size 

func (m *DynamicPartitionAccessObjects) XXX_Size() int

func (*DynamicPartitionAccessObjects) XXX_Unmarshal 

func (m *DynamicPartitionAccessObjects) XXX_Unmarshal(b []byte) error

type EmptyResponse 

type EmptyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (m *EmptyResponse) MarshalToSizedBuffer(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

func (*EmptyResponse) XXX_DiscardUnknown 

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal 

func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyResponse) XXX_Merge 

func (m *EmptyResponse) XXX_Merge(src proto.Message)

func (*EmptyResponse) XXX_Size 

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal 

func (m *EmptyResponse) XXX_Unmarshal(b []byte) error

type EncodeType 

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

func (EncodeType) Enum 

func (x EncodeType) Enum() *EncodeType

func (EncodeType) EnumDescriptor 

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

func (EncodeType) String 

func (x EncodeType) String() string

func (*EncodeType) UnmarshalJSON 

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

type Endian 

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

func (Endian) Enum 

func (x Endian) Enum() *Endian

func (Endian) EnumDescriptor 

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

func (Endian) String 

func (x Endian) String() string

func (*Endian) UnmarshalJSON 

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

type EngineType 

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

func (EngineType) Enum 

func (x EngineType) Enum() *EngineType

func (EngineType) EnumDescriptor 

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

func (EngineType) String 

func (x EngineType) String() string

func (*EngineType) UnmarshalJSON 

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

type Error 

type Error struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code" json:"code"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg" json:"msg"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *Error) MarshalToSizedBuffer(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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

type Event 

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

func (Event) Enum 

func (x Event) Enum() *Event

func (Event) EnumDescriptor 

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

func (Event) String 

func (x Event) String() string

func (*Event) UnmarshalJSON 

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

type ExchangeReceiver 

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

ExchangeReceiver accept connection and receiver data from ExchangeSender.

func (*ExchangeReceiver) Descriptor 

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

func (*ExchangeReceiver) GetEncodedTaskMeta 

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

func (*ExchangeReceiver) GetFieldTypes 

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

func (*ExchangeReceiver) GetTp 

func (m *ExchangeReceiver) GetTp() ExchangeType

func (*ExchangeReceiver) Marshal 

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

func (*ExchangeReceiver) MarshalTo 

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

func (*ExchangeReceiver) MarshalToSizedBuffer 

func (m *ExchangeReceiver) MarshalToSizedBuffer(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

func (*ExchangeReceiver) XXX_DiscardUnknown 

func (m *ExchangeReceiver) XXX_DiscardUnknown()

func (*ExchangeReceiver) XXX_Marshal 

func (m *ExchangeReceiver) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeReceiver) XXX_Merge 

func (m *ExchangeReceiver) XXX_Merge(src proto.Message)

func (*ExchangeReceiver) XXX_Size 

func (m *ExchangeReceiver) XXX_Size() int

func (*ExchangeReceiver) XXX_Unmarshal 

func (m *ExchangeReceiver) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `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) GetEncodedTaskMeta 

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

func (*ExchangeSender) GetPartitionKeys 

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

func (*ExchangeSender) GetTp 

func (m *ExchangeSender) GetTp() ExchangeType

func (*ExchangeSender) GetTypes 

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

func (*ExchangeSender) Marshal 

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

func (*ExchangeSender) MarshalTo 

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

func (*ExchangeSender) MarshalToSizedBuffer 

func (m *ExchangeSender) MarshalToSizedBuffer(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

func (*ExchangeSender) XXX_DiscardUnknown 

func (m *ExchangeSender) XXX_DiscardUnknown()

func (*ExchangeSender) XXX_Marshal 

func (m *ExchangeSender) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeSender) XXX_Merge 

func (m *ExchangeSender) XXX_Merge(src proto.Message)

func (*ExchangeSender) XXX_Size 

func (m *ExchangeSender) XXX_Size() int

func (*ExchangeSender) XXX_Unmarshal 

func (m *ExchangeSender) XXX_Unmarshal(b []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
)

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 */
	XXX_NoUnkeyedLiteral          struct{}            `json:"-"`
	XXX_unrecognized              []byte              `json:"-"`
	XXX_sizecache                 int32               `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) 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) MarshalToSizedBuffer 

func (m *Executor) MarshalToSizedBuffer(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

func (*Executor) XXX_DiscardUnknown 

func (m *Executor) XXX_DiscardUnknown()

func (*Executor) XXX_Marshal 

func (m *Executor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Executor) XXX_Merge 

func (m *Executor) XXX_Merge(src proto.Message)

func (*Executor) XXX_Size 

func (m *Executor) XXX_Size() int

func (*Executor) XXX_Unmarshal 

func (m *Executor) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `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) 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) MarshalToSizedBuffer 

func (m *ExecutorExecutionSummary) MarshalToSizedBuffer(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_DiscardUnknown 

func (m *ExecutorExecutionSummary) XXX_DiscardUnknown()

func (*ExecutorExecutionSummary) XXX_Marshal 

func (m *ExecutorExecutionSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutorExecutionSummary) XXX_Merge 

func (m *ExecutorExecutionSummary) XXX_Merge(src proto.Message)

func (*ExecutorExecutionSummary) XXX_OneofWrappers 

func (*ExecutorExecutionSummary) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExecutorExecutionSummary) XXX_Size 

func (m *ExecutorExecutionSummary) XXX_Size() int

func (*ExecutorExecutionSummary) XXX_Unmarshal 

func (m *ExecutorExecutionSummary) XXX_Unmarshal(b []byte) error

type ExecutorExecutionSummary_TiflashScanContext 

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

func (*ExecutorExecutionSummary_TiflashScanContext) MarshalTo 

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

func (*ExecutorExecutionSummary_TiflashScanContext) MarshalToSizedBuffer 

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

func (*ExecutorExecutionSummary_TiflashScanContext) Size 

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

type ExplainData 

type ExplainData struct {
	Main *ExplainOperator   `protobuf:"bytes,1,opt,name=main,proto3" json:"main,omitempty"`
	Ctes []*ExplainOperator `protobuf:"bytes,2,rep,name=ctes,proto3" 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 */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

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

func (m *ExplainData) MarshalToSizedBuffer(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

func (*ExplainData) XXX_DiscardUnknown 

func (m *ExplainData) XXX_DiscardUnknown()

func (*ExplainData) XXX_Marshal 

func (m *ExplainData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainData) XXX_Merge 

func (m *ExplainData) XXX_Merge(src proto.Message)

func (*ExplainData) XXX_Size 

func (m *ExplainData) XXX_Size() int

func (*ExplainData) XXX_Unmarshal 

func (m *ExplainData) XXX_Unmarshal(b []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,proto3" json:"children,omitempty"`
	Labels   []OperatorLabel    `protobuf:"varint,3,rep,packed,name=labels,proto3,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,proto3" 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,proto3" 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (m *ExplainOperator) MarshalToSizedBuffer(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

func (*ExplainOperator) XXX_DiscardUnknown 

func (m *ExplainOperator) XXX_DiscardUnknown()

func (*ExplainOperator) XXX_Marshal 

func (m *ExplainOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainOperator) XXX_Merge 

func (m *ExplainOperator) XXX_Merge(src proto.Message)

func (*ExplainOperator) XXX_Size 

func (m *ExplainOperator) XXX_Size() int

func (*ExplainOperator) XXX_Unmarshal 

func (m *ExplainOperator) XXX_Unmarshal(b []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"`
	FillValue            []byte           `protobuf:"bytes,10,opt,name=fill_value,json=fillValue" json:"fill_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `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) GetFillValue 

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

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

func (m *Expr) MarshalToSizedBuffer(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

func (*Expr) XXX_DiscardUnknown 

func (m *Expr) XXX_DiscardUnknown()

func (*Expr) XXX_Marshal 

func (m *Expr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Expr) XXX_Merge 

func (m *Expr) XXX_Merge(src proto.Message)

func (*Expr) XXX_Size 

func (m *Expr) XXX_Size() int

func (*Expr) XXX_Unmarshal 

func (m *Expr) XXX_Unmarshal(b []byte) error

type ExprType 

type ExprType int32
const (
	// Values are encoded bytes.
	ExprType_Null    ExprType = 0
	ExprType_Int64   ExprType = 1
	ExprType_Uint64  ExprType = 2
	ExprType_Float32 ExprType = 3
	ExprType_Float64 ExprType = 4
	ExprType_String  ExprType = 5
	ExprType_Bytes   ExprType = 6
	// Mysql specific types.
	ExprType_MysqlBit      ExprType = 101
	ExprType_MysqlDecimal  ExprType = 102
	ExprType_MysqlDuration ExprType = 103
	ExprType_MysqlEnum     ExprType = 104
	ExprType_MysqlHex      ExprType = 105
	ExprType_MysqlSet      ExprType = 106
	ExprType_MysqlTime     ExprType = 107
	ExprType_MysqlJson     ExprType = 108
	// Encoded value list.
	ExprType_ValueList ExprType = 151
	// Column reference. value is int64 column ID.
	ExprType_ColumnRef ExprType = 201
	// Aggregate functions.
	ExprType_Count               ExprType = 3001
	ExprType_Sum                 ExprType = 3002
	ExprType_Avg                 ExprType = 3003
	ExprType_Min                 ExprType = 3004
	ExprType_Max                 ExprType = 3005
	ExprType_First               ExprType = 3006
	ExprType_GroupConcat         ExprType = 3007
	ExprType_Agg_BitAnd          ExprType = 3008
	ExprType_Agg_BitOr           ExprType = 3009
	ExprType_Agg_BitXor          ExprType = 3010
	ExprType_Std                 ExprType = 3011
	ExprType_Stddev              ExprType = 3012
	ExprType_StddevPop           ExprType = 3013
	ExprType_StddevSamp          ExprType = 3014
	ExprType_VarPop              ExprType = 3015
	ExprType_VarSamp             ExprType = 3016
	ExprType_Variance            ExprType = 3017
	ExprType_JsonArrayAgg        ExprType = 3018
	ExprType_JsonObjectAgg       ExprType = 3019
	ExprType_ApproxCountDistinct ExprType = 3020
	// 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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *FMSketch) MarshalToSizedBuffer(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

func (*FMSketch) XXX_DiscardUnknown 

func (m *FMSketch) XXX_DiscardUnknown()

func (*FMSketch) XXX_Marshal 

func (m *FMSketch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FMSketch) XXX_Merge 

func (m *FMSketch) XXX_Merge(src proto.Message)

func (*FMSketch) XXX_Size 

func (m *FMSketch) XXX_Size() int

func (*FMSketch) XXX_Unmarshal 

func (m *FMSketch) XXX_Unmarshal(b []byte) error

type FieldType 

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

func (*FieldType) Descriptor 

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

func (*FieldType) GetCharset 

func (m *FieldType) GetCharset() string

func (*FieldType) GetCollate 

func (m *FieldType) GetCollate() int32

func (*FieldType) GetDecimal 

func (m *FieldType) GetDecimal() int32

func (*FieldType) GetElems 

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

func (*FieldType) GetFlag 

func (m *FieldType) GetFlag() uint32

func (*FieldType) GetFlen 

func (m *FieldType) GetFlen() int32

func (*FieldType) GetTp 

func (m *FieldType) GetTp() int32

func (*FieldType) Marshal 

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

func (*FieldType) MarshalTo 

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

func (*FieldType) MarshalToSizedBuffer 

func (m *FieldType) MarshalToSizedBuffer(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

func (*FieldType) XXX_DiscardUnknown 

func (m *FieldType) XXX_DiscardUnknown()

func (*FieldType) XXX_Marshal 

func (m *FieldType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldType) XXX_Merge 

func (m *FieldType) XXX_Merge(src proto.Message)

func (*FieldType) XXX_Size 

func (m *FieldType) XXX_Size() int

func (*FieldType) XXX_Unmarshal 

func (m *FieldType) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `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) MarshalToSizedBuffer 

func (m *Histogram) MarshalToSizedBuffer(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

func (*Histogram) XXX_DiscardUnknown 

func (m *Histogram) XXX_DiscardUnknown()

func (*Histogram) XXX_Marshal 

func (m *Histogram) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Histogram) XXX_Merge 

func (m *Histogram) XXX_Merge(src proto.Message)

func (*Histogram) XXX_Size 

func (m *Histogram) XXX_Size() int

func (*Histogram) XXX_Unmarshal 

func (m *Histogram) XXX_Unmarshal(b []byte) error

type InUnionMetadata 

type InUnionMetadata struct {
	InUnion              bool     `protobuf:"varint,1,req,name=in_union,json=inUnion" json:"in_union"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *InUnionMetadata) MarshalToSizedBuffer(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

func (*InUnionMetadata) XXX_DiscardUnknown 

func (m *InUnionMetadata) XXX_DiscardUnknown()

func (*InUnionMetadata) XXX_Marshal 

func (m *InUnionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InUnionMetadata) XXX_Merge 

func (m *InUnionMetadata) XXX_Merge(src proto.Message)

func (*InUnionMetadata) XXX_Size 

func (m *InUnionMetadata) XXX_Size() int

func (*InUnionMetadata) XXX_Unmarshal 

func (m *InUnionMetadata) XXX_Unmarshal(b []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,proto3" json:"cols,omitempty"`
	IsClusteredIndex     bool     `protobuf:"varint,3,opt,name=is_clustered_index,json=isClusteredIndex,proto3" json:"is_clustered_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

func (*IndexAccess) XXX_DiscardUnknown 

func (m *IndexAccess) XXX_DiscardUnknown()

func (*IndexAccess) XXX_Marshal 

func (m *IndexAccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexAccess) XXX_Merge 

func (m *IndexAccess) XXX_Merge(src proto.Message)

func (*IndexAccess) XXX_Size 

func (m *IndexAccess) XXX_Size() int

func (*IndexAccess) XXX_Unmarshal 

func (m *IndexAccess) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `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) MarshalToSizedBuffer 

func (m *IndexInfo) MarshalToSizedBuffer(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

func (*IndexInfo) XXX_DiscardUnknown 

func (m *IndexInfo) XXX_DiscardUnknown()

func (*IndexInfo) XXX_Marshal 

func (m *IndexInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexInfo) XXX_Merge 

func (m *IndexInfo) XXX_Merge(src proto.Message)

func (*IndexInfo) XXX_Size 

func (m *IndexInfo) XXX_Size() int

func (*IndexInfo) XXX_Unmarshal 

func (m *IndexInfo) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `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) MarshalToSizedBuffer 

func (m *IndexScan) MarshalToSizedBuffer(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

func (*IndexScan) XXX_DiscardUnknown 

func (m *IndexScan) XXX_DiscardUnknown()

func (*IndexScan) XXX_Marshal 

func (m *IndexScan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexScan) XXX_Merge 

func (m *IndexScan) XXX_Merge(src proto.Message)

func (*IndexScan) XXX_Size 

func (m *IndexScan) XXX_Size() int

func (*IndexScan) XXX_Unmarshal 

func (m *IndexScan) XXX_Unmarshal(b []byte) error

type Join 

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

func (*Join) Descriptor 

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

func (*Join) GetBuildTypes 

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

func (*Join) GetChildren 

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

func (*Join) GetInnerIdx 

func (m *Join) GetInnerIdx() int64

func (*Join) GetJoinExecType 

func (m *Join) GetJoinExecType() JoinExecType

func (*Join) GetJoinType 

func (m *Join) GetJoinType() JoinType

func (*Join) GetLeftConditions 

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

func (*Join) GetLeftJoinKeys 

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

func (*Join) GetOtherConditions 

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

func (*Join) GetOtherEqConditionsFromIn 

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

func (*Join) GetProbeTypes 

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

func (*Join) GetRightConditions 

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

func (*Join) GetRightJoinKeys 

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

func (*Join) Marshal 

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

func (*Join) MarshalTo 

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

func (*Join) MarshalToSizedBuffer 

func (m *Join) MarshalToSizedBuffer(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

func (*Join) XXX_DiscardUnknown 

func (m *Join) XXX_DiscardUnknown()

func (*Join) XXX_Marshal 

func (m *Join) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Join) XXX_Merge 

func (m *Join) XXX_Merge(src proto.Message)

func (*Join) XXX_Size 

func (m *Join) XXX_Size() int

func (*Join) XXX_Unmarshal 

func (m *Join) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *KeyRange) MarshalToSizedBuffer(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

func (*KeyRange) XXX_DiscardUnknown 

func (m *KeyRange) XXX_DiscardUnknown()

func (*KeyRange) XXX_Marshal 

func (m *KeyRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyRange) XXX_Merge 

func (m *KeyRange) XXX_Merge(src proto.Message)

func (*KeyRange) XXX_Size 

func (m *KeyRange) XXX_Size() int

func (*KeyRange) XXX_Unmarshal 

func (m *KeyRange) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *Kill) MarshalToSizedBuffer(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

func (*Kill) XXX_DiscardUnknown 

func (m *Kill) XXX_DiscardUnknown()

func (*Kill) XXX_Marshal 

func (m *Kill) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Kill) XXX_Merge 

func (m *Kill) XXX_Merge(src proto.Message)

func (*Kill) XXX_Size 

func (m *Kill) XXX_Size() int

func (*Kill) XXX_Unmarshal 

func (m *Kill) XXX_Unmarshal(b []byte) error

type Limit 

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

func (*Limit) Descriptor 

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

func (*Limit) GetChild 

func (m *Limit) GetChild() *Executor

func (*Limit) GetLimit 

func (m *Limit) GetLimit() uint64

func (*Limit) Marshal 

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

func (*Limit) MarshalTo 

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

func (*Limit) MarshalToSizedBuffer 

func (m *Limit) MarshalToSizedBuffer(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

func (*Limit) XXX_DiscardUnknown 

func (m *Limit) XXX_DiscardUnknown()

func (*Limit) XXX_Marshal 

func (m *Limit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Limit) XXX_Merge 

func (m *Limit) XXX_Merge(src proto.Message)

func (*Limit) XXX_Size 

func (m *Limit) XXX_Size() int

func (*Limit) XXX_Unmarshal 

func (m *Limit) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral   struct{}      `json:"-"`
	XXX_unrecognized       []byte        `json:"-"`
	XXX_sizecache          int32         `json:"-"`
}

func (*PartitionTableScan) Descriptor 

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

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

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

func (*PartitionTableScan) GetPrimaryColumnIds 

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

func (*PartitionTableScan) GetPrimaryPrefixColumnIds 

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

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

func (m *PartitionTableScan) MarshalToSizedBuffer(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

func (*PartitionTableScan) XXX_DiscardUnknown 

func (m *PartitionTableScan) XXX_DiscardUnknown()

func (*PartitionTableScan) XXX_Marshal 

func (m *PartitionTableScan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitionTableScan) XXX_Merge 

func (m *PartitionTableScan) XXX_Merge(src proto.Message)

func (*PartitionTableScan) XXX_Size 

func (m *PartitionTableScan) XXX_Size() int

func (*PartitionTableScan) XXX_Unmarshal 

func (m *PartitionTableScan) XXX_Unmarshal(b []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 */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

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

func (m *PlanMeta) MarshalToSizedBuffer(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

func (*PlanMeta) XXX_DiscardUnknown 

func (m *PlanMeta) XXX_DiscardUnknown()

func (*PlanMeta) XXX_Marshal 

func (m *PlanMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlanMeta) XXX_Merge 

func (m *PlanMeta) XXX_Merge(src proto.Message)

func (*PlanMeta) XXX_Size 

func (m *PlanMeta) XXX_Size() int

func (*PlanMeta) XXX_Unmarshal 

func (m *PlanMeta) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `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) MarshalToSizedBuffer 

func (m *Projection) MarshalToSizedBuffer(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

func (*Projection) XXX_DiscardUnknown 

func (m *Projection) XXX_DiscardUnknown()

func (*Projection) XXX_Marshal 

func (m *Projection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Projection) XXX_Merge 

func (m *Projection) XXX_Merge(src proto.Message)

func (*Projection) XXX_Size 

func (m *Projection) XXX_Size() int

func (*Projection) XXX_Unmarshal 

func (m *Projection) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `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) MarshalToSizedBuffer 

func (m *ResourceGroupTag) MarshalToSizedBuffer(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

func (*ResourceGroupTag) XXX_DiscardUnknown 

func (m *ResourceGroupTag) XXX_DiscardUnknown()

func (*ResourceGroupTag) XXX_Marshal 

func (m *ResourceGroupTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceGroupTag) XXX_Merge 

func (m *ResourceGroupTag) XXX_Merge(src proto.Message)

func (*ResourceGroupTag) XXX_Size 

func (m *ResourceGroupTag) XXX_Size() int

func (*ResourceGroupTag) XXX_Unmarshal 

func (m *ResourceGroupTag) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *Row) MarshalToSizedBuffer(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

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Row) XXX_Merge 

func (m *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

func (m *Row) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *RowMeta) MarshalToSizedBuffer(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

func (*RowMeta) XXX_DiscardUnknown 

func (m *RowMeta) XXX_DiscardUnknown()

func (*RowMeta) XXX_Marshal 

func (m *RowMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowMeta) XXX_Merge 

func (m *RowMeta) XXX_Merge(src proto.Message)

func (*RowMeta) XXX_Size 

func (m *RowMeta) XXX_Size() int

func (*RowMeta) XXX_Unmarshal 

func (m *RowMeta) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *RowSample) MarshalToSizedBuffer(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

func (*RowSample) XXX_DiscardUnknown 

func (m *RowSample) XXX_DiscardUnknown()

func (*RowSample) XXX_Marshal 

func (m *RowSample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowSample) XXX_Merge 

func (m *RowSample) XXX_Merge(src proto.Message)

func (*RowSample) XXX_Size 

func (m *RowSample) XXX_Size() int

func (*RowSample) XXX_Unmarshal 

func (m *RowSample) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `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) MarshalToSizedBuffer 

func (m *RowSampleCollector) MarshalToSizedBuffer(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

func (*RowSampleCollector) XXX_DiscardUnknown 

func (m *RowSampleCollector) XXX_DiscardUnknown()

func (*RowSampleCollector) XXX_Marshal 

func (m *RowSampleCollector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowSampleCollector) XXX_Merge 

func (m *RowSampleCollector) XXX_Merge(src proto.Message)

func (*RowSampleCollector) XXX_Size 

func (m *RowSampleCollector) XXX_Size() int

func (*RowSampleCollector) XXX_Unmarshal 

func (m *RowSampleCollector) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *RpnExpr) MarshalToSizedBuffer(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

func (*RpnExpr) XXX_DiscardUnknown 

func (m *RpnExpr) XXX_DiscardUnknown()

func (*RpnExpr) XXX_Marshal 

func (m *RpnExpr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpnExpr) XXX_Merge 

func (m *RpnExpr) XXX_Merge(src proto.Message)

func (*RpnExpr) XXX_Size 

func (m *RpnExpr) XXX_Size() int

func (*RpnExpr) XXX_Unmarshal 

func (m *RpnExpr) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (m *SQLMeta) MarshalToSizedBuffer(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

func (*SQLMeta) XXX_DiscardUnknown 

func (m *SQLMeta) XXX_DiscardUnknown()

func (*SQLMeta) XXX_Marshal 

func (m *SQLMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SQLMeta) XXX_Merge 

func (m *SQLMeta) XXX_Merge(src proto.Message)

func (*SQLMeta) XXX_Size 

func (m *SQLMeta) XXX_Size() int

func (*SQLMeta) XXX_Unmarshal 

func (m *SQLMeta) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `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) MarshalToSizedBuffer 

func (m *SampleCollector) MarshalToSizedBuffer(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

func (*SampleCollector) XXX_DiscardUnknown 

func (m *SampleCollector) XXX_DiscardUnknown()

func (*SampleCollector) XXX_Marshal 

func (m *SampleCollector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SampleCollector) XXX_Merge 

func (m *SampleCollector) XXX_Merge(src proto.Message)

func (*SampleCollector) XXX_Size 

func (m *SampleCollector) XXX_Size() int

func (*SampleCollector) XXX_Unmarshal 

func (m *SampleCollector) XXX_Unmarshal(b []byte) error

type ScalarFuncSig 

type ScalarFuncSig int32
const (
	ScalarFuncSig_Unspecified ScalarFuncSig = 0
	// Casting
	ScalarFuncSig_CastIntAsInt           ScalarFuncSig = 1
	ScalarFuncSig_CastIntAsReal          ScalarFuncSig = 2
	ScalarFuncSig_CastIntAsString        ScalarFuncSig = 3
	ScalarFuncSig_CastIntAsDecimal       ScalarFuncSig = 4
	ScalarFuncSig_CastIntAsTime          ScalarFuncSig = 5
	ScalarFuncSig_CastIntAsDuration      ScalarFuncSig = 6
	ScalarFuncSig_CastIntAsJson          ScalarFuncSig = 7
	ScalarFuncSig_CastRealAsInt          ScalarFuncSig = 10
	ScalarFuncSig_CastRealAsReal         ScalarFuncSig = 11
	ScalarFuncSig_CastRealAsString       ScalarFuncSig = 12
	ScalarFuncSig_CastRealAsDecimal      ScalarFuncSig = 13
	ScalarFuncSig_CastRealAsTime         ScalarFuncSig = 14
	ScalarFuncSig_CastRealAsDuration     ScalarFuncSig = 15
	ScalarFuncSig_CastRealAsJson         ScalarFuncSig = 16
	ScalarFuncSig_CastDecimalAsInt       ScalarFuncSig = 20
	ScalarFuncSig_CastDecimalAsReal      ScalarFuncSig = 21
	ScalarFuncSig_CastDecimalAsString    ScalarFuncSig = 22
	ScalarFuncSig_CastDecimalAsDecimal   ScalarFuncSig = 23
	ScalarFuncSig_CastDecimalAsTime      ScalarFuncSig = 24
	ScalarFuncSig_CastDecimalAsDuration  ScalarFuncSig = 25
	ScalarFuncSig_CastDecimalAsJson      ScalarFuncSig = 26
	ScalarFuncSig_CastStringAsInt        ScalarFuncSig = 30
	ScalarFuncSig_CastStringAsReal       ScalarFuncSig = 31
	ScalarFuncSig_CastStringAsString     ScalarFuncSig = 32
	ScalarFuncSig_CastStringAsDecimal    ScalarFuncSig = 33
	ScalarFuncSig_CastStringAsTime       ScalarFuncSig = 34
	ScalarFuncSig_CastStringAsDuration   ScalarFuncSig = 35
	ScalarFuncSig_CastStringAsJson       ScalarFuncSig = 36
	ScalarFuncSig_CastTimeAsInt          ScalarFuncSig = 40
	ScalarFuncSig_CastTimeAsReal         ScalarFuncSig = 41
	ScalarFuncSig_CastTimeAsString       ScalarFuncSig = 42
	ScalarFuncSig_CastTimeAsDecimal      ScalarFuncSig = 43
	ScalarFuncSig_CastTimeAsTime         ScalarFuncSig = 44
	ScalarFuncSig_CastTimeAsDuration     ScalarFuncSig = 45
	ScalarFuncSig_CastTimeAsJson         ScalarFuncSig = 46
	ScalarFuncSig_CastDurationAsInt      ScalarFuncSig = 50
	ScalarFuncSig_CastDurationAsReal     ScalarFuncSig = 51
	ScalarFuncSig_CastDurationAsString   ScalarFuncSig = 52
	ScalarFuncSig_CastDurationAsDecimal  ScalarFuncSig = 53
	ScalarFuncSig_CastDurationAsTime     ScalarFuncSig = 54
	ScalarFuncSig_CastDurationAsDuration ScalarFuncSig = 55
	ScalarFuncSig_CastDurationAsJson     ScalarFuncSig = 56
	ScalarFuncSig_CastJsonAsInt          ScalarFuncSig = 60
	ScalarFuncSig_CastJsonAsReal         ScalarFuncSig = 61
	ScalarFuncSig_CastJsonAsString       ScalarFuncSig = 62
	ScalarFuncSig_CastJsonAsDecimal      ScalarFuncSig = 63
	ScalarFuncSig_CastJsonAsTime         ScalarFuncSig = 64
	ScalarFuncSig_CastJsonAsDuration     ScalarFuncSig = 65
	ScalarFuncSig_CastJsonAsJson         ScalarFuncSig = 66
	//compare
	ScalarFuncSig_CoalesceInt      ScalarFuncSig = 4201
	ScalarFuncSig_CoalesceReal     ScalarFuncSig = 4202
	ScalarFuncSig_CoalesceDecimal  ScalarFuncSig = 4203
	ScalarFuncSig_CoalesceString   ScalarFuncSig = 4204
	ScalarFuncSig_CoalesceTime     ScalarFuncSig = 4205
	ScalarFuncSig_CoalesceDuration ScalarFuncSig = 4206
	// unimplemented in tidb
	ScalarFuncSig_CoalesceJson    ScalarFuncSig = 4207
	ScalarFuncSig_LTInt           ScalarFuncSig = 100
	ScalarFuncSig_LTReal          ScalarFuncSig = 101
	ScalarFuncSig_LTDecimal       ScalarFuncSig = 102
	ScalarFuncSig_LTString        ScalarFuncSig = 103
	ScalarFuncSig_LTTime          ScalarFuncSig = 104
	ScalarFuncSig_LTDuration      ScalarFuncSig = 105
	ScalarFuncSig_LTJson          ScalarFuncSig = 106
	ScalarFuncSig_LEInt           ScalarFuncSig = 110
	ScalarFuncSig_LEReal          ScalarFuncSig = 111
	ScalarFuncSig_LEDecimal       ScalarFuncSig = 112
	ScalarFuncSig_LEString        ScalarFuncSig = 113
	ScalarFuncSig_LETime          ScalarFuncSig = 114
	ScalarFuncSig_LEDuration      ScalarFuncSig = 115
	ScalarFuncSig_LEJson          ScalarFuncSig = 116
	ScalarFuncSig_GTInt           ScalarFuncSig = 120
	ScalarFuncSig_GTReal          ScalarFuncSig = 121
	ScalarFuncSig_GTDecimal       ScalarFuncSig = 122
	ScalarFuncSig_GTString        ScalarFuncSig = 123
	ScalarFuncSig_GTTime          ScalarFuncSig = 124
	ScalarFuncSig_GTDuration      ScalarFuncSig = 125
	ScalarFuncSig_GTJson          ScalarFuncSig = 126
	ScalarFuncSig_GreatestInt     ScalarFuncSig = 4215
	ScalarFuncSig_GreatestReal    ScalarFuncSig = 4216
	ScalarFuncSig_GreatestDecimal ScalarFuncSig = 4217
	ScalarFuncSig_GreatestString  ScalarFuncSig = 4218
	ScalarFuncSig_GreatestTime    ScalarFuncSig = 4219
	ScalarFuncSig_LeastInt        ScalarFuncSig = 4220
	ScalarFuncSig_LeastReal       ScalarFuncSig = 4221
	ScalarFuncSig_LeastDecimal    ScalarFuncSig = 4222
	ScalarFuncSig_LeastString     ScalarFuncSig = 4223
	ScalarFuncSig_LeastTime       ScalarFuncSig = 4224
	ScalarFuncSig_IntervalInt     ScalarFuncSig = 4225
	ScalarFuncSig_IntervalReal    ScalarFuncSig = 4226
	ScalarFuncSig_GEInt           ScalarFuncSig = 130
	ScalarFuncSig_GEReal          ScalarFuncSig = 131
	ScalarFuncSig_GEDecimal       ScalarFuncSig = 132
	ScalarFuncSig_GEString        ScalarFuncSig = 133
	ScalarFuncSig_GETime          ScalarFuncSig = 134
	ScalarFuncSig_GEDuration      ScalarFuncSig = 135
	ScalarFuncSig_GEJson          ScalarFuncSig = 136
	ScalarFuncSig_EQInt           ScalarFuncSig = 140
	ScalarFuncSig_EQReal          ScalarFuncSig = 141
	ScalarFuncSig_EQDecimal       ScalarFuncSig = 142
	ScalarFuncSig_EQString        ScalarFuncSig = 143
	ScalarFuncSig_EQTime          ScalarFuncSig = 144
	ScalarFuncSig_EQDuration      ScalarFuncSig = 145
	ScalarFuncSig_EQJson          ScalarFuncSig = 146
	ScalarFuncSig_NEInt           ScalarFuncSig = 150
	ScalarFuncSig_NEReal          ScalarFuncSig = 151
	ScalarFuncSig_NEDecimal       ScalarFuncSig = 152
	ScalarFuncSig_NEString        ScalarFuncSig = 153
	ScalarFuncSig_NETime          ScalarFuncSig = 154
	ScalarFuncSig_NEDuration      ScalarFuncSig = 155
	ScalarFuncSig_NEJson          ScalarFuncSig = 156
	ScalarFuncSig_NullEQInt       ScalarFuncSig = 160
	ScalarFuncSig_NullEQReal      ScalarFuncSig = 161
	ScalarFuncSig_NullEQDecimal   ScalarFuncSig = 162
	ScalarFuncSig_NullEQString    ScalarFuncSig = 163
	ScalarFuncSig_NullEQTime      ScalarFuncSig = 164
	ScalarFuncSig_NullEQDuration  ScalarFuncSig = 165
	ScalarFuncSig_NullEQJson      ScalarFuncSig = 166
	//arithmetic
	ScalarFuncSig_PlusReal                       ScalarFuncSig = 200
	ScalarFuncSig_PlusDecimal                    ScalarFuncSig = 201
	ScalarFuncSig_PlusInt                        ScalarFuncSig = 203
	ScalarFuncSig_MinusReal                      ScalarFuncSig = 204
	ScalarFuncSig_MinusDecimal                   ScalarFuncSig = 205
	ScalarFuncSig_MinusInt                       ScalarFuncSig = 207
	ScalarFuncSig_MultiplyReal                   ScalarFuncSig = 208
	ScalarFuncSig_MultiplyDecimal                ScalarFuncSig = 209
	ScalarFuncSig_MultiplyInt                    ScalarFuncSig = 210
	ScalarFuncSig_DivideReal                     ScalarFuncSig = 211
	ScalarFuncSig_DivideDecimal                  ScalarFuncSig = 212
	ScalarFuncSig_IntDivideInt                   ScalarFuncSig = 213
	ScalarFuncSig_IntDivideDecimal               ScalarFuncSig = 214
	ScalarFuncSig_ModReal                        ScalarFuncSig = 215
	ScalarFuncSig_ModDecimal                     ScalarFuncSig = 216
	ScalarFuncSig_ModInt                         ScalarFuncSig = 217
	ScalarFuncSig_MultiplyIntUnsigned            ScalarFuncSig = 218
	ScalarFuncSig_PlusIntUnsignedUnsigned        ScalarFuncSig = 219
	ScalarFuncSig_PlusIntUnsignedSigned          ScalarFuncSig = 220
	ScalarFuncSig_PlusIntSignedUnsigned          ScalarFuncSig = 221
	ScalarFuncSig_PlusIntSignedSigned            ScalarFuncSig = 222
	ScalarFuncSig_ModIntUnsignedUnsigned         ScalarFuncSig = 223
	ScalarFuncSig_ModIntUnsignedSigned           ScalarFuncSig = 224
	ScalarFuncSig_ModIntSignedUnsigned           ScalarFuncSig = 225
	ScalarFuncSig_ModIntSignedSigned             ScalarFuncSig = 226
	ScalarFuncSig_MinusIntUnsignedUnsigned       ScalarFuncSig = 227
	ScalarFuncSig_MinusIntUnsignedSigned         ScalarFuncSig = 228
	ScalarFuncSig_MinusIntSignedUnsigned         ScalarFuncSig = 229
	ScalarFuncSig_MinusIntSignedSigned           ScalarFuncSig = 230
	ScalarFuncSig_MinusIntForcedUnsignedUnsigned ScalarFuncSig = 231
	ScalarFuncSig_MinusIntForcedUnsignedSigned   ScalarFuncSig = 232
	ScalarFuncSig_MinusIntForcedSignedUnsigned   ScalarFuncSig = 233
	ScalarFuncSig_IntDivideIntUnsignedUnsigned   ScalarFuncSig = 234
	ScalarFuncSig_IntDivideIntUnsignedSigned     ScalarFuncSig = 235
	ScalarFuncSig_IntDivideIntSignedSigned       ScalarFuncSig = 236
	ScalarFuncSig_IntDivideIntSignedUnsigned     ScalarFuncSig = 237
	//math
	ScalarFuncSig_AbsInt               ScalarFuncSig = 2101
	ScalarFuncSig_AbsUInt              ScalarFuncSig = 2102
	ScalarFuncSig_AbsReal              ScalarFuncSig = 2103
	ScalarFuncSig_AbsDecimal           ScalarFuncSig = 2104
	ScalarFuncSig_CeilIntToDec         ScalarFuncSig = 2105
	ScalarFuncSig_CeilIntToInt         ScalarFuncSig = 2106
	ScalarFuncSig_CeilDecToInt         ScalarFuncSig = 2107
	ScalarFuncSig_CeilDecToDec         ScalarFuncSig = 2108
	ScalarFuncSig_CeilReal             ScalarFuncSig = 2109
	ScalarFuncSig_FloorIntToDec        ScalarFuncSig = 2110
	ScalarFuncSig_FloorIntToInt        ScalarFuncSig = 2111
	ScalarFuncSig_FloorDecToInt        ScalarFuncSig = 2112
	ScalarFuncSig_FloorDecToDec        ScalarFuncSig = 2113
	ScalarFuncSig_FloorReal            ScalarFuncSig = 2114
	ScalarFuncSig_RoundReal            ScalarFuncSig = 2121
	ScalarFuncSig_RoundInt             ScalarFuncSig = 2122
	ScalarFuncSig_RoundDec             ScalarFuncSig = 2123
	ScalarFuncSig_RoundWithFracReal    ScalarFuncSig = 2124
	ScalarFuncSig_RoundWithFracInt     ScalarFuncSig = 2125
	ScalarFuncSig_RoundWithFracDec     ScalarFuncSig = 2126
	ScalarFuncSig_Log1Arg              ScalarFuncSig = 2131
	ScalarFuncSig_Log2Args             ScalarFuncSig = 2132
	ScalarFuncSig_Log2                 ScalarFuncSig = 2133
	ScalarFuncSig_Log10                ScalarFuncSig = 2134
	ScalarFuncSig_Rand                 ScalarFuncSig = 2135
	ScalarFuncSig_RandWithSeedFirstGen ScalarFuncSig = 2136
	ScalarFuncSig_Pow                  ScalarFuncSig = 2137
	ScalarFuncSig_Conv                 ScalarFuncSig = 2138
	ScalarFuncSig_CRC32                ScalarFuncSig = 2139
	ScalarFuncSig_Sign                 ScalarFuncSig = 2140
	ScalarFuncSig_Sqrt                 ScalarFuncSig = 2141
	ScalarFuncSig_Acos                 ScalarFuncSig = 2142
	ScalarFuncSig_Asin                 ScalarFuncSig = 2143
	ScalarFuncSig_Atan1Arg             ScalarFuncSig = 2144
	ScalarFuncSig_Atan2Args            ScalarFuncSig = 2145
	ScalarFuncSig_Cos                  ScalarFuncSig = 2146
	ScalarFuncSig_Cot                  ScalarFuncSig = 2147
	ScalarFuncSig_Degrees              ScalarFuncSig = 2148
	ScalarFuncSig_Exp                  ScalarFuncSig = 2149
	ScalarFuncSig_PI                   ScalarFuncSig = 2150
	ScalarFuncSig_Radians              ScalarFuncSig = 2151
	ScalarFuncSig_Sin                  ScalarFuncSig = 2152
	ScalarFuncSig_Tan                  ScalarFuncSig = 2153
	ScalarFuncSig_TruncateInt          ScalarFuncSig = 2154
	ScalarFuncSig_TruncateReal         ScalarFuncSig = 2155
	ScalarFuncSig_TruncateDecimal      ScalarFuncSig = 2156
	ScalarFuncSig_TruncateUint         ScalarFuncSig = 2157
	//op
	ScalarFuncSig_LogicalAnd        ScalarFuncSig = 3101
	ScalarFuncSig_LogicalOr         ScalarFuncSig = 3102
	ScalarFuncSig_LogicalXor        ScalarFuncSig = 3103
	ScalarFuncSig_UnaryNotInt       ScalarFuncSig = 3104
	ScalarFuncSig_UnaryNotDecimal   ScalarFuncSig = 3105
	ScalarFuncSig_UnaryNotReal      ScalarFuncSig = 3106
	ScalarFuncSig_UnaryMinusInt     ScalarFuncSig = 3108
	ScalarFuncSig_UnaryMinusReal    ScalarFuncSig = 3109
	ScalarFuncSig_UnaryMinusDecimal ScalarFuncSig = 3110
	ScalarFuncSig_DecimalIsNull     ScalarFuncSig = 3111
	ScalarFuncSig_DurationIsNull    ScalarFuncSig = 3112
	ScalarFuncSig_RealIsNull        ScalarFuncSig = 3113
	ScalarFuncSig_StringIsNull      ScalarFuncSig = 3114
	ScalarFuncSig_TimeIsNull        ScalarFuncSig = 3115
	ScalarFuncSig_IntIsNull         ScalarFuncSig = 3116
	// unimplemented in tidb
	ScalarFuncSig_JsonIsNull             ScalarFuncSig = 3117
	ScalarFuncSig_BitAndSig              ScalarFuncSig = 3118
	ScalarFuncSig_BitOrSig               ScalarFuncSig = 3119
	ScalarFuncSig_BitXorSig              ScalarFuncSig = 3120
	ScalarFuncSig_BitNegSig              ScalarFuncSig = 3121
	ScalarFuncSig_IntIsTrue              ScalarFuncSig = 3122
	ScalarFuncSig_RealIsTrue             ScalarFuncSig = 3123
	ScalarFuncSig_DecimalIsTrue          ScalarFuncSig = 3124
	ScalarFuncSig_IntIsFalse             ScalarFuncSig = 3125
	ScalarFuncSig_RealIsFalse            ScalarFuncSig = 3126
	ScalarFuncSig_DecimalIsFalse         ScalarFuncSig = 3127
	ScalarFuncSig_LeftShift              ScalarFuncSig = 3129
	ScalarFuncSig_RightShift             ScalarFuncSig = 3130
	ScalarFuncSig_IntIsTrueWithNull      ScalarFuncSig = 3142
	ScalarFuncSig_RealIsTrueWithNull     ScalarFuncSig = 3143
	ScalarFuncSig_DecimalIsTrueWithNull  ScalarFuncSig = 3144
	ScalarFuncSig_IntIsFalseWithNull     ScalarFuncSig = 3145
	ScalarFuncSig_RealIsFalseWithNull    ScalarFuncSig = 3146
	ScalarFuncSig_DecimalIsFalseWithNull ScalarFuncSig = 3147
	//other
	ScalarFuncSig_BitCount       ScalarFuncSig = 3128
	ScalarFuncSig_GetParamString ScalarFuncSig = 3131
	ScalarFuncSig_GetVar         ScalarFuncSig = 3132
	ScalarFuncSig_RowSig         ScalarFuncSig = 3133
	ScalarFuncSig_SetVar         ScalarFuncSig = 3134
	ScalarFuncSig_ValuesDecimal  ScalarFuncSig = 3135
	ScalarFuncSig_ValuesDuration ScalarFuncSig = 3136
	ScalarFuncSig_ValuesInt      ScalarFuncSig = 3137
	ScalarFuncSig_ValuesJSON     ScalarFuncSig = 3138
	ScalarFuncSig_ValuesReal     ScalarFuncSig = 3139
	ScalarFuncSig_ValuesString   ScalarFuncSig = 3140
	ScalarFuncSig_ValuesTime     ScalarFuncSig = 3141
	ScalarFuncSig_InInt          ScalarFuncSig = 4001
	ScalarFuncSig_InReal         ScalarFuncSig = 4002
	ScalarFuncSig_InDecimal      ScalarFuncSig = 4003
	ScalarFuncSig_InString       ScalarFuncSig = 4004
	ScalarFuncSig_InTime         ScalarFuncSig = 4005
	ScalarFuncSig_InDuration     ScalarFuncSig = 4006
	ScalarFuncSig_InJson         ScalarFuncSig = 4007
	//control
	ScalarFuncSig_IfNullInt        ScalarFuncSig = 4101
	ScalarFuncSig_IfNullReal       ScalarFuncSig = 4102
	ScalarFuncSig_IfNullDecimal    ScalarFuncSig = 4103
	ScalarFuncSig_IfNullString     ScalarFuncSig = 4104
	ScalarFuncSig_IfNullTime       ScalarFuncSig = 4105
	ScalarFuncSig_IfNullDuration   ScalarFuncSig = 4106
	ScalarFuncSig_IfInt            ScalarFuncSig = 4107
	ScalarFuncSig_IfReal           ScalarFuncSig = 4108
	ScalarFuncSig_IfDecimal        ScalarFuncSig = 4109
	ScalarFuncSig_IfString         ScalarFuncSig = 4110
	ScalarFuncSig_IfTime           ScalarFuncSig = 4111
	ScalarFuncSig_IfDuration       ScalarFuncSig = 4112
	ScalarFuncSig_IfNullJson       ScalarFuncSig = 4113
	ScalarFuncSig_IfJson           ScalarFuncSig = 4114
	ScalarFuncSig_CaseWhenInt      ScalarFuncSig = 4208
	ScalarFuncSig_CaseWhenReal     ScalarFuncSig = 4209
	ScalarFuncSig_CaseWhenDecimal  ScalarFuncSig = 4210
	ScalarFuncSig_CaseWhenString   ScalarFuncSig = 4211
	ScalarFuncSig_CaseWhenTime     ScalarFuncSig = 4212
	ScalarFuncSig_CaseWhenDuration ScalarFuncSig = 4213
	// unimplemented in tidb
	ScalarFuncSig_CaseWhenJson ScalarFuncSig = 4214
	// encryption
	ScalarFuncSig_AesDecrypt         ScalarFuncSig = 4501
	ScalarFuncSig_AesEncrypt         ScalarFuncSig = 4502
	ScalarFuncSig_Compress           ScalarFuncSig = 4503
	ScalarFuncSig_MD5                ScalarFuncSig = 4504
	ScalarFuncSig_Password           ScalarFuncSig = 4505
	ScalarFuncSig_RandomBytes        ScalarFuncSig = 4506
	ScalarFuncSig_SHA1               ScalarFuncSig = 4507
	ScalarFuncSig_SHA2               ScalarFuncSig = 4508
	ScalarFuncSig_Uncompress         ScalarFuncSig = 4509
	ScalarFuncSig_UncompressedLength ScalarFuncSig = 4510
	ScalarFuncSig_AesDecryptIV       ScalarFuncSig = 4511
	ScalarFuncSig_AesEncryptIV       ScalarFuncSig = 4512
	ScalarFuncSig_Encode             ScalarFuncSig = 4513
	ScalarFuncSig_Decode             ScalarFuncSig = 4514
	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
	//like
	ScalarFuncSig_LikeSig              ScalarFuncSig = 4310
	ScalarFuncSig_RegexpSig            ScalarFuncSig = 4311
	ScalarFuncSig_RegexpUTF8Sig        ScalarFuncSig = 4312
	ScalarFuncSig_RegexpLikeSig        ScalarFuncSig = 4313
	ScalarFuncSig_RegexpLikeUTF8Sig    ScalarFuncSig = 4314
	ScalarFuncSig_RegexpInStrSig       ScalarFuncSig = 4315
	ScalarFuncSig_RegexpInStrUTF8Sig   ScalarFuncSig = 4316
	ScalarFuncSig_RegexpReplaceSig     ScalarFuncSig = 4317
	ScalarFuncSig_RegexpReplaceUTF8Sig ScalarFuncSig = 4318
	ScalarFuncSig_RegexpSubstrSig      ScalarFuncSig = 4319
	ScalarFuncSig_RegexpSubstrUTF8Sig  ScalarFuncSig = 4320
	//json
	ScalarFuncSig_JsonExtractSig       ScalarFuncSig = 5001
	ScalarFuncSig_JsonUnquoteSig       ScalarFuncSig = 5002
	ScalarFuncSig_JsonTypeSig          ScalarFuncSig = 5003
	ScalarFuncSig_JsonSetSig           ScalarFuncSig = 5004
	ScalarFuncSig_JsonInsertSig        ScalarFuncSig = 5005
	ScalarFuncSig_JsonReplaceSig       ScalarFuncSig = 5006
	ScalarFuncSig_JsonRemoveSig        ScalarFuncSig = 5007
	ScalarFuncSig_JsonMergeSig         ScalarFuncSig = 5008
	ScalarFuncSig_JsonObjectSig        ScalarFuncSig = 5009
	ScalarFuncSig_JsonArraySig         ScalarFuncSig = 5010
	ScalarFuncSig_JsonValidJsonSig     ScalarFuncSig = 5011
	ScalarFuncSig_JsonContainsSig      ScalarFuncSig = 5012
	ScalarFuncSig_JsonArrayAppendSig   ScalarFuncSig = 5013
	ScalarFuncSig_JsonArrayInsertSig   ScalarFuncSig = 5014
	ScalarFuncSig_JsonMergePatchSig    ScalarFuncSig = 5015
	ScalarFuncSig_JsonMergePreserveSig ScalarFuncSig = 5016
	ScalarFuncSig_JsonContainsPathSig  ScalarFuncSig = 5017
	ScalarFuncSig_JsonPrettySig        ScalarFuncSig = 5018
	ScalarFuncSig_JsonQuoteSig         ScalarFuncSig = 5019
	ScalarFuncSig_JsonSearchSig        ScalarFuncSig = 5020
	ScalarFuncSig_JsonStorageSizeSig   ScalarFuncSig = 5021
	ScalarFuncSig_JsonDepthSig         ScalarFuncSig = 5022
	ScalarFuncSig_JsonKeysSig          ScalarFuncSig = 5023
	ScalarFuncSig_JsonLengthSig        ScalarFuncSig = 5024
	ScalarFuncSig_JsonKeys2ArgsSig     ScalarFuncSig = 5025
	ScalarFuncSig_JsonValidStringSig   ScalarFuncSig = 5026
	ScalarFuncSig_JsonValidOthersSig   ScalarFuncSig = 5027
	ScalarFuncSig_JsonStorageFreeSig   ScalarFuncSig = 5028
	//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,proto3" json:"indexes,omitempty"`
	Partitions           []string       `protobuf:"bytes,4,rep,name=partitions,proto3" json:"partitions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

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

func (*ScanAccessObject) XXX_DiscardUnknown 

func (m *ScanAccessObject) XXX_DiscardUnknown()

func (*ScanAccessObject) XXX_Marshal 

func (m *ScanAccessObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanAccessObject) XXX_Merge 

func (m *ScanAccessObject) XXX_Merge(src proto.Message)

func (*ScanAccessObject) XXX_Size 

func (m *ScanAccessObject) XXX_Size() int

func (*ScanAccessObject) XXX_Unmarshal 

func (m *ScanAccessObject) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *SelectResponse) MarshalToSizedBuffer(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

func (*SelectResponse) XXX_DiscardUnknown 

func (m *SelectResponse) XXX_DiscardUnknown()

func (*SelectResponse) XXX_Marshal 

func (m *SelectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SelectResponse) XXX_Merge 

func (m *SelectResponse) XXX_Merge(src proto.Message)

func (*SelectResponse) XXX_Size 

func (m *SelectResponse) XXX_Size() int

func (*SelectResponse) XXX_Unmarshal 

func (m *SelectResponse) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `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) MarshalToSizedBuffer 

func (m *Selection) MarshalToSizedBuffer(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

func (*Selection) XXX_DiscardUnknown 

func (m *Selection) XXX_DiscardUnknown()

func (*Selection) XXX_Marshal 

func (m *Selection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Selection) XXX_Merge 

func (m *Selection) XXX_Merge(src proto.Message)

func (*Selection) XXX_Size 

func (m *Selection) XXX_Size() int

func (*Selection) XXX_Unmarshal 

func (m *Selection) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `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) MarshalToSizedBuffer 

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

func (*Sort) XXX_DiscardUnknown 

func (m *Sort) XXX_DiscardUnknown()

func (*Sort) XXX_Marshal 

func (m *Sort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sort) XXX_Merge 

func (m *Sort) XXX_Merge(src proto.Message)

func (*Sort) XXX_Size 

func (m *Sort) XXX_Size() int

func (*Sort) XXX_Unmarshal 

func (m *Sort) XXX_Unmarshal(b []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_ab111404212_tipb_sharedbytes.SharedBytes `protobuf:"bytes,3,opt,name=data,customtype=github.com/ab111404212/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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *StreamResponse) MarshalToSizedBuffer(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

func (*StreamResponse) XXX_DiscardUnknown 

func (m *StreamResponse) XXX_DiscardUnknown()

func (*StreamResponse) XXX_Marshal 

func (m *StreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamResponse) XXX_Merge 

func (m *StreamResponse) XXX_Merge(src proto.Message)

func (*StreamResponse) XXX_Size 

func (m *StreamResponse) XXX_Size() int

func (*StreamResponse) XXX_Unmarshal 

func (m *StreamResponse) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `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) MarshalToSizedBuffer 

func (m *TableInfo) MarshalToSizedBuffer(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

func (*TableInfo) XXX_DiscardUnknown 

func (m *TableInfo) XXX_DiscardUnknown()

func (*TableInfo) XXX_Marshal 

func (m *TableInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableInfo) XXX_Merge 

func (m *TableInfo) XXX_Merge(src proto.Message)

func (*TableInfo) XXX_Size 

func (m *TableInfo) XXX_Size() int

func (*TableInfo) XXX_Unmarshal 

func (m *TableInfo) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral   struct{}      `json:"-"`
	XXX_unrecognized       []byte        `json:"-"`
	XXX_sizecache          int32         `json:"-"`
}

func (*TableScan) Descriptor 

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

func (*TableScan) GetColumns 

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

func (*TableScan) GetDesc 

func (m *TableScan) GetDesc() bool

func (*TableScan) GetIsFastScan 

func (m *TableScan) GetIsFastScan() bool

func (*TableScan) GetKeepOrder 

func (m *TableScan) GetKeepOrder() bool

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

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

func (*TableScan) GetTableId 

func (m *TableScan) GetTableId() int64

func (*TableScan) Marshal 

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

func (*TableScan) MarshalTo 

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

func (*TableScan) MarshalToSizedBuffer 

func (m *TableScan) MarshalToSizedBuffer(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

func (*TableScan) XXX_DiscardUnknown 

func (m *TableScan) XXX_DiscardUnknown()

func (*TableScan) XXX_Marshal 

func (m *TableScan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableScan) XXX_Merge 

func (m *TableScan) XXX_Merge(src proto.Message)

func (*TableScan) XXX_Size 

func (m *TableScan) XXX_Size() int

func (*TableScan) XXX_Unmarshal 

func (m *TableScan) XXX_Unmarshal(b []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 TiFlashScanContext 

type TiFlashScanContext struct {
	TotalDmfileScannedPacks            *uint64  `` /* 128-byte string literal not displayed */
	TotalDmfileSkippedPacks            *uint64  `` /* 128-byte string literal not displayed */
	TotalDmfileScannedRows             *uint64  `protobuf:"varint,3,opt,name=total_dmfile_scanned_rows,json=totalDmfileScannedRows" json:"total_dmfile_scanned_rows,omitempty"`
	TotalDmfileSkippedRows             *uint64  `protobuf:"varint,4,opt,name=total_dmfile_skipped_rows,json=totalDmfileSkippedRows" json:"total_dmfile_skipped_rows,omitempty"`
	TotalDmfileRoughSetIndexLoadTimeMs *uint64  `` /* 169-byte string literal not displayed */
	TotalDmfileReadTimeMs              *uint64  `protobuf:"varint,6,opt,name=total_dmfile_read_time_ms,json=totalDmfileReadTimeMs" json:"total_dmfile_read_time_ms,omitempty"`
	TotalCreateSnapshotTimeMs          *uint64  `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral               struct{} `json:"-"`
	XXX_unrecognized                   []byte   `json:"-"`
	XXX_sizecache                      int32    `json:"-"`
}

func (*TiFlashScanContext) Descriptor 

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

func (*TiFlashScanContext) GetTotalCreateSnapshotTimeMs 

func (m *TiFlashScanContext) GetTotalCreateSnapshotTimeMs() uint64

func (*TiFlashScanContext) GetTotalDmfileReadTimeMs 

func (m *TiFlashScanContext) GetTotalDmfileReadTimeMs() uint64

func (*TiFlashScanContext) GetTotalDmfileRoughSetIndexLoadTimeMs 

func (m *TiFlashScanContext) GetTotalDmfileRoughSetIndexLoadTimeMs() uint64

func (*TiFlashScanContext) GetTotalDmfileScannedPacks 

func (m *TiFlashScanContext) GetTotalDmfileScannedPacks() uint64

func (*TiFlashScanContext) GetTotalDmfileScannedRows 

func (m *TiFlashScanContext) GetTotalDmfileScannedRows() uint64

func (*TiFlashScanContext) GetTotalDmfileSkippedPacks 

func (m *TiFlashScanContext) GetTotalDmfileSkippedPacks() uint64

func (*TiFlashScanContext) GetTotalDmfileSkippedRows 

func (m *TiFlashScanContext) GetTotalDmfileSkippedRows() 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) MarshalToSizedBuffer 

func (m *TiFlashScanContext) MarshalToSizedBuffer(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

func (*TiFlashScanContext) XXX_DiscardUnknown 

func (m *TiFlashScanContext) XXX_DiscardUnknown()

func (*TiFlashScanContext) XXX_Marshal 

func (m *TiFlashScanContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TiFlashScanContext) XXX_Merge 

func (m *TiFlashScanContext) XXX_Merge(src proto.Message)

func (*TiFlashScanContext) XXX_Size 

func (m *TiFlashScanContext) XXX_Size() int

func (*TiFlashScanContext) XXX_Unmarshal 

func (m *TiFlashScanContext) XXX_Unmarshal(b []byte) error

type TopN 

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

func (*TopN) Descriptor 

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

func (*TopN) GetChild 

func (m *TopN) GetChild() *Executor

func (*TopN) GetLimit 

func (m *TopN) GetLimit() uint64

func (*TopN) GetOrderBy 

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

func (*TopN) Marshal 

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

func (*TopN) MarshalTo 

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

func (*TopN) MarshalToSizedBuffer 

func (m *TopN) MarshalToSizedBuffer(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

func (*TopN) XXX_DiscardUnknown 

func (m *TopN) XXX_DiscardUnknown()

func (*TopN) XXX_Marshal 

func (m *TopN) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopN) XXX_Merge 

func (m *TopN) XXX_Merge(src proto.Message)

func (*TopN) XXX_Size 

func (m *TopN) XXX_Size() int

func (*TopN) XXX_Unmarshal 

func (m *TopN) XXX_Unmarshal(b []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)
}

TopSQLAgentClient is the client API for TopSQLAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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
}

TopSQLAgentServer is the server API for TopSQLAgent service.

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

TopSQLPubSubClient is the client API for TopSQLPubSub service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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
}

TopSQLPubSubServer is the server API for TopSQLPubSub service.

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,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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

func (m *TopSQLRecord) MarshalToSizedBuffer(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

func (*TopSQLRecord) XXX_DiscardUnknown 

func (m *TopSQLRecord) XXX_DiscardUnknown()

func (*TopSQLRecord) XXX_Marshal 

func (m *TopSQLRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopSQLRecord) XXX_Merge 

func (m *TopSQLRecord) XXX_Merge(src proto.Message)

func (*TopSQLRecord) XXX_Size 

func (m *TopSQLRecord) XXX_Size() int

func (*TopSQLRecord) XXX_Unmarshal 

func (m *TopSQLRecord) XXX_Unmarshal(b []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 `` /* 199-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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (m *TopSQLRecordItem) MarshalToSizedBuffer(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

func (*TopSQLRecordItem) XXX_DiscardUnknown 

func (m *TopSQLRecordItem) XXX_DiscardUnknown()

func (*TopSQLRecordItem) XXX_Marshal 

func (m *TopSQLRecordItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopSQLRecordItem) XXX_Merge 

func (m *TopSQLRecordItem) XXX_Merge(src proto.Message)

func (*TopSQLRecordItem) XXX_Size 

func (m *TopSQLRecordItem) XXX_Size() int

func (*TopSQLRecordItem) XXX_Unmarshal 

func (m *TopSQLRecordItem) XXX_Unmarshal(b []byte) error

type TopSQLSubRequest 

type TopSQLSubRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (m *TopSQLSubRequest) MarshalToSizedBuffer(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

func (*TopSQLSubRequest) XXX_DiscardUnknown 

func (m *TopSQLSubRequest) XXX_DiscardUnknown()

func (*TopSQLSubRequest) XXX_Marshal 

func (m *TopSQLSubRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopSQLSubRequest) XXX_Merge 

func (m *TopSQLSubRequest) XXX_Merge(src proto.Message)

func (*TopSQLSubRequest) XXX_Size 

func (m *TopSQLSubRequest) XXX_Size() int

func (*TopSQLSubRequest) XXX_Unmarshal 

func (m *TopSQLSubRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

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

func (m *TopSQLSubResponse) MarshalToSizedBuffer(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_DiscardUnknown 

func (m *TopSQLSubResponse) XXX_DiscardUnknown()

func (*TopSQLSubResponse) XXX_Marshal 

func (m *TopSQLSubResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopSQLSubResponse) XXX_Merge 

func (m *TopSQLSubResponse) XXX_Merge(src proto.Message)

func (*TopSQLSubResponse) XXX_OneofWrappers 

func (*TopSQLSubResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TopSQLSubResponse) XXX_Size 

func (m *TopSQLSubResponse) XXX_Size() int

func (*TopSQLSubResponse) XXX_Unmarshal 

func (m *TopSQLSubResponse) XXX_Unmarshal(b []byte) error

type TopSQLSubResponse_PlanMeta 

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

func (*TopSQLSubResponse_PlanMeta) MarshalTo 

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

func (*TopSQLSubResponse_PlanMeta) MarshalToSizedBuffer 

func (m *TopSQLSubResponse_PlanMeta) MarshalToSizedBuffer(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,proto3,oneof" json:"record,omitempty"`
}

func (*TopSQLSubResponse_Record) MarshalTo 

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

func (*TopSQLSubResponse_Record) MarshalToSizedBuffer 

func (m *TopSQLSubResponse_Record) MarshalToSizedBuffer(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,proto3,oneof" json:"sql_meta,omitempty"`
}

func (*TopSQLSubResponse_SqlMeta) MarshalTo 

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

func (*TopSQLSubResponse_SqlMeta) MarshalToSizedBuffer 

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

func (*TopSQLSubResponse_SqlMeta) Size 

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

type UnimplementedTopSQLAgentServer 

type UnimplementedTopSQLAgentServer struct {
}

UnimplementedTopSQLAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedTopSQLAgentServer) ReportPlanMeta 

func (*UnimplementedTopSQLAgentServer) ReportPlanMeta(srv TopSQLAgent_ReportPlanMetaServer) error

func (*UnimplementedTopSQLAgentServer) ReportSQLMeta 

func (*UnimplementedTopSQLAgentServer) ReportSQLMeta(srv TopSQLAgent_ReportSQLMetaServer) error

func (*UnimplementedTopSQLAgentServer) ReportTopSQLRecords 

func (*UnimplementedTopSQLAgentServer) ReportTopSQLRecords(srv TopSQLAgent_ReportTopSQLRecordsServer) error

type UnimplementedTopSQLPubSubServer 

type UnimplementedTopSQLPubSubServer struct {
}

UnimplementedTopSQLPubSubServer can be embedded to have forward compatible implementations.

func (*UnimplementedTopSQLPubSubServer) Subscribe 

func (*UnimplementedTopSQLPubSubServer) Subscribe(req *TopSQLSubRequest, srv TopSQLPubSub_SubscribeServer) error

type UserIdentity 

type UserIdentity struct {
	UserName             string   `protobuf:"bytes,1,opt,name=user_name,json=userName" json:"user_name"`
	UserHost             string   `protobuf:"bytes,2,opt,name=user_host,json=userHost" json:"user_host"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) MarshalToSizedBuffer 

func (m *UserIdentity) MarshalToSizedBuffer(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

func (*UserIdentity) XXX_DiscardUnknown 

func (m *UserIdentity) XXX_DiscardUnknown()

func (*UserIdentity) XXX_Marshal 

func (m *UserIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserIdentity) XXX_Merge 

func (m *UserIdentity) XXX_Merge(src proto.Message)

func (*UserIdentity) XXX_Size 

func (m *UserIdentity) XXX_Size() int

func (*UserIdentity) XXX_Unmarshal 

func (m *UserIdentity) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `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) MarshalToSizedBuffer 

func (m *Window) MarshalToSizedBuffer(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

func (*Window) XXX_DiscardUnknown 

func (m *Window) XXX_DiscardUnknown()

func (*Window) XXX_Marshal 

func (m *Window) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Window) XXX_Merge 

func (m *Window) XXX_Merge(src proto.Message)

func (*Window) XXX_Size 

func (m *Window) XXX_Size() int

func (*Window) XXX_Unmarshal 

func (m *Window) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `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) MarshalToSizedBuffer 

func (m *WindowFrame) MarshalToSizedBuffer(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

func (*WindowFrame) XXX_DiscardUnknown 

func (m *WindowFrame) XXX_DiscardUnknown()

func (*WindowFrame) XXX_Marshal 

func (m *WindowFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WindowFrame) XXX_Merge 

func (m *WindowFrame) XXX_Merge(src proto.Message)

func (*WindowFrame) XXX_Size 

func (m *WindowFrame) XXX_Size() int

func (*WindowFrame) XXX_Unmarshal 

func (m *WindowFrame) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*WindowFrameBound) Descriptor 

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

func (*WindowFrameBound) GetCalcFuncs 

func (m *WindowFrameBound) GetCalcFuncs() []*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) MarshalToSizedBuffer 

func (m *WindowFrameBound) MarshalToSizedBuffer(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

func (*WindowFrameBound) XXX_DiscardUnknown 

func (m *WindowFrameBound) XXX_DiscardUnknown()

func (*WindowFrameBound) XXX_Marshal 

func (m *WindowFrameBound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WindowFrameBound) XXX_Merge 

func (m *WindowFrameBound) XXX_Merge(src proto.Message)

func (*WindowFrameBound) XXX_Size 

func (m *WindowFrameBound) XXX_Size() int

func (*WindowFrameBound) XXX_Unmarshal 

func (m *WindowFrameBound) XXX_Unmarshal(b []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.