Documentation ¶
Overview ¶
Package tipb is a generated protocol buffer package.
It is generated from these files:
analyze.proto checksum.proto executor.proto expression.proto schema.proto select.proto
It has these top-level messages:
AnalyzeReq AnalyzeIndexReq AnalyzeColumnsReq AnalyzeColumnsResp AnalyzeIndexResp Bucket Histogram FMSketch SampleCollector CMSketchRow CMSketch ChecksumRequest ChecksumResponse Executor TableScan IndexScan Selection Projection Aggregation TopN Limit FieldType Expr ByItem TableInfo ColumnInfo IndexInfo KeyRange Row Error SelectResponse Chunk RowMeta DAGRequest StreamResponse
Index ¶
- Variables
- type Aggregation
- func (*Aggregation) Descriptor() ([]byte, []int)
- func (m *Aggregation) GetAggFunc() []*Expr
- func (m *Aggregation) GetGroupBy() []*Expr
- func (m *Aggregation) GetStreamed() bool
- func (m *Aggregation) Marshal() (dAtA []byte, err error)
- func (m *Aggregation) MarshalTo(dAtA []byte) (int, error)
- func (*Aggregation) ProtoMessage()
- func (m *Aggregation) Reset()
- func (m *Aggregation) Size() (n int)
- func (m *Aggregation) String() string
- func (m *Aggregation) Unmarshal(dAtA []byte) error
- type AnalyzeColumnsReq
- func (*AnalyzeColumnsReq) Descriptor() ([]byte, []int)
- func (m *AnalyzeColumnsReq) GetBucketSize() int64
- func (m *AnalyzeColumnsReq) GetCmsketchDepth() int32
- func (m *AnalyzeColumnsReq) GetCmsketchWidth() int32
- func (m *AnalyzeColumnsReq) GetColumnsInfo() []*ColumnInfo
- func (m *AnalyzeColumnsReq) GetSampleSize() int64
- func (m *AnalyzeColumnsReq) GetSketchSize() int64
- func (m *AnalyzeColumnsReq) Marshal() (dAtA []byte, err error)
- func (m *AnalyzeColumnsReq) MarshalTo(dAtA []byte) (int, error)
- func (*AnalyzeColumnsReq) ProtoMessage()
- func (m *AnalyzeColumnsReq) Reset()
- func (m *AnalyzeColumnsReq) Size() (n int)
- func (m *AnalyzeColumnsReq) String() string
- func (m *AnalyzeColumnsReq) Unmarshal(dAtA []byte) error
- type AnalyzeColumnsResp
- func (*AnalyzeColumnsResp) Descriptor() ([]byte, []int)
- func (m *AnalyzeColumnsResp) GetCollectors() []*SampleCollector
- func (m *AnalyzeColumnsResp) GetPkHist() *Histogram
- func (m *AnalyzeColumnsResp) Marshal() (dAtA []byte, err error)
- func (m *AnalyzeColumnsResp) MarshalTo(dAtA []byte) (int, error)
- func (*AnalyzeColumnsResp) ProtoMessage()
- func (m *AnalyzeColumnsResp) Reset()
- func (m *AnalyzeColumnsResp) Size() (n int)
- func (m *AnalyzeColumnsResp) String() string
- func (m *AnalyzeColumnsResp) Unmarshal(dAtA []byte) error
- type AnalyzeIndexReq
- func (*AnalyzeIndexReq) Descriptor() ([]byte, []int)
- func (m *AnalyzeIndexReq) GetBucketSize() int64
- func (m *AnalyzeIndexReq) GetCmsketchDepth() int32
- func (m *AnalyzeIndexReq) GetCmsketchWidth() int32
- func (m *AnalyzeIndexReq) GetNumColumns() int32
- func (m *AnalyzeIndexReq) Marshal() (dAtA []byte, err error)
- func (m *AnalyzeIndexReq) MarshalTo(dAtA []byte) (int, error)
- func (*AnalyzeIndexReq) ProtoMessage()
- func (m *AnalyzeIndexReq) Reset()
- func (m *AnalyzeIndexReq) Size() (n int)
- func (m *AnalyzeIndexReq) String() string
- func (m *AnalyzeIndexReq) Unmarshal(dAtA []byte) error
- type AnalyzeIndexResp
- func (*AnalyzeIndexResp) Descriptor() ([]byte, []int)
- func (m *AnalyzeIndexResp) GetCms() *CMSketch
- func (m *AnalyzeIndexResp) GetHist() *Histogram
- func (m *AnalyzeIndexResp) Marshal() (dAtA []byte, err error)
- func (m *AnalyzeIndexResp) MarshalTo(dAtA []byte) (int, error)
- func (*AnalyzeIndexResp) ProtoMessage()
- func (m *AnalyzeIndexResp) Reset()
- func (m *AnalyzeIndexResp) Size() (n int)
- func (m *AnalyzeIndexResp) String() string
- func (m *AnalyzeIndexResp) Unmarshal(dAtA []byte) error
- type AnalyzeReq
- func (*AnalyzeReq) Descriptor() ([]byte, []int)
- func (m *AnalyzeReq) GetColReq() *AnalyzeColumnsReq
- func (m *AnalyzeReq) GetFlags() uint64
- func (m *AnalyzeReq) GetIdxReq() *AnalyzeIndexReq
- func (m *AnalyzeReq) GetStartTs() uint64
- func (m *AnalyzeReq) GetTimeZoneOffset() int64
- func (m *AnalyzeReq) GetTp() AnalyzeType
- func (m *AnalyzeReq) Marshal() (dAtA []byte, err error)
- func (m *AnalyzeReq) MarshalTo(dAtA []byte) (int, error)
- func (*AnalyzeReq) ProtoMessage()
- func (m *AnalyzeReq) Reset()
- func (m *AnalyzeReq) Size() (n int)
- func (m *AnalyzeReq) String() string
- func (m *AnalyzeReq) Unmarshal(dAtA []byte) error
- type AnalyzeType
- type Bucket
- func (*Bucket) Descriptor() ([]byte, []int)
- func (m *Bucket) GetCount() int64
- func (m *Bucket) GetLowerBound() []byte
- func (m *Bucket) GetRepeats() int64
- func (m *Bucket) GetUpperBound() []byte
- func (m *Bucket) Marshal() (dAtA []byte, err error)
- func (m *Bucket) MarshalTo(dAtA []byte) (int, error)
- func (*Bucket) ProtoMessage()
- func (m *Bucket) Reset()
- func (m *Bucket) Size() (n int)
- func (m *Bucket) String() string
- func (m *Bucket) Unmarshal(dAtA []byte) error
- type ByItem
- func (*ByItem) Descriptor() ([]byte, []int)
- func (m *ByItem) GetDesc() bool
- func (m *ByItem) GetExpr() *Expr
- func (m *ByItem) Marshal() (dAtA []byte, err error)
- func (m *ByItem) MarshalTo(dAtA []byte) (int, error)
- func (*ByItem) ProtoMessage()
- func (m *ByItem) Reset()
- func (m *ByItem) Size() (n int)
- func (m *ByItem) String() string
- func (m *ByItem) Unmarshal(dAtA []byte) error
- type CMSketch
- func (*CMSketch) Descriptor() ([]byte, []int)
- func (m *CMSketch) GetRows() []*CMSketchRow
- func (m *CMSketch) Marshal() (dAtA []byte, err error)
- func (m *CMSketch) MarshalTo(dAtA []byte) (int, error)
- func (*CMSketch) ProtoMessage()
- func (m *CMSketch) Reset()
- func (m *CMSketch) Size() (n int)
- func (m *CMSketch) String() string
- func (m *CMSketch) Unmarshal(dAtA []byte) error
- type CMSketchRow
- func (*CMSketchRow) Descriptor() ([]byte, []int)
- func (m *CMSketchRow) GetCounters() []uint32
- func (m *CMSketchRow) Marshal() (dAtA []byte, err error)
- func (m *CMSketchRow) MarshalTo(dAtA []byte) (int, error)
- func (*CMSketchRow) ProtoMessage()
- func (m *CMSketchRow) Reset()
- func (m *CMSketchRow) Size() (n int)
- func (m *CMSketchRow) String() string
- func (m *CMSketchRow) Unmarshal(dAtA []byte) error
- type ChecksumAlgorithm
- type ChecksumRequest
- func (*ChecksumRequest) Descriptor() ([]byte, []int)
- func (m *ChecksumRequest) GetAlgorithm() ChecksumAlgorithm
- func (m *ChecksumRequest) GetScanOn() ChecksumScanOn
- func (m *ChecksumRequest) GetStartTs() uint64
- func (m *ChecksumRequest) Marshal() (dAtA []byte, err error)
- func (m *ChecksumRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ChecksumRequest) ProtoMessage()
- func (m *ChecksumRequest) Reset()
- func (m *ChecksumRequest) Size() (n int)
- func (m *ChecksumRequest) String() string
- func (m *ChecksumRequest) Unmarshal(dAtA []byte) error
- type ChecksumResponse
- func (*ChecksumResponse) Descriptor() ([]byte, []int)
- func (m *ChecksumResponse) GetChecksum() uint64
- func (m *ChecksumResponse) GetTotalBytes() uint64
- func (m *ChecksumResponse) GetTotalKvs() uint64
- func (m *ChecksumResponse) Marshal() (dAtA []byte, err error)
- func (m *ChecksumResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ChecksumResponse) ProtoMessage()
- func (m *ChecksumResponse) Reset()
- func (m *ChecksumResponse) Size() (n int)
- func (m *ChecksumResponse) String() string
- func (m *ChecksumResponse) Unmarshal(dAtA []byte) error
- type ChecksumScanOn
- type Chunk
- func (*Chunk) Descriptor() ([]byte, []int)
- func (m *Chunk) GetRowsMeta() []RowMeta
- func (m *Chunk) Marshal() (dAtA []byte, err error)
- func (m *Chunk) MarshalTo(dAtA []byte) (int, error)
- func (*Chunk) ProtoMessage()
- func (m *Chunk) Reset()
- func (m *Chunk) Size() (n int)
- func (m *Chunk) String() string
- func (m *Chunk) Unmarshal(dAtA []byte) error
- type ColumnInfo
- func (*ColumnInfo) Descriptor() ([]byte, []int)
- func (m *ColumnInfo) GetCollation() int32
- func (m *ColumnInfo) GetColumnId() int64
- func (m *ColumnInfo) GetColumnLen() int32
- func (m *ColumnInfo) GetDecimal() int32
- func (m *ColumnInfo) GetDefaultVal() []byte
- func (m *ColumnInfo) GetElems() []string
- func (m *ColumnInfo) GetFlag() int32
- func (m *ColumnInfo) GetPkHandle() bool
- func (m *ColumnInfo) GetTp() int32
- func (m *ColumnInfo) Marshal() (dAtA []byte, err error)
- func (m *ColumnInfo) MarshalTo(dAtA []byte) (int, error)
- func (*ColumnInfo) ProtoMessage()
- func (m *ColumnInfo) Reset()
- func (m *ColumnInfo) Size() (n int)
- func (m *ColumnInfo) String() string
- func (m *ColumnInfo) Unmarshal(dAtA []byte) error
- type DAGRequest
- func (*DAGRequest) Descriptor() ([]byte, []int)
- func (m *DAGRequest) GetCollectRangeCounts() bool
- func (m *DAGRequest) GetEncodeType() EncodeType
- func (m *DAGRequest) GetExecutors() []*Executor
- func (m *DAGRequest) GetFlags() uint64
- func (m *DAGRequest) GetIsStrictSqlMode() bool
- func (m *DAGRequest) GetMaxWarningCount() uint64
- func (m *DAGRequest) GetOutputOffsets() []uint32
- func (m *DAGRequest) GetSqlMode() uint64
- func (m *DAGRequest) GetStartTs() uint64
- func (m *DAGRequest) GetTimeZoneName() string
- func (m *DAGRequest) GetTimeZoneOffset() int64
- func (m *DAGRequest) Marshal() (dAtA []byte, err error)
- func (m *DAGRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DAGRequest) ProtoMessage()
- func (m *DAGRequest) Reset()
- func (m *DAGRequest) Size() (n int)
- func (m *DAGRequest) String() string
- func (m *DAGRequest) Unmarshal(dAtA []byte) error
- type EncodeType
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetCode() int32
- func (m *Error) GetMsg() string
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- type ExecType
- type Executor
- func (*Executor) Descriptor() ([]byte, []int)
- func (m *Executor) GetAggregation() *Aggregation
- func (m *Executor) GetIdxScan() *IndexScan
- func (m *Executor) GetLimit() *Limit
- func (m *Executor) GetSelection() *Selection
- func (m *Executor) GetStreamAgg() *Aggregation
- func (m *Executor) GetTblScan() *TableScan
- func (m *Executor) GetTopN() *TopN
- func (m *Executor) GetTp() ExecType
- func (m *Executor) Marshal() (dAtA []byte, err error)
- func (m *Executor) MarshalTo(dAtA []byte) (int, error)
- func (*Executor) ProtoMessage()
- func (m *Executor) Reset()
- func (m *Executor) Size() (n int)
- func (m *Executor) String() string
- func (m *Executor) Unmarshal(dAtA []byte) error
- type Expr
- func (*Expr) Descriptor() ([]byte, []int)
- func (m *Expr) GetChildren() []*Expr
- func (m *Expr) GetFieldType() *FieldType
- func (m *Expr) GetSig() ScalarFuncSig
- func (m *Expr) GetTp() ExprType
- func (m *Expr) GetVal() []byte
- func (m *Expr) Marshal() (dAtA []byte, err error)
- func (m *Expr) MarshalTo(dAtA []byte) (int, error)
- func (*Expr) ProtoMessage()
- func (m *Expr) Reset()
- func (m *Expr) Size() (n int)
- func (m *Expr) String() string
- func (m *Expr) Unmarshal(dAtA []byte) error
- type ExprType
- type FMSketch
- func (*FMSketch) Descriptor() ([]byte, []int)
- func (m *FMSketch) GetHashset() []uint64
- func (m *FMSketch) GetMask() uint64
- func (m *FMSketch) Marshal() (dAtA []byte, err error)
- func (m *FMSketch) MarshalTo(dAtA []byte) (int, error)
- func (*FMSketch) ProtoMessage()
- func (m *FMSketch) Reset()
- func (m *FMSketch) Size() (n int)
- func (m *FMSketch) String() string
- func (m *FMSketch) Unmarshal(dAtA []byte) error
- type FieldType
- func (*FieldType) Descriptor() ([]byte, []int)
- func (m *FieldType) GetCharset() string
- func (m *FieldType) GetCollate() int32
- func (m *FieldType) GetDecimal() int32
- func (m *FieldType) GetFlag() uint32
- func (m *FieldType) GetFlen() int32
- func (m *FieldType) GetTp() int32
- func (m *FieldType) Marshal() (dAtA []byte, err error)
- func (m *FieldType) MarshalTo(dAtA []byte) (int, error)
- func (*FieldType) ProtoMessage()
- func (m *FieldType) Reset()
- func (m *FieldType) Size() (n int)
- func (m *FieldType) String() string
- func (m *FieldType) Unmarshal(dAtA []byte) error
- type Histogram
- func (*Histogram) Descriptor() ([]byte, []int)
- func (m *Histogram) GetBuckets() []*Bucket
- func (m *Histogram) GetNdv() int64
- func (m *Histogram) Marshal() (dAtA []byte, err error)
- func (m *Histogram) MarshalTo(dAtA []byte) (int, error)
- func (*Histogram) ProtoMessage()
- func (m *Histogram) Reset()
- func (m *Histogram) Size() (n int)
- func (m *Histogram) String() string
- func (m *Histogram) Unmarshal(dAtA []byte) error
- type IndexInfo
- func (*IndexInfo) Descriptor() ([]byte, []int)
- func (m *IndexInfo) GetColumns() []*ColumnInfo
- func (m *IndexInfo) GetIndexId() int64
- func (m *IndexInfo) GetTableId() int64
- func (m *IndexInfo) GetUnique() bool
- func (m *IndexInfo) Marshal() (dAtA []byte, err error)
- func (m *IndexInfo) MarshalTo(dAtA []byte) (int, error)
- func (*IndexInfo) ProtoMessage()
- func (m *IndexInfo) Reset()
- func (m *IndexInfo) Size() (n int)
- func (m *IndexInfo) String() string
- func (m *IndexInfo) Unmarshal(dAtA []byte) error
- type IndexScan
- func (*IndexScan) Descriptor() ([]byte, []int)
- func (m *IndexScan) GetColumns() []*ColumnInfo
- func (m *IndexScan) GetDesc() bool
- func (m *IndexScan) GetIndexId() int64
- func (m *IndexScan) GetTableId() int64
- func (m *IndexScan) GetUnique() bool
- func (m *IndexScan) Marshal() (dAtA []byte, err error)
- func (m *IndexScan) MarshalTo(dAtA []byte) (int, error)
- func (*IndexScan) ProtoMessage()
- func (m *IndexScan) Reset()
- func (m *IndexScan) Size() (n int)
- func (m *IndexScan) String() string
- func (m *IndexScan) Unmarshal(dAtA []byte) error
- type KeyRange
- func (*KeyRange) Descriptor() ([]byte, []int)
- func (m *KeyRange) GetHigh() []byte
- func (m *KeyRange) GetLow() []byte
- func (m *KeyRange) Marshal() (dAtA []byte, err error)
- func (m *KeyRange) MarshalTo(dAtA []byte) (int, error)
- func (*KeyRange) ProtoMessage()
- func (m *KeyRange) Reset()
- func (m *KeyRange) Size() (n int)
- func (m *KeyRange) String() string
- func (m *KeyRange) Unmarshal(dAtA []byte) error
- type Limit
- func (*Limit) Descriptor() ([]byte, []int)
- func (m *Limit) GetLimit() uint64
- func (m *Limit) Marshal() (dAtA []byte, err error)
- func (m *Limit) MarshalTo(dAtA []byte) (int, error)
- func (*Limit) ProtoMessage()
- func (m *Limit) Reset()
- func (m *Limit) Size() (n int)
- func (m *Limit) String() string
- func (m *Limit) Unmarshal(dAtA []byte) error
- type Projection
- func (*Projection) Descriptor() ([]byte, []int)
- func (m *Projection) GetExprs() []*Expr
- func (m *Projection) Marshal() (dAtA []byte, err error)
- func (m *Projection) MarshalTo(dAtA []byte) (int, error)
- func (*Projection) ProtoMessage()
- func (m *Projection) Reset()
- func (m *Projection) Size() (n int)
- func (m *Projection) String() string
- func (m *Projection) Unmarshal(dAtA []byte) error
- type Row
- func (*Row) Descriptor() ([]byte, []int)
- func (m *Row) GetData() []byte
- func (m *Row) GetHandle() []byte
- func (m *Row) Marshal() (dAtA []byte, err error)
- func (m *Row) MarshalTo(dAtA []byte) (int, error)
- func (*Row) ProtoMessage()
- func (m *Row) Reset()
- func (m *Row) Size() (n int)
- func (m *Row) String() string
- func (m *Row) Unmarshal(dAtA []byte) error
- type RowMeta
- func (*RowMeta) Descriptor() ([]byte, []int)
- func (m *RowMeta) GetHandle() int64
- func (m *RowMeta) GetLength() int64
- func (m *RowMeta) Marshal() (dAtA []byte, err error)
- func (m *RowMeta) MarshalTo(dAtA []byte) (int, error)
- func (*RowMeta) ProtoMessage()
- func (m *RowMeta) Reset()
- func (m *RowMeta) Size() (n int)
- func (m *RowMeta) String() string
- func (m *RowMeta) Unmarshal(dAtA []byte) error
- type SampleCollector
- func (*SampleCollector) Descriptor() ([]byte, []int)
- func (m *SampleCollector) GetCmSketch() *CMSketch
- func (m *SampleCollector) GetCount() int64
- func (m *SampleCollector) GetFmSketch() *FMSketch
- func (m *SampleCollector) GetNullCount() int64
- func (m *SampleCollector) GetSamples() [][]byte
- func (m *SampleCollector) GetTotalSize() int64
- func (m *SampleCollector) Marshal() (dAtA []byte, err error)
- func (m *SampleCollector) MarshalTo(dAtA []byte) (int, error)
- func (*SampleCollector) ProtoMessage()
- func (m *SampleCollector) Reset()
- func (m *SampleCollector) Size() (n int)
- func (m *SampleCollector) String() string
- func (m *SampleCollector) Unmarshal(dAtA []byte) error
- type ScalarFuncSig
- type SelectResponse
- func (*SelectResponse) Descriptor() ([]byte, []int)
- func (m *SelectResponse) GetChunks() []Chunk
- func (m *SelectResponse) GetError() *Error
- func (m *SelectResponse) GetOutputCounts() []int64
- func (m *SelectResponse) GetRows() []*Row
- func (m *SelectResponse) GetWarningCount() int64
- func (m *SelectResponse) GetWarnings() []*Error
- func (m *SelectResponse) Marshal() (dAtA []byte, err error)
- func (m *SelectResponse) MarshalTo(dAtA []byte) (int, error)
- func (*SelectResponse) ProtoMessage()
- func (m *SelectResponse) Reset()
- func (m *SelectResponse) Size() (n int)
- func (m *SelectResponse) String() string
- func (m *SelectResponse) Unmarshal(dAtA []byte) error
- type Selection
- func (*Selection) Descriptor() ([]byte, []int)
- func (m *Selection) GetConditions() []*Expr
- func (m *Selection) Marshal() (dAtA []byte, err error)
- func (m *Selection) MarshalTo(dAtA []byte) (int, error)
- func (*Selection) ProtoMessage()
- func (m *Selection) Reset()
- func (m *Selection) Size() (n int)
- func (m *Selection) String() string
- func (m *Selection) Unmarshal(dAtA []byte) error
- type StreamResponse
- func (*StreamResponse) Descriptor() ([]byte, []int)
- func (m *StreamResponse) GetError() *Error
- func (m *StreamResponse) GetOutputCounts() []int64
- func (m *StreamResponse) GetWarningCount() int64
- func (m *StreamResponse) GetWarnings() []*Error
- func (m *StreamResponse) Marshal() (dAtA []byte, err error)
- func (m *StreamResponse) MarshalTo(dAtA []byte) (int, error)
- func (*StreamResponse) ProtoMessage()
- func (m *StreamResponse) Reset()
- func (m *StreamResponse) Size() (n int)
- func (m *StreamResponse) String() string
- func (m *StreamResponse) Unmarshal(dAtA []byte) error
- type TableInfo
- func (*TableInfo) Descriptor() ([]byte, []int)
- func (m *TableInfo) GetColumns() []*ColumnInfo
- func (m *TableInfo) GetTableId() int64
- func (m *TableInfo) Marshal() (dAtA []byte, err error)
- func (m *TableInfo) MarshalTo(dAtA []byte) (int, error)
- func (*TableInfo) ProtoMessage()
- func (m *TableInfo) Reset()
- func (m *TableInfo) Size() (n int)
- func (m *TableInfo) String() string
- func (m *TableInfo) Unmarshal(dAtA []byte) error
- type TableScan
- func (*TableScan) Descriptor() ([]byte, []int)
- func (m *TableScan) GetColumns() []*ColumnInfo
- func (m *TableScan) GetDesc() bool
- func (m *TableScan) GetTableId() int64
- func (m *TableScan) Marshal() (dAtA []byte, err error)
- func (m *TableScan) MarshalTo(dAtA []byte) (int, error)
- func (*TableScan) ProtoMessage()
- func (m *TableScan) Reset()
- func (m *TableScan) Size() (n int)
- func (m *TableScan) String() string
- func (m *TableScan) Unmarshal(dAtA []byte) error
- type TopN
- func (*TopN) Descriptor() ([]byte, []int)
- func (m *TopN) GetLimit() uint64
- func (m *TopN) GetOrderBy() []*ByItem
- func (m *TopN) Marshal() (dAtA []byte, err error)
- func (m *TopN) MarshalTo(dAtA []byte) (int, error)
- func (*TopN) ProtoMessage()
- func (m *TopN) Reset()
- func (m *TopN) Size() (n int)
- func (m *TopN) String() string
- func (m *TopN) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthAnalyze = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAnalyze = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthChecksum = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowChecksum = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthExecutor = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowExecutor = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthExpression = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowExpression = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSchema = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthSelect = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSelect = fmt.Errorf("proto: integer overflow") )
var AnalyzeType_name = map[int32]string{
0: "TypeIndex",
1: "TypeColumn",
}
var AnalyzeType_value = map[string]int32{
"TypeIndex": 0,
"TypeColumn": 1,
}
var ChecksumAlgorithm_name = map[int32]string{
0: "Crc64_Xor",
}
var ChecksumAlgorithm_value = map[string]int32{
"Crc64_Xor": 0,
}
var ChecksumScanOn_name = map[int32]string{
0: "Table",
1: "Index",
}
var ChecksumScanOn_value = map[string]int32{
"Table": 0,
"Index": 1,
}
var EncodeType_name = map[int32]string{
0: "TypeDefault",
1: "TypeArrow",
}
var EncodeType_value = map[string]int32{
"TypeDefault": 0,
"TypeArrow": 1,
}
var ExecType_name = map[int32]string{
0: "TypeTableScan",
1: "TypeIndexScan",
2: "TypeSelection",
3: "TypeAggregation",
4: "TypeTopN",
5: "TypeLimit",
6: "TypeStreamAgg",
}
var ExecType_value = map[string]int32{
"TypeTableScan": 0,
"TypeIndexScan": 1,
"TypeSelection": 2,
"TypeAggregation": 3,
"TypeTopN": 4,
"TypeLimit": 5,
"TypeStreamAgg": 6,
}
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",
10000: "ScalarFunc",
}
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,
"ScalarFunc": 10000,
}
var ScalarFuncSig_name = map[int32]string{}/* 485 elements not displayed */
var ScalarFuncSig_value = map[string]int32{}/* 485 elements not displayed */
Functions ¶
This section is empty.
Types ¶
type Aggregation ¶
type Aggregation struct { // Group by clause. GroupBy []*Expr `protobuf:"bytes,1,rep,name=group_by,json=groupBy" json:"group_by,omitempty"` // Aggregate functions. AggFunc []*Expr `protobuf:"bytes,2,rep,name=agg_func,json=aggFunc" json:"agg_func,omitempty"` // If it is a stream aggregation. Streamed bool `protobuf:"varint,3,opt,name=streamed" json:"streamed"` XXX_unrecognized []byte `json:"-"` }
func (*Aggregation) Descriptor ¶
func (*Aggregation) Descriptor() ([]byte, []int)
func (*Aggregation) GetAggFunc ¶
func (m *Aggregation) GetAggFunc() []*Expr
func (*Aggregation) GetGroupBy ¶
func (m *Aggregation) GetGroupBy() []*Expr
func (*Aggregation) GetStreamed ¶
func (m *Aggregation) GetStreamed() bool
func (*Aggregation) Marshal ¶
func (m *Aggregation) Marshal() (dAtA []byte, err error)
func (*Aggregation) ProtoMessage ¶
func (*Aggregation) ProtoMessage()
func (*Aggregation) Reset ¶
func (m *Aggregation) Reset()
func (*Aggregation) Size ¶
func (m *Aggregation) Size() (n int)
func (*Aggregation) String ¶
func (m *Aggregation) String() string
func (*Aggregation) Unmarshal ¶
func (m *Aggregation) Unmarshal(dAtA []byte) error
type AnalyzeColumnsReq ¶
type AnalyzeColumnsReq struct { // bucket_size is the max histograms bucket size, we need this because when primary key is handle, // the histogram will be directly built. BucketSize int64 `protobuf:"varint,1,opt,name=bucket_size,json=bucketSize" json:"bucket_size"` // sample_size is the max number of samples that will be collected. SampleSize int64 `protobuf:"varint,2,opt,name=sample_size,json=sampleSize" json:"sample_size"` // sketch_size is the max sketch size. SketchSize int64 `protobuf:"varint,3,opt,name=sketch_size,json=sketchSize" json:"sketch_size"` // columns_info is the info of all the columns that needs to be analyzed. ColumnsInfo []*ColumnInfo `protobuf:"bytes,4,rep,name=columns_info,json=columnsInfo" json:"columns_info,omitempty"` CmsketchDepth *int32 `protobuf:"varint,5,opt,name=cmsketch_depth,json=cmsketchDepth" json:"cmsketch_depth,omitempty"` CmsketchWidth *int32 `protobuf:"varint,6,opt,name=cmsketch_width,json=cmsketchWidth" json:"cmsketch_width,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AnalyzeColumnsReq) Descriptor ¶
func (*AnalyzeColumnsReq) Descriptor() ([]byte, []int)
func (*AnalyzeColumnsReq) GetBucketSize ¶
func (m *AnalyzeColumnsReq) GetBucketSize() int64
func (*AnalyzeColumnsReq) GetCmsketchDepth ¶
func (m *AnalyzeColumnsReq) GetCmsketchDepth() int32
func (*AnalyzeColumnsReq) GetCmsketchWidth ¶
func (m *AnalyzeColumnsReq) GetCmsketchWidth() int32
func (*AnalyzeColumnsReq) GetColumnsInfo ¶
func (m *AnalyzeColumnsReq) GetColumnsInfo() []*ColumnInfo
func (*AnalyzeColumnsReq) GetSampleSize ¶
func (m *AnalyzeColumnsReq) GetSampleSize() int64
func (*AnalyzeColumnsReq) GetSketchSize ¶
func (m *AnalyzeColumnsReq) GetSketchSize() int64
func (*AnalyzeColumnsReq) Marshal ¶
func (m *AnalyzeColumnsReq) Marshal() (dAtA []byte, err error)
func (*AnalyzeColumnsReq) MarshalTo ¶
func (m *AnalyzeColumnsReq) MarshalTo(dAtA []byte) (int, error)
func (*AnalyzeColumnsReq) ProtoMessage ¶
func (*AnalyzeColumnsReq) ProtoMessage()
func (*AnalyzeColumnsReq) Reset ¶
func (m *AnalyzeColumnsReq) Reset()
func (*AnalyzeColumnsReq) Size ¶
func (m *AnalyzeColumnsReq) Size() (n int)
func (*AnalyzeColumnsReq) String ¶
func (m *AnalyzeColumnsReq) String() string
func (*AnalyzeColumnsReq) Unmarshal ¶
func (m *AnalyzeColumnsReq) Unmarshal(dAtA []byte) error
type AnalyzeColumnsResp ¶
type AnalyzeColumnsResp struct { // collectors is the sample collectors for columns. Collectors []*SampleCollector `protobuf:"bytes,1,rep,name=collectors" json:"collectors,omitempty"` // pk_hist is the histogram for primary key when it is the handle. PkHist *Histogram `protobuf:"bytes,2,opt,name=pk_hist,json=pkHist" json:"pk_hist,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AnalyzeColumnsResp) Descriptor ¶
func (*AnalyzeColumnsResp) Descriptor() ([]byte, []int)
func (*AnalyzeColumnsResp) GetCollectors ¶
func (m *AnalyzeColumnsResp) GetCollectors() []*SampleCollector
func (*AnalyzeColumnsResp) GetPkHist ¶
func (m *AnalyzeColumnsResp) GetPkHist() *Histogram
func (*AnalyzeColumnsResp) Marshal ¶
func (m *AnalyzeColumnsResp) Marshal() (dAtA []byte, err error)
func (*AnalyzeColumnsResp) MarshalTo ¶
func (m *AnalyzeColumnsResp) MarshalTo(dAtA []byte) (int, error)
func (*AnalyzeColumnsResp) ProtoMessage ¶
func (*AnalyzeColumnsResp) ProtoMessage()
func (*AnalyzeColumnsResp) Reset ¶
func (m *AnalyzeColumnsResp) Reset()
func (*AnalyzeColumnsResp) Size ¶
func (m *AnalyzeColumnsResp) Size() (n int)
func (*AnalyzeColumnsResp) String ¶
func (m *AnalyzeColumnsResp) String() string
func (*AnalyzeColumnsResp) Unmarshal ¶
func (m *AnalyzeColumnsResp) Unmarshal(dAtA []byte) error
type AnalyzeIndexReq ¶
type AnalyzeIndexReq struct { // bucket_size is the max histograms bucket size. BucketSize int64 `protobuf:"varint,1,opt,name=bucket_size,json=bucketSize" json:"bucket_size"` // num_columns is the number of columns in the index. NumColumns int32 `protobuf:"varint,2,opt,name=num_columns,json=numColumns" json:"num_columns"` CmsketchDepth *int32 `protobuf:"varint,3,opt,name=cmsketch_depth,json=cmsketchDepth" json:"cmsketch_depth,omitempty"` CmsketchWidth *int32 `protobuf:"varint,4,opt,name=cmsketch_width,json=cmsketchWidth" json:"cmsketch_width,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AnalyzeIndexReq) Descriptor ¶
func (*AnalyzeIndexReq) Descriptor() ([]byte, []int)
func (*AnalyzeIndexReq) GetBucketSize ¶
func (m *AnalyzeIndexReq) GetBucketSize() int64
func (*AnalyzeIndexReq) GetCmsketchDepth ¶
func (m *AnalyzeIndexReq) GetCmsketchDepth() int32
func (*AnalyzeIndexReq) GetCmsketchWidth ¶
func (m *AnalyzeIndexReq) GetCmsketchWidth() int32
func (*AnalyzeIndexReq) GetNumColumns ¶
func (m *AnalyzeIndexReq) GetNumColumns() int32
func (*AnalyzeIndexReq) Marshal ¶
func (m *AnalyzeIndexReq) Marshal() (dAtA []byte, err error)
func (*AnalyzeIndexReq) ProtoMessage ¶
func (*AnalyzeIndexReq) ProtoMessage()
func (*AnalyzeIndexReq) Reset ¶
func (m *AnalyzeIndexReq) Reset()
func (*AnalyzeIndexReq) Size ¶
func (m *AnalyzeIndexReq) Size() (n int)
func (*AnalyzeIndexReq) String ¶
func (m *AnalyzeIndexReq) String() string
func (*AnalyzeIndexReq) Unmarshal ¶
func (m *AnalyzeIndexReq) Unmarshal(dAtA []byte) error
type AnalyzeIndexResp ¶
type AnalyzeIndexResp struct { Hist *Histogram `protobuf:"bytes,1,opt,name=hist" json:"hist,omitempty"` Cms *CMSketch `protobuf:"bytes,2,opt,name=cms" json:"cms,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AnalyzeIndexResp) Descriptor ¶
func (*AnalyzeIndexResp) Descriptor() ([]byte, []int)
func (*AnalyzeIndexResp) GetCms ¶
func (m *AnalyzeIndexResp) GetCms() *CMSketch
func (*AnalyzeIndexResp) GetHist ¶
func (m *AnalyzeIndexResp) GetHist() *Histogram
func (*AnalyzeIndexResp) Marshal ¶
func (m *AnalyzeIndexResp) Marshal() (dAtA []byte, err error)
func (*AnalyzeIndexResp) ProtoMessage ¶
func (*AnalyzeIndexResp) ProtoMessage()
func (*AnalyzeIndexResp) Reset ¶
func (m *AnalyzeIndexResp) Reset()
func (*AnalyzeIndexResp) Size ¶
func (m *AnalyzeIndexResp) Size() (n int)
func (*AnalyzeIndexResp) String ¶
func (m *AnalyzeIndexResp) String() string
func (*AnalyzeIndexResp) Unmarshal ¶
func (m *AnalyzeIndexResp) Unmarshal(dAtA []byte) error
type AnalyzeReq ¶
type AnalyzeReq struct { Tp AnalyzeType `protobuf:"varint,1,opt,name=tp,enum=tipb.AnalyzeType" json:"tp"` StartTs uint64 `protobuf:"varint,2,opt,name=start_ts,json=startTs" json:"start_ts"` Flags uint64 `protobuf:"varint,3,opt,name=flags" json:"flags"` TimeZoneOffset int64 `protobuf:"varint,4,opt,name=time_zone_offset,json=timeZoneOffset" json:"time_zone_offset"` IdxReq *AnalyzeIndexReq `protobuf:"bytes,5,opt,name=idx_req,json=idxReq" json:"idx_req,omitempty"` ColReq *AnalyzeColumnsReq `protobuf:"bytes,6,opt,name=col_req,json=colReq" json:"col_req,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AnalyzeReq) Descriptor ¶
func (*AnalyzeReq) Descriptor() ([]byte, []int)
func (*AnalyzeReq) GetColReq ¶
func (m *AnalyzeReq) GetColReq() *AnalyzeColumnsReq
func (*AnalyzeReq) GetFlags ¶
func (m *AnalyzeReq) GetFlags() uint64
func (*AnalyzeReq) GetIdxReq ¶
func (m *AnalyzeReq) GetIdxReq() *AnalyzeIndexReq
func (*AnalyzeReq) GetStartTs ¶
func (m *AnalyzeReq) GetStartTs() uint64
func (*AnalyzeReq) GetTimeZoneOffset ¶
func (m *AnalyzeReq) GetTimeZoneOffset() int64
func (*AnalyzeReq) GetTp ¶
func (m *AnalyzeReq) GetTp() AnalyzeType
func (*AnalyzeReq) Marshal ¶
func (m *AnalyzeReq) Marshal() (dAtA []byte, err error)
func (*AnalyzeReq) ProtoMessage ¶
func (*AnalyzeReq) ProtoMessage()
func (*AnalyzeReq) Reset ¶
func (m *AnalyzeReq) Reset()
func (*AnalyzeReq) Size ¶
func (m *AnalyzeReq) Size() (n int)
func (*AnalyzeReq) String ¶
func (m *AnalyzeReq) String() string
func (*AnalyzeReq) Unmarshal ¶
func (m *AnalyzeReq) Unmarshal(dAtA []byte) error
type AnalyzeType ¶
type AnalyzeType int32
const ( AnalyzeType_TypeIndex AnalyzeType = 0 AnalyzeType_TypeColumn AnalyzeType = 1 )
func (AnalyzeType) Enum ¶
func (x AnalyzeType) Enum() *AnalyzeType
func (AnalyzeType) EnumDescriptor ¶
func (AnalyzeType) EnumDescriptor() ([]byte, []int)
func (AnalyzeType) String ¶
func (x AnalyzeType) String() string
func (*AnalyzeType) UnmarshalJSON ¶
func (x *AnalyzeType) UnmarshalJSON(data []byte) error
type Bucket ¶
type Bucket struct { Count int64 `protobuf:"varint,1,opt,name=count" json:"count"` LowerBound []byte `protobuf:"bytes,2,opt,name=lower_bound,json=lowerBound" json:"lower_bound,omitempty"` UpperBound []byte `protobuf:"bytes,3,opt,name=upper_bound,json=upperBound" json:"upper_bound,omitempty"` Repeats int64 `protobuf:"varint,4,opt,name=repeats" json:"repeats"` XXX_unrecognized []byte `json:"-"` }
Bucket is an element of histogram.
func (*Bucket) Descriptor ¶
func (*Bucket) GetLowerBound ¶
func (*Bucket) GetRepeats ¶
func (*Bucket) GetUpperBound ¶
func (*Bucket) ProtoMessage ¶
func (*Bucket) ProtoMessage()
type ByItem ¶
type ByItem struct { Expr *Expr `protobuf:"bytes,1,opt,name=expr" json:"expr,omitempty"` Desc bool `protobuf:"varint,2,opt,name=desc" json:"desc"` XXX_unrecognized []byte `json:"-"` }
ByItem type for group by and order by.
func (*ByItem) Descriptor ¶
func (*ByItem) ProtoMessage ¶
func (*ByItem) ProtoMessage()
type CMSketch ¶
type CMSketch struct { Rows []*CMSketchRow `protobuf:"bytes,1,rep,name=rows" json:"rows,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CMSketch) Descriptor ¶
func (*CMSketch) GetRows ¶
func (m *CMSketch) GetRows() []*CMSketchRow
func (*CMSketch) ProtoMessage ¶
func (*CMSketch) ProtoMessage()
type CMSketchRow ¶
type CMSketchRow struct { Counters []uint32 `protobuf:"varint,1,rep,name=counters" json:"counters,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CMSketchRow) Descriptor ¶
func (*CMSketchRow) Descriptor() ([]byte, []int)
func (*CMSketchRow) GetCounters ¶
func (m *CMSketchRow) GetCounters() []uint32
func (*CMSketchRow) Marshal ¶
func (m *CMSketchRow) Marshal() (dAtA []byte, err error)
func (*CMSketchRow) ProtoMessage ¶
func (*CMSketchRow) ProtoMessage()
func (*CMSketchRow) Reset ¶
func (m *CMSketchRow) Reset()
func (*CMSketchRow) Size ¶
func (m *CMSketchRow) Size() (n int)
func (*CMSketchRow) String ¶
func (m *CMSketchRow) String() string
func (*CMSketchRow) Unmarshal ¶
func (m *CMSketchRow) Unmarshal(dAtA []byte) error
type ChecksumAlgorithm ¶
type ChecksumAlgorithm int32
const (
ChecksumAlgorithm_Crc64_Xor ChecksumAlgorithm = 0
)
func (ChecksumAlgorithm) Enum ¶
func (x ChecksumAlgorithm) Enum() *ChecksumAlgorithm
func (ChecksumAlgorithm) EnumDescriptor ¶
func (ChecksumAlgorithm) EnumDescriptor() ([]byte, []int)
func (ChecksumAlgorithm) String ¶
func (x ChecksumAlgorithm) String() string
func (*ChecksumAlgorithm) UnmarshalJSON ¶
func (x *ChecksumAlgorithm) UnmarshalJSON(data []byte) error
type ChecksumRequest ¶
type ChecksumRequest struct { StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs" json:"start_ts"` ScanOn ChecksumScanOn `protobuf:"varint,2,opt,name=scan_on,json=scanOn,enum=tipb.ChecksumScanOn" json:"scan_on"` Algorithm ChecksumAlgorithm `protobuf:"varint,3,opt,name=algorithm,enum=tipb.ChecksumAlgorithm" json:"algorithm"` XXX_unrecognized []byte `json:"-"` }
func (*ChecksumRequest) Descriptor ¶
func (*ChecksumRequest) Descriptor() ([]byte, []int)
func (*ChecksumRequest) GetAlgorithm ¶
func (m *ChecksumRequest) GetAlgorithm() ChecksumAlgorithm
func (*ChecksumRequest) GetScanOn ¶
func (m *ChecksumRequest) GetScanOn() ChecksumScanOn
func (*ChecksumRequest) GetStartTs ¶
func (m *ChecksumRequest) GetStartTs() uint64
func (*ChecksumRequest) Marshal ¶
func (m *ChecksumRequest) Marshal() (dAtA []byte, err error)
func (*ChecksumRequest) ProtoMessage ¶
func (*ChecksumRequest) ProtoMessage()
func (*ChecksumRequest) Reset ¶
func (m *ChecksumRequest) Reset()
func (*ChecksumRequest) Size ¶
func (m *ChecksumRequest) Size() (n int)
func (*ChecksumRequest) String ¶
func (m *ChecksumRequest) String() string
func (*ChecksumRequest) Unmarshal ¶
func (m *ChecksumRequest) Unmarshal(dAtA []byte) error
type ChecksumResponse ¶
type ChecksumResponse struct { Checksum uint64 `protobuf:"varint,1,opt,name=checksum" json:"checksum"` TotalKvs uint64 `protobuf:"varint,2,opt,name=total_kvs,json=totalKvs" json:"total_kvs"` TotalBytes uint64 `protobuf:"varint,3,opt,name=total_bytes,json=totalBytes" json:"total_bytes"` XXX_unrecognized []byte `json:"-"` }
func (*ChecksumResponse) Descriptor ¶
func (*ChecksumResponse) Descriptor() ([]byte, []int)
func (*ChecksumResponse) GetChecksum ¶
func (m *ChecksumResponse) GetChecksum() uint64
func (*ChecksumResponse) GetTotalBytes ¶
func (m *ChecksumResponse) GetTotalBytes() uint64
func (*ChecksumResponse) GetTotalKvs ¶
func (m *ChecksumResponse) GetTotalKvs() uint64
func (*ChecksumResponse) Marshal ¶
func (m *ChecksumResponse) Marshal() (dAtA []byte, err error)
func (*ChecksumResponse) ProtoMessage ¶
func (*ChecksumResponse) ProtoMessage()
func (*ChecksumResponse) Reset ¶
func (m *ChecksumResponse) Reset()
func (*ChecksumResponse) Size ¶
func (m *ChecksumResponse) Size() (n int)
func (*ChecksumResponse) String ¶
func (m *ChecksumResponse) String() string
func (*ChecksumResponse) Unmarshal ¶
func (m *ChecksumResponse) Unmarshal(dAtA []byte) error
type ChecksumScanOn ¶
type ChecksumScanOn int32
const ( ChecksumScanOn_Table ChecksumScanOn = 0 ChecksumScanOn_Index ChecksumScanOn = 1 )
func (ChecksumScanOn) Enum ¶
func (x ChecksumScanOn) Enum() *ChecksumScanOn
func (ChecksumScanOn) EnumDescriptor ¶
func (ChecksumScanOn) EnumDescriptor() ([]byte, []int)
func (ChecksumScanOn) String ¶
func (x ChecksumScanOn) String() string
func (*ChecksumScanOn) UnmarshalJSON ¶
func (x *ChecksumScanOn) UnmarshalJSON(data []byte) error
type Chunk ¶
type Chunk struct { // Data for all rows in the chunk. RowsData github_com_pingcap_tipb_sharedbytes.SharedBytes `` /* 127-byte string literal not displayed */ // Meta data for every row. RowsMeta []RowMeta `protobuf:"bytes,4,rep,name=rows_meta,json=rowsMeta" json:"rows_meta"` XXX_unrecognized []byte `json:"-"` }
Chunk contains multiple rows data and rows meta.
func (*Chunk) Descriptor ¶
func (*Chunk) GetRowsMeta ¶
func (*Chunk) ProtoMessage ¶
func (*Chunk) ProtoMessage()
type ColumnInfo ¶
type ColumnInfo struct { ColumnId int64 `protobuf:"varint,1,opt,name=column_id,json=columnId" json:"column_id"` Tp int32 `protobuf:"varint,2,opt,name=tp" json:"tp"` Collation int32 `protobuf:"varint,3,opt,name=collation" json:"collation"` ColumnLen int32 `protobuf:"varint,4,opt,name=columnLen" json:"columnLen"` Decimal int32 `protobuf:"varint,5,opt,name=decimal" json:"decimal"` Flag int32 `protobuf:"varint,6,opt,name=flag" json:"flag"` Elems []string `protobuf:"bytes,7,rep,name=elems" json:"elems,omitempty"` DefaultVal []byte `protobuf:"bytes,8,opt,name=default_val,json=defaultVal" json:"default_val,omitempty"` PkHandle bool `protobuf:"varint,21,opt,name=pk_handle,json=pkHandle" json:"pk_handle"` XXX_unrecognized []byte `json:"-"` }
func (*ColumnInfo) Descriptor ¶
func (*ColumnInfo) Descriptor() ([]byte, []int)
func (*ColumnInfo) GetCollation ¶
func (m *ColumnInfo) GetCollation() int32
func (*ColumnInfo) GetColumnId ¶
func (m *ColumnInfo) GetColumnId() int64
func (*ColumnInfo) GetColumnLen ¶
func (m *ColumnInfo) GetColumnLen() int32
func (*ColumnInfo) GetDecimal ¶
func (m *ColumnInfo) GetDecimal() int32
func (*ColumnInfo) GetDefaultVal ¶
func (m *ColumnInfo) GetDefaultVal() []byte
func (*ColumnInfo) GetElems ¶
func (m *ColumnInfo) GetElems() []string
func (*ColumnInfo) GetFlag ¶
func (m *ColumnInfo) GetFlag() int32
func (*ColumnInfo) GetPkHandle ¶
func (m *ColumnInfo) GetPkHandle() bool
func (*ColumnInfo) GetTp ¶
func (m *ColumnInfo) GetTp() int32
func (*ColumnInfo) Marshal ¶
func (m *ColumnInfo) Marshal() (dAtA []byte, err error)
func (*ColumnInfo) ProtoMessage ¶
func (*ColumnInfo) ProtoMessage()
func (*ColumnInfo) Reset ¶
func (m *ColumnInfo) Reset()
func (*ColumnInfo) Size ¶
func (m *ColumnInfo) Size() (n int)
func (*ColumnInfo) String ¶
func (m *ColumnInfo) String() string
func (*ColumnInfo) Unmarshal ¶
func (m *ColumnInfo) Unmarshal(dAtA []byte) error
type DAGRequest ¶
type DAGRequest struct { // Transaction start timestamp. StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs" json:"start_ts"` // It represents push down Executors. Executors []*Executor `protobuf:"bytes,2,rep,name=executors" json:"executors,omitempty"` // time zone offset in seconds TimeZoneOffset int64 `protobuf:"varint,3,opt,name=time_zone_offset,json=timeZoneOffset" json:"time_zone_offset"` // flags are used to store flags that change the execution mode, it contains: // ignore_truncate = 1 // truncate error should be ignore if set. // truncate_as_warning = 1 << 1 // when ignored_truncate is not set, return warning instead of error if this flag is set. // ... // add more when needed. Flags uint64 `protobuf:"varint,4,opt,name=flags" json:"flags"` // It represents which columns we should output. OutputOffsets []uint32 `protobuf:"varint,5,rep,name=output_offsets,json=outputOffsets" json:"output_offsets,omitempty"` // It represents whether we collect the detailed scan counts in each range. CollectRangeCounts *bool `protobuf:"varint,6,opt,name=collect_range_counts,json=collectRangeCounts" json:"collect_range_counts,omitempty"` // It indicates the maximum number of warning, // which is the number of messages that SHOW WARNINGS displays. MaxWarningCount *uint64 `protobuf:"varint,7,opt,name=max_warning_count,json=maxWarningCount" json:"max_warning_count,omitempty"` // It indicates the encode type of response. EncodeType EncodeType `protobuf:"varint,8,opt,name=encode_type,json=encodeType,enum=tipb.EncodeType" json:"encode_type"` // It indicates the sql_mode. SqlMode *uint64 `protobuf:"varint,9,opt,name=sql_mode,json=sqlMode" json:"sql_mode,omitempty"` // It indicates whether the sql mode is strict. IsStrictSqlMode *bool `protobuf:"varint,10,opt,name=is_strict_sql_mode,json=isStrictSqlMode" json:"is_strict_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"` XXX_unrecognized []byte `json:"-"` }
DAGRequest represents the request that will be handled with DAG mode.
func (*DAGRequest) Descriptor ¶
func (*DAGRequest) Descriptor() ([]byte, []int)
func (*DAGRequest) 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) GetIsStrictSqlMode ¶
func (m *DAGRequest) GetIsStrictSqlMode() bool
func (*DAGRequest) GetMaxWarningCount ¶
func (m *DAGRequest) GetMaxWarningCount() uint64
func (*DAGRequest) GetOutputOffsets ¶
func (m *DAGRequest) GetOutputOffsets() []uint32
func (*DAGRequest) GetSqlMode ¶
func (m *DAGRequest) GetSqlMode() uint64
func (*DAGRequest) GetStartTs ¶
func (m *DAGRequest) GetStartTs() uint64
func (*DAGRequest) GetTimeZoneName ¶
func (m *DAGRequest) GetTimeZoneName() string
func (*DAGRequest) GetTimeZoneOffset ¶
func (m *DAGRequest) GetTimeZoneOffset() int64
func (*DAGRequest) Marshal ¶
func (m *DAGRequest) Marshal() (dAtA []byte, err error)
func (*DAGRequest) ProtoMessage ¶
func (*DAGRequest) ProtoMessage()
func (*DAGRequest) Reset ¶
func (m *DAGRequest) Reset()
func (*DAGRequest) Size ¶
func (m *DAGRequest) Size() (n int)
func (*DAGRequest) String ¶
func (m *DAGRequest) String() string
func (*DAGRequest) Unmarshal ¶
func (m *DAGRequest) Unmarshal(dAtA []byte) error
type EncodeType ¶
type EncodeType int32
const ( EncodeType_TypeDefault EncodeType = 0 EncodeType_TypeArrow EncodeType = 1 )
func (EncodeType) Enum ¶
func (x EncodeType) Enum() *EncodeType
func (EncodeType) EnumDescriptor ¶
func (EncodeType) EnumDescriptor() ([]byte, []int)
func (EncodeType) String ¶
func (x EncodeType) String() string
func (*EncodeType) UnmarshalJSON ¶
func (x *EncodeType) UnmarshalJSON(data []byte) error
type Error ¶
type Error struct { Code int32 `protobuf:"varint,1,opt,name=code" json:"code"` Msg string `protobuf:"bytes,2,opt,name=msg" json:"msg"` XXX_unrecognized []byte `json:"-"` }
func (*Error) Descriptor ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
type ExecType ¶
type ExecType int32
func (ExecType) EnumDescriptor ¶
func (*ExecType) UnmarshalJSON ¶
type Executor ¶
type Executor struct { Tp ExecType `protobuf:"varint,1,opt,name=tp,enum=tipb.ExecType" json:"tp"` TblScan *TableScan `protobuf:"bytes,2,opt,name=tbl_scan,json=tblScan" json:"tbl_scan,omitempty"` IdxScan *IndexScan `protobuf:"bytes,3,opt,name=idx_scan,json=idxScan" json:"idx_scan,omitempty"` Selection *Selection `protobuf:"bytes,4,opt,name=selection" json:"selection,omitempty"` Aggregation *Aggregation `protobuf:"bytes,5,opt,name=aggregation" json:"aggregation,omitempty"` TopN *TopN `protobuf:"bytes,6,opt,name=topN" json:"topN,omitempty"` Limit *Limit `protobuf:"bytes,7,opt,name=limit" json:"limit,omitempty"` StreamAgg *Aggregation `protobuf:"bytes,8,opt,name=stream_agg,json=streamAgg" json:"stream_agg,omitempty"` XXX_unrecognized []byte `json:"-"` }
It represents a Executor.
func (*Executor) Descriptor ¶
func (*Executor) GetAggregation ¶
func (m *Executor) GetAggregation() *Aggregation
func (*Executor) GetIdxScan ¶
func (*Executor) GetSelection ¶
func (*Executor) GetStreamAgg ¶
func (m *Executor) GetStreamAgg() *Aggregation
func (*Executor) GetTblScan ¶
func (*Executor) ProtoMessage ¶
func (*Executor) ProtoMessage()
type Expr ¶
type Expr struct { Tp ExprType `protobuf:"varint,1,opt,name=tp,enum=tipb.ExprType" json:"tp"` Val []byte `protobuf:"bytes,2,opt,name=val" json:"val,omitempty"` Children []*Expr `protobuf:"bytes,3,rep,name=children" json:"children,omitempty"` Sig ScalarFuncSig `protobuf:"varint,4,opt,name=sig,enum=tipb.ScalarFuncSig" json:"sig"` FieldType *FieldType `protobuf:"bytes,5,opt,name=field_type,json=fieldType" json:"field_type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Evaluators should implement evaluation functions for every expression type.
func (*Expr) Descriptor ¶
func (*Expr) GetChildren ¶
func (*Expr) GetFieldType ¶
func (*Expr) GetSig ¶
func (m *Expr) GetSig() ScalarFuncSig
func (*Expr) ProtoMessage ¶
func (*Expr) ProtoMessage()
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 // Scalar Function ExprType_ScalarFunc ExprType = 10000 )
func (ExprType) EnumDescriptor ¶
func (*ExprType) UnmarshalJSON ¶
type FMSketch ¶
type FMSketch struct { Mask uint64 `protobuf:"varint,1,opt,name=mask" json:"mask"` Hashset []uint64 `protobuf:"varint,2,rep,name=hashset" json:"hashset,omitempty"` XXX_unrecognized []byte `json:"-"` }
FMSketch is used to count distinct values for columns.
func (*FMSketch) Descriptor ¶
func (*FMSketch) GetHashset ¶
func (*FMSketch) ProtoMessage ¶
func (*FMSketch) ProtoMessage()
type FieldType ¶
type FieldType struct { Tp int32 `protobuf:"varint,1,opt,name=tp" json:"tp"` Flag uint32 `protobuf:"varint,2,opt,name=flag" json:"flag"` Flen int32 `protobuf:"varint,3,opt,name=flen" json:"flen"` Decimal int32 `protobuf:"varint,4,opt,name=decimal" json:"decimal"` Collate int32 `protobuf:"varint,5,opt,name=collate" json:"collate"` Charset string `protobuf:"bytes,6,opt,name=charset" json:"charset"` XXX_unrecognized []byte `json:"-"` }
func (*FieldType) Descriptor ¶
func (*FieldType) GetCharset ¶
func (*FieldType) GetCollate ¶
func (*FieldType) GetDecimal ¶
func (*FieldType) ProtoMessage ¶
func (*FieldType) ProtoMessage()
type Histogram ¶
type Histogram struct { // ndv is the number of distinct values. Ndv int64 `protobuf:"varint,1,opt,name=ndv" json:"ndv"` // buckets represents all the buckets. Buckets []*Bucket `protobuf:"bytes,2,rep,name=buckets" json:"buckets,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Histogram) Descriptor ¶
func (*Histogram) GetBuckets ¶
func (*Histogram) ProtoMessage ¶
func (*Histogram) ProtoMessage()
type IndexInfo ¶
type IndexInfo struct { TableId int64 `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"` IndexId int64 `protobuf:"varint,2,opt,name=index_id,json=indexId" json:"index_id"` Columns []*ColumnInfo `protobuf:"bytes,3,rep,name=columns" json:"columns,omitempty"` Unique bool `protobuf:"varint,4,opt,name=unique" json:"unique"` XXX_unrecognized []byte `json:"-"` }
func (*IndexInfo) Descriptor ¶
func (*IndexInfo) GetColumns ¶
func (m *IndexInfo) GetColumns() []*ColumnInfo
func (*IndexInfo) GetIndexId ¶
func (*IndexInfo) GetTableId ¶
func (*IndexInfo) ProtoMessage ¶
func (*IndexInfo) ProtoMessage()
type IndexScan ¶
type IndexScan struct { TableId int64 `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"` IndexId int64 `protobuf:"varint,2,opt,name=index_id,json=indexId" json:"index_id"` Columns []*ColumnInfo `protobuf:"bytes,3,rep,name=columns" json:"columns,omitempty"` Desc bool `protobuf:"varint,4,opt,name=desc" json:"desc"` Unique *bool `protobuf:"varint,5,opt,name=unique" json:"unique,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*IndexScan) Descriptor ¶
func (*IndexScan) GetColumns ¶
func (m *IndexScan) GetColumns() []*ColumnInfo
func (*IndexScan) GetIndexId ¶
func (*IndexScan) GetTableId ¶
func (*IndexScan) ProtoMessage ¶
func (*IndexScan) ProtoMessage()
type KeyRange ¶
type KeyRange struct { Low []byte `protobuf:"bytes,1,opt,name=low" json:"low,omitempty"` High []byte `protobuf:"bytes,2,opt,name=high" json:"high,omitempty"` XXX_unrecognized []byte `json:"-"` }
KeyRange is the encoded index key range, low is closed, high is open. (low <= x < high)
func (*KeyRange) Descriptor ¶
func (*KeyRange) ProtoMessage ¶
func (*KeyRange) ProtoMessage()
type Limit ¶
type Limit struct { // Limit the result to be returned. Limit uint64 `protobuf:"varint,1,opt,name=limit" json:"limit"` XXX_unrecognized []byte `json:"-"` }
func (*Limit) Descriptor ¶
func (*Limit) ProtoMessage ¶
func (*Limit) ProtoMessage()
type Projection ¶
type Projection struct { // Projection expressions. Exprs []*Expr `protobuf:"bytes,1,rep,name=exprs" json:"exprs,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Projection) Descriptor ¶
func (*Projection) Descriptor() ([]byte, []int)
func (*Projection) GetExprs ¶
func (m *Projection) GetExprs() []*Expr
func (*Projection) Marshal ¶
func (m *Projection) Marshal() (dAtA []byte, err error)
func (*Projection) ProtoMessage ¶
func (*Projection) ProtoMessage()
func (*Projection) Reset ¶
func (m *Projection) Reset()
func (*Projection) Size ¶
func (m *Projection) Size() (n int)
func (*Projection) String ¶
func (m *Projection) String() string
func (*Projection) Unmarshal ¶
func (m *Projection) Unmarshal(dAtA []byte) error
type Row ¶
type Row struct { Handle []byte `protobuf:"bytes,1,opt,name=handle" json:"handle,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"` XXX_unrecognized []byte `json:"-"` }
values are all in text format.
func (*Row) Descriptor ¶
func (*Row) ProtoMessage ¶
func (*Row) ProtoMessage()
type RowMeta ¶
type RowMeta struct { Handle int64 `protobuf:"varint,1,opt,name=handle" json:"handle"` Length int64 `protobuf:"varint,2,opt,name=length" json:"length"` XXX_unrecognized []byte `json:"-"` }
RowMeta contains row handle and length of a row.
func (*RowMeta) Descriptor ¶
func (*RowMeta) ProtoMessage ¶
func (*RowMeta) ProtoMessage()
type SampleCollector ¶
type SampleCollector struct { Samples [][]byte `protobuf:"bytes,1,rep,name=samples" json:"samples,omitempty"` NullCount int64 `protobuf:"varint,2,opt,name=null_count,json=nullCount" json:"null_count"` Count int64 `protobuf:"varint,3,opt,name=count" json:"count"` FmSketch *FMSketch `protobuf:"bytes,4,opt,name=fm_sketch,json=fmSketch" json:"fm_sketch,omitempty"` CmSketch *CMSketch `protobuf:"bytes,5,opt,name=cm_sketch,json=cmSketch" json:"cm_sketch,omitempty"` TotalSize *int64 `protobuf:"varint,6,opt,name=total_size,json=totalSize" json:"total_size,omitempty"` XXX_unrecognized []byte `json:"-"` }
SampleCollector is used for collect samples and calculate the count and ndv of an column.
func (*SampleCollector) Descriptor ¶
func (*SampleCollector) Descriptor() ([]byte, []int)
func (*SampleCollector) GetCmSketch ¶
func (m *SampleCollector) GetCmSketch() *CMSketch
func (*SampleCollector) GetCount ¶
func (m *SampleCollector) GetCount() int64
func (*SampleCollector) GetFmSketch ¶
func (m *SampleCollector) GetFmSketch() *FMSketch
func (*SampleCollector) GetNullCount ¶
func (m *SampleCollector) GetNullCount() int64
func (*SampleCollector) GetSamples ¶
func (m *SampleCollector) GetSamples() [][]byte
func (*SampleCollector) GetTotalSize ¶
func (m *SampleCollector) GetTotalSize() int64
func (*SampleCollector) Marshal ¶
func (m *SampleCollector) Marshal() (dAtA []byte, err error)
func (*SampleCollector) ProtoMessage ¶
func (*SampleCollector) ProtoMessage()
func (*SampleCollector) Reset ¶
func (m *SampleCollector) Reset()
func (*SampleCollector) Size ¶
func (m *SampleCollector) Size() (n int)
func (*SampleCollector) String ¶
func (m *SampleCollector) String() string
func (*SampleCollector) Unmarshal ¶
func (m *SampleCollector) Unmarshal(dAtA []byte) error
type ScalarFuncSig ¶
type ScalarFuncSig int32
const ( // Casting ScalarFuncSig_CastIntAsInt ScalarFuncSig = 0 ScalarFuncSig_CastIntAsReal ScalarFuncSig = 1 ScalarFuncSig_CastIntAsString ScalarFuncSig = 2 ScalarFuncSig_CastIntAsDecimal ScalarFuncSig = 3 ScalarFuncSig_CastIntAsTime ScalarFuncSig = 4 ScalarFuncSig_CastIntAsDuration ScalarFuncSig = 5 ScalarFuncSig_CastIntAsJson ScalarFuncSig = 6 ScalarFuncSig_CastRealAsInt ScalarFuncSig = 10 ScalarFuncSig_CastRealAsReal ScalarFuncSig = 11 ScalarFuncSig_CastRealAsString ScalarFuncSig = 12 ScalarFuncSig_CastRealAsDecimal ScalarFuncSig = 13 ScalarFuncSig_CastRealAsTime ScalarFuncSig = 14 ScalarFuncSig_CastRealAsDuration ScalarFuncSig = 15 ScalarFuncSig_CastRealAsJson ScalarFuncSig = 16 ScalarFuncSig_CastDecimalAsInt ScalarFuncSig = 20 ScalarFuncSig_CastDecimalAsReal ScalarFuncSig = 21 ScalarFuncSig_CastDecimalAsString ScalarFuncSig = 22 ScalarFuncSig_CastDecimalAsDecimal ScalarFuncSig = 23 ScalarFuncSig_CastDecimalAsTime ScalarFuncSig = 24 ScalarFuncSig_CastDecimalAsDuration ScalarFuncSig = 25 ScalarFuncSig_CastDecimalAsJson ScalarFuncSig = 26 ScalarFuncSig_CastStringAsInt ScalarFuncSig = 30 ScalarFuncSig_CastStringAsReal ScalarFuncSig = 31 ScalarFuncSig_CastStringAsString ScalarFuncSig = 32 ScalarFuncSig_CastStringAsDecimal ScalarFuncSig = 33 ScalarFuncSig_CastStringAsTime ScalarFuncSig = 34 ScalarFuncSig_CastStringAsDuration ScalarFuncSig = 35 ScalarFuncSig_CastStringAsJson ScalarFuncSig = 36 ScalarFuncSig_CastTimeAsInt ScalarFuncSig = 40 ScalarFuncSig_CastTimeAsReal ScalarFuncSig = 41 ScalarFuncSig_CastTimeAsString ScalarFuncSig = 42 ScalarFuncSig_CastTimeAsDecimal ScalarFuncSig = 43 ScalarFuncSig_CastTimeAsTime ScalarFuncSig = 44 ScalarFuncSig_CastTimeAsDuration ScalarFuncSig = 45 ScalarFuncSig_CastTimeAsJson ScalarFuncSig = 46 ScalarFuncSig_CastDurationAsInt ScalarFuncSig = 50 ScalarFuncSig_CastDurationAsReal ScalarFuncSig = 51 ScalarFuncSig_CastDurationAsString ScalarFuncSig = 52 ScalarFuncSig_CastDurationAsDecimal ScalarFuncSig = 53 ScalarFuncSig_CastDurationAsTime ScalarFuncSig = 54 ScalarFuncSig_CastDurationAsDuration ScalarFuncSig = 55 ScalarFuncSig_CastDurationAsJson ScalarFuncSig = 56 ScalarFuncSig_CastJsonAsInt ScalarFuncSig = 60 ScalarFuncSig_CastJsonAsReal ScalarFuncSig = 61 ScalarFuncSig_CastJsonAsString ScalarFuncSig = 62 ScalarFuncSig_CastJsonAsDecimal ScalarFuncSig = 63 ScalarFuncSig_CastJsonAsTime ScalarFuncSig = 64 ScalarFuncSig_CastJsonAsDuration ScalarFuncSig = 65 ScalarFuncSig_CastJsonAsJson ScalarFuncSig = 66 // compare ScalarFuncSig_CoalesceInt ScalarFuncSig = 4201 ScalarFuncSig_CoalesceReal ScalarFuncSig = 4202 ScalarFuncSig_CoalesceDecimal ScalarFuncSig = 4203 ScalarFuncSig_CoalesceString ScalarFuncSig = 4204 ScalarFuncSig_CoalesceTime ScalarFuncSig = 4205 ScalarFuncSig_CoalesceDuration ScalarFuncSig = 4206 // unimplemented in tidb ScalarFuncSig_CoalesceJson ScalarFuncSig = 4207 ScalarFuncSig_LTInt ScalarFuncSig = 100 ScalarFuncSig_LTReal ScalarFuncSig = 101 ScalarFuncSig_LTDecimal ScalarFuncSig = 102 ScalarFuncSig_LTString ScalarFuncSig = 103 ScalarFuncSig_LTTime ScalarFuncSig = 104 ScalarFuncSig_LTDuration ScalarFuncSig = 105 ScalarFuncSig_LTJson ScalarFuncSig = 106 ScalarFuncSig_LEInt ScalarFuncSig = 110 ScalarFuncSig_LEReal ScalarFuncSig = 111 ScalarFuncSig_LEDecimal ScalarFuncSig = 112 ScalarFuncSig_LEString ScalarFuncSig = 113 ScalarFuncSig_LETime ScalarFuncSig = 114 ScalarFuncSig_LEDuration ScalarFuncSig = 115 ScalarFuncSig_LEJson ScalarFuncSig = 116 ScalarFuncSig_GTInt ScalarFuncSig = 120 ScalarFuncSig_GTReal ScalarFuncSig = 121 ScalarFuncSig_GTDecimal ScalarFuncSig = 122 ScalarFuncSig_GTString ScalarFuncSig = 123 ScalarFuncSig_GTTime ScalarFuncSig = 124 ScalarFuncSig_GTDuration ScalarFuncSig = 125 ScalarFuncSig_GTJson ScalarFuncSig = 126 ScalarFuncSig_GreatestInt ScalarFuncSig = 4215 ScalarFuncSig_GreatestReal ScalarFuncSig = 4216 ScalarFuncSig_GreatestDecimal ScalarFuncSig = 4217 ScalarFuncSig_GreatestString ScalarFuncSig = 4218 ScalarFuncSig_GreatestTime ScalarFuncSig = 4219 ScalarFuncSig_LeastInt ScalarFuncSig = 4220 ScalarFuncSig_LeastReal ScalarFuncSig = 4221 ScalarFuncSig_LeastDecimal ScalarFuncSig = 4222 ScalarFuncSig_LeastString ScalarFuncSig = 4223 ScalarFuncSig_LeastTime ScalarFuncSig = 4224 ScalarFuncSig_IntervalInt ScalarFuncSig = 4225 ScalarFuncSig_IntervalReal ScalarFuncSig = 4226 ScalarFuncSig_GEInt ScalarFuncSig = 130 ScalarFuncSig_GEReal ScalarFuncSig = 131 ScalarFuncSig_GEDecimal ScalarFuncSig = 132 ScalarFuncSig_GEString ScalarFuncSig = 133 ScalarFuncSig_GETime ScalarFuncSig = 134 ScalarFuncSig_GEDuration ScalarFuncSig = 135 ScalarFuncSig_GEJson ScalarFuncSig = 136 ScalarFuncSig_EQInt ScalarFuncSig = 140 ScalarFuncSig_EQReal ScalarFuncSig = 141 ScalarFuncSig_EQDecimal ScalarFuncSig = 142 ScalarFuncSig_EQString ScalarFuncSig = 143 ScalarFuncSig_EQTime ScalarFuncSig = 144 ScalarFuncSig_EQDuration ScalarFuncSig = 145 ScalarFuncSig_EQJson ScalarFuncSig = 146 ScalarFuncSig_NEInt ScalarFuncSig = 150 ScalarFuncSig_NEReal ScalarFuncSig = 151 ScalarFuncSig_NEDecimal ScalarFuncSig = 152 ScalarFuncSig_NEString ScalarFuncSig = 153 ScalarFuncSig_NETime ScalarFuncSig = 154 ScalarFuncSig_NEDuration ScalarFuncSig = 155 ScalarFuncSig_NEJson ScalarFuncSig = 156 ScalarFuncSig_NullEQInt ScalarFuncSig = 160 ScalarFuncSig_NullEQReal ScalarFuncSig = 161 ScalarFuncSig_NullEQDecimal ScalarFuncSig = 162 ScalarFuncSig_NullEQString ScalarFuncSig = 163 ScalarFuncSig_NullEQTime ScalarFuncSig = 164 ScalarFuncSig_NullEQDuration ScalarFuncSig = 165 ScalarFuncSig_NullEQJson ScalarFuncSig = 166 // arithmetic ScalarFuncSig_PlusReal ScalarFuncSig = 200 ScalarFuncSig_PlusDecimal ScalarFuncSig = 201 ScalarFuncSig_PlusInt ScalarFuncSig = 203 ScalarFuncSig_MinusReal ScalarFuncSig = 204 ScalarFuncSig_MinusDecimal ScalarFuncSig = 205 ScalarFuncSig_MinusInt ScalarFuncSig = 207 ScalarFuncSig_MultiplyReal ScalarFuncSig = 208 ScalarFuncSig_MultiplyDecimal ScalarFuncSig = 209 ScalarFuncSig_MultiplyInt ScalarFuncSig = 210 ScalarFuncSig_DivideReal ScalarFuncSig = 211 ScalarFuncSig_DivideDecimal ScalarFuncSig = 212 ScalarFuncSig_IntDivideInt ScalarFuncSig = 213 ScalarFuncSig_IntDivideDecimal ScalarFuncSig = 214 ScalarFuncSig_ModReal ScalarFuncSig = 215 ScalarFuncSig_ModDecimal ScalarFuncSig = 216 ScalarFuncSig_ModInt ScalarFuncSig = 217 ScalarFuncSig_MultiplyIntUnsigned ScalarFuncSig = 218 // math ScalarFuncSig_AbsInt ScalarFuncSig = 2101 ScalarFuncSig_AbsUInt ScalarFuncSig = 2102 ScalarFuncSig_AbsReal ScalarFuncSig = 2103 ScalarFuncSig_AbsDecimal ScalarFuncSig = 2104 ScalarFuncSig_CeilIntToDec ScalarFuncSig = 2105 ScalarFuncSig_CeilIntToInt ScalarFuncSig = 2106 ScalarFuncSig_CeilDecToInt ScalarFuncSig = 2107 ScalarFuncSig_CeilDecToDec ScalarFuncSig = 2108 ScalarFuncSig_CeilReal ScalarFuncSig = 2109 ScalarFuncSig_FloorIntToDec ScalarFuncSig = 2110 ScalarFuncSig_FloorIntToInt ScalarFuncSig = 2111 ScalarFuncSig_FloorDecToInt ScalarFuncSig = 2112 ScalarFuncSig_FloorDecToDec ScalarFuncSig = 2113 ScalarFuncSig_FloorReal ScalarFuncSig = 2114 ScalarFuncSig_RoundReal ScalarFuncSig = 2121 ScalarFuncSig_RoundInt ScalarFuncSig = 2122 ScalarFuncSig_RoundDec ScalarFuncSig = 2123 ScalarFuncSig_RoundWithFracReal ScalarFuncSig = 2124 ScalarFuncSig_RoundWithFracInt ScalarFuncSig = 2125 ScalarFuncSig_RoundWithFracDec ScalarFuncSig = 2126 ScalarFuncSig_Log1Arg ScalarFuncSig = 2131 ScalarFuncSig_Log2Args ScalarFuncSig = 2132 ScalarFuncSig_Log2 ScalarFuncSig = 2133 ScalarFuncSig_Log10 ScalarFuncSig = 2134 ScalarFuncSig_Rand ScalarFuncSig = 2135 ScalarFuncSig_RandWithSeed ScalarFuncSig = 2136 ScalarFuncSig_Pow ScalarFuncSig = 2137 ScalarFuncSig_Conv ScalarFuncSig = 2138 ScalarFuncSig_CRC32 ScalarFuncSig = 2139 ScalarFuncSig_Sign ScalarFuncSig = 2140 ScalarFuncSig_Sqrt ScalarFuncSig = 2141 ScalarFuncSig_Acos ScalarFuncSig = 2142 ScalarFuncSig_Asin ScalarFuncSig = 2143 ScalarFuncSig_Atan1Arg ScalarFuncSig = 2144 ScalarFuncSig_Atan2Args ScalarFuncSig = 2145 ScalarFuncSig_Cos ScalarFuncSig = 2146 ScalarFuncSig_Cot ScalarFuncSig = 2147 ScalarFuncSig_Degrees ScalarFuncSig = 2148 ScalarFuncSig_Exp ScalarFuncSig = 2149 ScalarFuncSig_PI ScalarFuncSig = 2150 ScalarFuncSig_Radians ScalarFuncSig = 2151 ScalarFuncSig_Sin ScalarFuncSig = 2152 ScalarFuncSig_Tan ScalarFuncSig = 2153 ScalarFuncSig_TruncateInt ScalarFuncSig = 2154 ScalarFuncSig_TruncateReal ScalarFuncSig = 2155 ScalarFuncSig_TruncateDecimal ScalarFuncSig = 2156 // op ScalarFuncSig_LogicalAnd ScalarFuncSig = 3101 ScalarFuncSig_LogicalOr ScalarFuncSig = 3102 ScalarFuncSig_LogicalXor ScalarFuncSig = 3103 ScalarFuncSig_UnaryNot ScalarFuncSig = 3104 ScalarFuncSig_UnaryMinusInt ScalarFuncSig = 3108 ScalarFuncSig_UnaryMinusReal ScalarFuncSig = 3109 ScalarFuncSig_UnaryMinusDecimal ScalarFuncSig = 3110 ScalarFuncSig_DecimalIsNull ScalarFuncSig = 3111 ScalarFuncSig_DurationIsNull ScalarFuncSig = 3112 ScalarFuncSig_RealIsNull ScalarFuncSig = 3113 ScalarFuncSig_StringIsNull ScalarFuncSig = 3114 ScalarFuncSig_TimeIsNull ScalarFuncSig = 3115 ScalarFuncSig_IntIsNull ScalarFuncSig = 3116 // unimplemented in tidb ScalarFuncSig_JsonIsNull ScalarFuncSig = 3117 ScalarFuncSig_BitAndSig ScalarFuncSig = 3118 ScalarFuncSig_BitOrSig ScalarFuncSig = 3119 ScalarFuncSig_BitXorSig ScalarFuncSig = 3120 ScalarFuncSig_BitNegSig ScalarFuncSig = 3121 ScalarFuncSig_IntIsTrue ScalarFuncSig = 3122 ScalarFuncSig_RealIsTrue ScalarFuncSig = 3123 ScalarFuncSig_DecimalIsTrue ScalarFuncSig = 3124 ScalarFuncSig_IntIsFalse ScalarFuncSig = 3125 ScalarFuncSig_RealIsFalse ScalarFuncSig = 3126 ScalarFuncSig_DecimalIsFalse ScalarFuncSig = 3127 ScalarFuncSig_LeftShift ScalarFuncSig = 3129 ScalarFuncSig_RightShift ScalarFuncSig = 3130 // other ScalarFuncSig_BitCount ScalarFuncSig = 3128 ScalarFuncSig_GetParamString ScalarFuncSig = 3131 ScalarFuncSig_GetVar ScalarFuncSig = 3132 ScalarFuncSig_RowSig ScalarFuncSig = 3133 ScalarFuncSig_SetVar ScalarFuncSig = 3134 ScalarFuncSig_ValuesDecimal ScalarFuncSig = 3135 ScalarFuncSig_ValuesDuration ScalarFuncSig = 3136 ScalarFuncSig_ValuesInt ScalarFuncSig = 3137 ScalarFuncSig_ValuesJSON ScalarFuncSig = 3138 ScalarFuncSig_ValuesReal ScalarFuncSig = 3139 ScalarFuncSig_ValuesString ScalarFuncSig = 3140 ScalarFuncSig_ValuesTime ScalarFuncSig = 3141 ScalarFuncSig_InInt ScalarFuncSig = 4001 ScalarFuncSig_InReal ScalarFuncSig = 4002 ScalarFuncSig_InDecimal ScalarFuncSig = 4003 ScalarFuncSig_InString ScalarFuncSig = 4004 ScalarFuncSig_InTime ScalarFuncSig = 4005 ScalarFuncSig_InDuration ScalarFuncSig = 4006 ScalarFuncSig_InJson ScalarFuncSig = 4007 // control ScalarFuncSig_IfNullInt ScalarFuncSig = 4101 ScalarFuncSig_IfNullReal ScalarFuncSig = 4102 ScalarFuncSig_IfNullDecimal ScalarFuncSig = 4103 ScalarFuncSig_IfNullString ScalarFuncSig = 4104 ScalarFuncSig_IfNullTime ScalarFuncSig = 4105 ScalarFuncSig_IfNullDuration ScalarFuncSig = 4106 ScalarFuncSig_IfInt ScalarFuncSig = 4107 ScalarFuncSig_IfReal ScalarFuncSig = 4108 ScalarFuncSig_IfDecimal ScalarFuncSig = 4109 ScalarFuncSig_IfString ScalarFuncSig = 4110 ScalarFuncSig_IfTime ScalarFuncSig = 4111 ScalarFuncSig_IfDuration ScalarFuncSig = 4112 ScalarFuncSig_IfNullJson ScalarFuncSig = 4113 ScalarFuncSig_IfJson ScalarFuncSig = 4114 ScalarFuncSig_CaseWhenInt ScalarFuncSig = 4208 ScalarFuncSig_CaseWhenReal ScalarFuncSig = 4209 ScalarFuncSig_CaseWhenDecimal ScalarFuncSig = 4210 ScalarFuncSig_CaseWhenString ScalarFuncSig = 4211 ScalarFuncSig_CaseWhenTime ScalarFuncSig = 4212 ScalarFuncSig_CaseWhenDuration ScalarFuncSig = 4213 // unimplemented in tidb ScalarFuncSig_CaseWhenJson ScalarFuncSig = 4214 // encryption ScalarFuncSig_AesDecrypt ScalarFuncSig = 4501 ScalarFuncSig_AesEncrypt ScalarFuncSig = 4502 ScalarFuncSig_Compress ScalarFuncSig = 4503 ScalarFuncSig_MD5 ScalarFuncSig = 4504 ScalarFuncSig_Password ScalarFuncSig = 4505 ScalarFuncSig_RandomBytes ScalarFuncSig = 4506 ScalarFuncSig_SHA1 ScalarFuncSig = 4507 ScalarFuncSig_SHA2 ScalarFuncSig = 4508 ScalarFuncSig_Uncompress ScalarFuncSig = 4509 ScalarFuncSig_UncompressedLength ScalarFuncSig = 4510 // info ScalarFuncSig_Database ScalarFuncSig = 4521 ScalarFuncSig_FoundRows ScalarFuncSig = 4522 ScalarFuncSig_CurrentUser ScalarFuncSig = 4523 ScalarFuncSig_User ScalarFuncSig = 4524 ScalarFuncSig_ConnectionID ScalarFuncSig = 4525 ScalarFuncSig_LastInsertID ScalarFuncSig = 4526 ScalarFuncSig_LastInsertIDWithID ScalarFuncSig = 4527 ScalarFuncSig_Version ScalarFuncSig = 4528 ScalarFuncSig_TiDBVersion ScalarFuncSig = 4529 ScalarFuncSig_RowCount ScalarFuncSig = 4530 // miscellaneous ScalarFuncSig_Sleep ScalarFuncSig = 4551 ScalarFuncSig_Lock ScalarFuncSig = 4552 ScalarFuncSig_ReleaseLock ScalarFuncSig = 4553 ScalarFuncSig_DecimalAnyValue ScalarFuncSig = 4554 ScalarFuncSig_DurationAnyValue ScalarFuncSig = 4555 ScalarFuncSig_IntAnyValue ScalarFuncSig = 4556 ScalarFuncSig_JSONAnyValue ScalarFuncSig = 4557 ScalarFuncSig_RealAnyValue ScalarFuncSig = 4558 ScalarFuncSig_StringAnyValue ScalarFuncSig = 4559 ScalarFuncSig_TimeAnyValue ScalarFuncSig = 4560 ScalarFuncSig_InetAton ScalarFuncSig = 4561 ScalarFuncSig_InetNtoa ScalarFuncSig = 4562 ScalarFuncSig_Inet6Aton ScalarFuncSig = 4563 ScalarFuncSig_Inet6Ntoa ScalarFuncSig = 4564 ScalarFuncSig_IsIPv4 ScalarFuncSig = 4565 ScalarFuncSig_IsIPv4Compat ScalarFuncSig = 4566 ScalarFuncSig_IsIPv4Mapped ScalarFuncSig = 4567 ScalarFuncSig_IsIPv6 ScalarFuncSig = 4568 ScalarFuncSig_UUID ScalarFuncSig = 4569 // like ScalarFuncSig_LikeSig ScalarFuncSig = 4310 ScalarFuncSig_RegexpBinarySig ScalarFuncSig = 4311 ScalarFuncSig_RegexpSig ScalarFuncSig = 4312 // json ScalarFuncSig_JsonExtractSig ScalarFuncSig = 5001 ScalarFuncSig_JsonUnquoteSig ScalarFuncSig = 5002 ScalarFuncSig_JsonTypeSig ScalarFuncSig = 5003 ScalarFuncSig_JsonSetSig ScalarFuncSig = 5004 ScalarFuncSig_JsonInsertSig ScalarFuncSig = 5005 ScalarFuncSig_JsonReplaceSig ScalarFuncSig = 5006 ScalarFuncSig_JsonRemoveSig ScalarFuncSig = 5007 ScalarFuncSig_JsonMergeSig ScalarFuncSig = 5008 ScalarFuncSig_JsonObjectSig ScalarFuncSig = 5009 ScalarFuncSig_JsonArraySig ScalarFuncSig = 5010 ScalarFuncSig_JsonValidJsonSig ScalarFuncSig = 5011 ScalarFuncSig_JsonContainsSig ScalarFuncSig = 5012 ScalarFuncSig_JsonArrayAppendSig ScalarFuncSig = 5013 ScalarFuncSig_JsonArrayInsertSig ScalarFuncSig = 5014 ScalarFuncSig_JsonMergePatchSig ScalarFuncSig = 5015 ScalarFuncSig_JsonMergePreserveSig ScalarFuncSig = 5016 ScalarFuncSig_JsonContainsPathSig ScalarFuncSig = 5017 ScalarFuncSig_JsonPrettySig ScalarFuncSig = 5018 ScalarFuncSig_JsonQuoteSig ScalarFuncSig = 5019 ScalarFuncSig_JsonSearchSig ScalarFuncSig = 5020 ScalarFuncSig_JsonStorageSizeSig ScalarFuncSig = 5021 ScalarFuncSig_JsonDepthSig ScalarFuncSig = 5022 ScalarFuncSig_JsonKeysSig ScalarFuncSig = 5023 ScalarFuncSig_JsonLengthSig ScalarFuncSig = 5024 ScalarFuncSig_JsonValidStringSig ScalarFuncSig = 5026 ScalarFuncSig_JsonValidOthersSig ScalarFuncSig = 5027 // time ScalarFuncSig_DateFormatSig ScalarFuncSig = 6001 ScalarFuncSig_DateLiteral ScalarFuncSig = 6002 ScalarFuncSig_DateDiff ScalarFuncSig = 6003 ScalarFuncSig_NullTimeDiff ScalarFuncSig = 6004 ScalarFuncSig_TimeStringTimeDiff ScalarFuncSig = 6005 ScalarFuncSig_DurationStringTimeDiff ScalarFuncSig = 6006 ScalarFuncSig_DurationDurationTimeDiff ScalarFuncSig = 6007 ScalarFuncSig_StringTimeTimeDiff ScalarFuncSig = 6008 ScalarFuncSig_StringDurationTimeDiff ScalarFuncSig = 6009 ScalarFuncSig_StringStringTimeDiff ScalarFuncSig = 6010 ScalarFuncSig_TimeTimeTimeDiff ScalarFuncSig = 6011 ScalarFuncSig_Date ScalarFuncSig = 6012 ScalarFuncSig_Hour ScalarFuncSig = 6013 ScalarFuncSig_Minute ScalarFuncSig = 6014 ScalarFuncSig_Second ScalarFuncSig = 6015 ScalarFuncSig_MicroSecond ScalarFuncSig = 6016 ScalarFuncSig_Month ScalarFuncSig = 6017 ScalarFuncSig_MonthName ScalarFuncSig = 6018 ScalarFuncSig_NowWithArg ScalarFuncSig = 6019 ScalarFuncSig_NowWithoutArg ScalarFuncSig = 6020 ScalarFuncSig_DayName ScalarFuncSig = 6021 ScalarFuncSig_DayOfMonth ScalarFuncSig = 6022 ScalarFuncSig_DayOfWeek ScalarFuncSig = 6023 ScalarFuncSig_DayOfYear ScalarFuncSig = 6024 ScalarFuncSig_WeekWithMode ScalarFuncSig = 6025 ScalarFuncSig_WeekWithoutMode ScalarFuncSig = 6026 ScalarFuncSig_WeekDay ScalarFuncSig = 6027 ScalarFuncSig_WeekOfYear ScalarFuncSig = 6028 ScalarFuncSig_Year ScalarFuncSig = 6029 ScalarFuncSig_YearWeekWithMode ScalarFuncSig = 6030 ScalarFuncSig_YearWeekWithoutMode ScalarFuncSig = 6031 ScalarFuncSig_GetFormat ScalarFuncSig = 6032 ScalarFuncSig_SysDateWithFsp ScalarFuncSig = 6033 ScalarFuncSig_SysDateWithoutFsp ScalarFuncSig = 6034 ScalarFuncSig_CurrentDate ScalarFuncSig = 6035 ScalarFuncSig_CurrentTime0Arg ScalarFuncSig = 6036 ScalarFuncSig_CurrentTime1Arg ScalarFuncSig = 6037 ScalarFuncSig_Time ScalarFuncSig = 6038 ScalarFuncSig_TimeLiteral ScalarFuncSig = 6039 ScalarFuncSig_UTCDate ScalarFuncSig = 6040 ScalarFuncSig_UTCTimestampWithArg ScalarFuncSig = 6041 ScalarFuncSig_UTCTimestampWithoutArg ScalarFuncSig = 6042 ScalarFuncSig_AddDatetimeAndDuration ScalarFuncSig = 6043 ScalarFuncSig_AddDatetimeAndString ScalarFuncSig = 6044 ScalarFuncSig_AddTimeDateTimeNull ScalarFuncSig = 6045 ScalarFuncSig_AddStringAndDuration ScalarFuncSig = 6046 ScalarFuncSig_AddStringAndString ScalarFuncSig = 6047 ScalarFuncSig_AddTimeStringNull ScalarFuncSig = 6048 ScalarFuncSig_AddDurationAndDuration ScalarFuncSig = 6049 ScalarFuncSig_AddDurationAndString ScalarFuncSig = 6050 ScalarFuncSig_AddTimeDurationNull ScalarFuncSig = 6051 ScalarFuncSig_AddDateAndDuration ScalarFuncSig = 6052 ScalarFuncSig_AddDateAndString ScalarFuncSig = 6053 ScalarFuncSig_SubDatetimeAndDuration ScalarFuncSig = 6054 ScalarFuncSig_SubDatetimeAndString ScalarFuncSig = 6055 ScalarFuncSig_SubTimeDateTimeNull ScalarFuncSig = 6056 ScalarFuncSig_SubStringAndDuration ScalarFuncSig = 6057 ScalarFuncSig_SubStringAndString ScalarFuncSig = 6058 ScalarFuncSig_SubTimeStringNull ScalarFuncSig = 6059 ScalarFuncSig_SubDurationAndDuration ScalarFuncSig = 6060 ScalarFuncSig_SubDurationAndString ScalarFuncSig = 6061 ScalarFuncSig_SubTimeDurationNull ScalarFuncSig = 6062 ScalarFuncSig_SubDateAndDuration ScalarFuncSig = 6063 ScalarFuncSig_SubDateAndString ScalarFuncSig = 6064 ScalarFuncSig_UnixTimestampCurrent ScalarFuncSig = 6065 ScalarFuncSig_UnixTimestampInt ScalarFuncSig = 6066 ScalarFuncSig_UnixTimestampDec ScalarFuncSig = 6067 ScalarFuncSig_ConvertTz ScalarFuncSig = 6068 ScalarFuncSig_MakeDate ScalarFuncSig = 6069 ScalarFuncSig_MakeTime ScalarFuncSig = 6070 ScalarFuncSig_PeriodAdd ScalarFuncSig = 6071 ScalarFuncSig_PeriodDiff ScalarFuncSig = 6072 ScalarFuncSig_Quarter ScalarFuncSig = 6073 ScalarFuncSig_SecToTime ScalarFuncSig = 6074 ScalarFuncSig_TimeToSec ScalarFuncSig = 6075 ScalarFuncSig_TimestampAdd ScalarFuncSig = 6076 ScalarFuncSig_ToDays ScalarFuncSig = 6077 ScalarFuncSig_ToSeconds ScalarFuncSig = 6078 ScalarFuncSig_UTCTimeWithArg ScalarFuncSig = 6079 ScalarFuncSig_UTCTimeWithoutArg ScalarFuncSig = 6080 ScalarFuncSig_Timestamp1Arg ScalarFuncSig = 6081 ScalarFuncSig_Timestamp2Args ScalarFuncSig = 6082 ScalarFuncSig_TimestampLiteral ScalarFuncSig = 6083 ScalarFuncSig_LastDay ScalarFuncSig = 6084 ScalarFuncSig_StrToDateDate ScalarFuncSig = 6085 ScalarFuncSig_StrToDateDatetime ScalarFuncSig = 6086 ScalarFuncSig_StrToDateDuration ScalarFuncSig = 6087 ScalarFuncSig_FromUnixTime1Arg ScalarFuncSig = 6088 ScalarFuncSig_FromUnixTime2Arg ScalarFuncSig = 6089 ScalarFuncSig_ExtractDatetime ScalarFuncSig = 6090 ScalarFuncSig_ExtractDuration ScalarFuncSig = 6091 ScalarFuncSig_AddDateStringString ScalarFuncSig = 6092 ScalarFuncSig_AddDateStringInt ScalarFuncSig = 6093 ScalarFuncSig_AddDateStringDecimal ScalarFuncSig = 6094 ScalarFuncSig_AddDateIntString ScalarFuncSig = 6095 ScalarFuncSig_AddDateIntInt ScalarFuncSig = 6096 ScalarFuncSig_AddDateDatetimeString ScalarFuncSig = 6097 ScalarFuncSig_AddDateDatetimeInt ScalarFuncSig = 6098 ScalarFuncSig_SubDateStringString ScalarFuncSig = 6099 ScalarFuncSig_SubDateStringInt ScalarFuncSig = 6100 ScalarFuncSig_SubDateStringDecimal ScalarFuncSig = 6101 ScalarFuncSig_SubDateIntString ScalarFuncSig = 6102 ScalarFuncSig_SubDateIntInt ScalarFuncSig = 6103 ScalarFuncSig_SubDateDatetimeString ScalarFuncSig = 6104 ScalarFuncSig_SubDateDatetimeInt ScalarFuncSig = 6105 ScalarFuncSig_FromDays ScalarFuncSig = 6106 ScalarFuncSig_TimeFormat ScalarFuncSig = 6107 ScalarFuncSig_TimestampDiff ScalarFuncSig = 6108 // String functions ScalarFuncSig_BitLength ScalarFuncSig = 7001 ScalarFuncSig_Bin ScalarFuncSig = 7002 ScalarFuncSig_ASCII ScalarFuncSig = 7003 ScalarFuncSig_Char ScalarFuncSig = 7004 ScalarFuncSig_CharLength ScalarFuncSig = 7005 ScalarFuncSig_Concat ScalarFuncSig = 7006 ScalarFuncSig_ConcatWS ScalarFuncSig = 7007 ScalarFuncSig_Convert ScalarFuncSig = 7008 ScalarFuncSig_Elt ScalarFuncSig = 7009 ScalarFuncSig_ExportSet3Arg ScalarFuncSig = 7010 ScalarFuncSig_ExportSet4Arg ScalarFuncSig = 7011 ScalarFuncSig_ExportSet5Arg ScalarFuncSig = 7012 ScalarFuncSig_FieldInt ScalarFuncSig = 7013 ScalarFuncSig_FieldReal ScalarFuncSig = 7014 ScalarFuncSig_FieldString ScalarFuncSig = 7015 ScalarFuncSig_FindInSet ScalarFuncSig = 7016 ScalarFuncSig_Format ScalarFuncSig = 7017 ScalarFuncSig_FormatWithLocale ScalarFuncSig = 7018 ScalarFuncSig_FromBase64 ScalarFuncSig = 7019 ScalarFuncSig_HexIntArg ScalarFuncSig = 7020 ScalarFuncSig_HexStrArg ScalarFuncSig = 7021 ScalarFuncSig_Insert ScalarFuncSig = 7022 ScalarFuncSig_InsertBinary ScalarFuncSig = 7023 ScalarFuncSig_Instr ScalarFuncSig = 7024 ScalarFuncSig_InstrBinary ScalarFuncSig = 7025 ScalarFuncSig_LTrim ScalarFuncSig = 7026 ScalarFuncSig_Left ScalarFuncSig = 7027 ScalarFuncSig_LeftBinary ScalarFuncSig = 7028 ScalarFuncSig_Length ScalarFuncSig = 7029 ScalarFuncSig_Locate2Args ScalarFuncSig = 7030 ScalarFuncSig_Locate3Args ScalarFuncSig = 7031 ScalarFuncSig_LocateBinary2Args ScalarFuncSig = 7032 ScalarFuncSig_LocateBinary3Args ScalarFuncSig = 7033 ScalarFuncSig_Lower ScalarFuncSig = 7034 ScalarFuncSig_Lpad ScalarFuncSig = 7035 ScalarFuncSig_LpadBinary ScalarFuncSig = 7036 ScalarFuncSig_MakeSet ScalarFuncSig = 7037 ScalarFuncSig_OctInt ScalarFuncSig = 7038 ScalarFuncSig_OctString ScalarFuncSig = 7039 ScalarFuncSig_Ord ScalarFuncSig = 7040 ScalarFuncSig_Quote ScalarFuncSig = 7041 ScalarFuncSig_RTrim ScalarFuncSig = 7042 ScalarFuncSig_Repeat ScalarFuncSig = 7043 ScalarFuncSig_Replace ScalarFuncSig = 7044 ScalarFuncSig_Reverse ScalarFuncSig = 7045 ScalarFuncSig_ReverseBinary ScalarFuncSig = 7046 ScalarFuncSig_Right ScalarFuncSig = 7047 ScalarFuncSig_RightBinary ScalarFuncSig = 7048 ScalarFuncSig_Rpad ScalarFuncSig = 7049 ScalarFuncSig_RpadBinary ScalarFuncSig = 7050 ScalarFuncSig_Space ScalarFuncSig = 7051 ScalarFuncSig_Strcmp ScalarFuncSig = 7052 ScalarFuncSig_Substring2Args ScalarFuncSig = 7053 ScalarFuncSig_Substring3Args ScalarFuncSig = 7054 ScalarFuncSig_SubstringBinary2Args ScalarFuncSig = 7055 ScalarFuncSig_SubstringBinary3Args ScalarFuncSig = 7056 ScalarFuncSig_SubstringIndex ScalarFuncSig = 7057 ScalarFuncSig_ToBase64 ScalarFuncSig = 7058 ScalarFuncSig_Trim1Arg ScalarFuncSig = 7059 ScalarFuncSig_Trim2Args ScalarFuncSig = 7060 ScalarFuncSig_Trim3Args ScalarFuncSig = 7061 ScalarFuncSig_UnHex ScalarFuncSig = 7062 ScalarFuncSig_Upper ScalarFuncSig = 7063 )
func (ScalarFuncSig) Enum ¶
func (x ScalarFuncSig) Enum() *ScalarFuncSig
func (ScalarFuncSig) EnumDescriptor ¶
func (ScalarFuncSig) EnumDescriptor() ([]byte, []int)
func (ScalarFuncSig) String ¶
func (x ScalarFuncSig) String() string
func (*ScalarFuncSig) UnmarshalJSON ¶
func (x *ScalarFuncSig) UnmarshalJSON(data []byte) error
type SelectResponse ¶
type SelectResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` // Result rows. Rows []*Row `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"` // Use multiple chunks to reduce memory allocation and // avoid allocating large contiguous memory. Chunks []Chunk `protobuf:"bytes,3,rep,name=chunks" json:"chunks"` Warnings []*Error `protobuf:"bytes,4,rep,name=warnings" json:"warnings,omitempty"` OutputCounts []int64 `protobuf:"varint,5,rep,name=output_counts,json=outputCounts" json:"output_counts,omitempty"` WarningCount *int64 `protobuf:"varint,6,opt,name=warning_count,json=warningCount" json:"warning_count,omitempty"` RowBatchData github_com_pingcap_tipb_sharedbytes.SharedBytes `` /* 141-byte string literal not displayed */ XXX_unrecognized []byte `json:"-"` }
Response for SelectRequest.
func (*SelectResponse) Descriptor ¶
func (*SelectResponse) Descriptor() ([]byte, []int)
func (*SelectResponse) GetChunks ¶
func (m *SelectResponse) GetChunks() []Chunk
func (*SelectResponse) GetError ¶
func (m *SelectResponse) GetError() *Error
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) ProtoMessage ¶
func (*SelectResponse) ProtoMessage()
func (*SelectResponse) Reset ¶
func (m *SelectResponse) Reset()
func (*SelectResponse) Size ¶
func (m *SelectResponse) Size() (n int)
func (*SelectResponse) String ¶
func (m *SelectResponse) String() string
func (*SelectResponse) Unmarshal ¶
func (m *SelectResponse) Unmarshal(dAtA []byte) error
type Selection ¶
type Selection struct { // Where conditions. Conditions []*Expr `protobuf:"bytes,1,rep,name=conditions" json:"conditions,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Selection) Descriptor ¶
func (*Selection) GetConditions ¶
func (*Selection) ProtoMessage ¶
func (*Selection) ProtoMessage()
type StreamResponse ¶
type StreamResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` // Data for all rows Data github_com_pingcap_tipb_sharedbytes.SharedBytes `protobuf:"bytes,3,opt,name=data,customtype=github.com/pingcap/tipb/sharedbytes.SharedBytes" json:"data"` Warnings []*Error `protobuf:"bytes,4,rep,name=warnings" json:"warnings,omitempty"` // output row count for each executor OutputCounts []int64 `protobuf:"varint,5,rep,name=output_counts,json=outputCounts" json:"output_counts,omitempty"` WarningCount *int64 `protobuf:"varint,6,opt,name=warning_count,json=warningCount" json:"warning_count,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StreamResponse) Descriptor ¶
func (*StreamResponse) Descriptor() ([]byte, []int)
func (*StreamResponse) GetError ¶
func (m *StreamResponse) GetError() *Error
func (*StreamResponse) GetOutputCounts ¶
func (m *StreamResponse) GetOutputCounts() []int64
func (*StreamResponse) GetWarningCount ¶
func (m *StreamResponse) GetWarningCount() int64
func (*StreamResponse) GetWarnings ¶
func (m *StreamResponse) GetWarnings() []*Error
func (*StreamResponse) Marshal ¶
func (m *StreamResponse) Marshal() (dAtA []byte, err error)
func (*StreamResponse) ProtoMessage ¶
func (*StreamResponse) ProtoMessage()
func (*StreamResponse) Reset ¶
func (m *StreamResponse) Reset()
func (*StreamResponse) Size ¶
func (m *StreamResponse) Size() (n int)
func (*StreamResponse) String ¶
func (m *StreamResponse) String() string
func (*StreamResponse) Unmarshal ¶
func (m *StreamResponse) Unmarshal(dAtA []byte) error
type TableInfo ¶
type TableInfo struct { TableId int64 `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"` Columns []*ColumnInfo `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*TableInfo) Descriptor ¶
func (*TableInfo) GetColumns ¶
func (m *TableInfo) GetColumns() []*ColumnInfo
func (*TableInfo) GetTableId ¶
func (*TableInfo) ProtoMessage ¶
func (*TableInfo) ProtoMessage()
type TableScan ¶
type TableScan struct { TableId int64 `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"` Columns []*ColumnInfo `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"` Desc bool `protobuf:"varint,3,opt,name=desc" json:"desc"` XXX_unrecognized []byte `json:"-"` }
func (*TableScan) Descriptor ¶
func (*TableScan) GetColumns ¶
func (m *TableScan) GetColumns() []*ColumnInfo
func (*TableScan) GetTableId ¶
func (*TableScan) ProtoMessage ¶
func (*TableScan) ProtoMessage()
type TopN ¶
type TopN struct { // Order by clause. OrderBy []*ByItem `protobuf:"bytes,1,rep,name=order_by,json=orderBy" json:"order_by,omitempty"` Limit uint64 `protobuf:"varint,2,opt,name=limit" json:"limit"` XXX_unrecognized []byte `json:"-"` }
func (*TopN) Descriptor ¶
func (*TopN) GetOrderBy ¶
func (*TopN) ProtoMessage ¶
func (*TopN) ProtoMessage()