Documentation
¶
Index ¶
- Variables
- type ColData
- func (*ColData) Descriptor() ([]byte, []int)deprecated
- func (x *ColData) GetF32() []float32
- func (x *ColData) GetF64() []float64
- func (x *ColData) GetI32() []int32
- func (x *ColData) GetI64() []int64
- func (x *ColData) GetNullCount() int32
- func (x *ColData) GetNulls() []bool
- func (x *ColData) GetRowCount() int32
- func (x *ColData) GetS() []string
- func (*ColData) ProtoMessage()
- func (x *ColData) ProtoReflect() protoreflect.Message
- func (x *ColData) Reset()
- func (x *ColData) String() string
- type ColDef
- type ColRef
- type Const
- func (*Const) Descriptor() ([]byte, []int)deprecated
- func (x *Const) GetDval() float64
- func (x *Const) GetIsnull() bool
- func (x *Const) GetIval() int64
- func (x *Const) GetSval() string
- func (m *Const) GetValue() isConst_Value
- func (*Const) ProtoMessage()
- func (x *Const) ProtoReflect() protoreflect.Message
- func (x *Const) Reset()
- func (x *Const) String() string
- type Const_Dval
- type Const_Ival
- type Const_Sval
- type CorrColRef
- func (*CorrColRef) Descriptor() ([]byte, []int)deprecated
- func (x *CorrColRef) GetColPos() int32
- func (x *CorrColRef) GetName() string
- func (x *CorrColRef) GetNodeId() int32
- func (x *CorrColRef) GetRelPos() int32
- func (*CorrColRef) ProtoMessage()
- func (x *CorrColRef) ProtoReflect() protoreflect.Message
- func (x *CorrColRef) Reset()
- func (x *CorrColRef) String() string
- type Cost
- func (*Cost) Descriptor() ([]byte, []int)deprecated
- func (x *Cost) GetCard() float64
- func (x *Cost) GetNdv() float64
- func (x *Cost) GetRowsize() float64
- func (x *Cost) GetStart() float64
- func (x *Cost) GetTotal() float64
- func (*Cost) ProtoMessage()
- func (x *Cost) ProtoReflect() protoreflect.Message
- func (x *Cost) Reset()
- func (x *Cost) String() string
- type Expr
- func (*Expr) Descriptor() ([]byte, []int)deprecated
- func (x *Expr) GetAlias() string
- func (x *Expr) GetC() *Const
- func (x *Expr) GetCol() *ColRef
- func (x *Expr) GetCorr() *CorrColRef
- func (m *Expr) GetExpr() isExpr_Expr
- func (x *Expr) GetF() *Function
- func (x *Expr) GetList() *ExprList
- func (x *Expr) GetP() *ParamRef
- func (x *Expr) GetSub() *SubQuery
- func (x *Expr) GetTyp() *Type
- func (x *Expr) GetV() *VarRef
- func (*Expr) ProtoMessage()
- func (x *Expr) ProtoReflect() protoreflect.Message
- func (x *Expr) Reset()
- func (x *Expr) String() string
- type ExprList
- type Expr_C
- type Expr_Col
- type Expr_Corr
- type Expr_F
- type Expr_List
- type Expr_P
- type Expr_Sub
- type Expr_V
- type Function
- type Function_FuncFlag
- func (Function_FuncFlag) Descriptor() protoreflect.EnumDescriptor
- func (x Function_FuncFlag) Enum() *Function_FuncFlag
- func (Function_FuncFlag) EnumDescriptor() ([]byte, []int)deprecated
- func (x Function_FuncFlag) Number() protoreflect.EnumNumber
- func (x Function_FuncFlag) String() string
- func (Function_FuncFlag) Type() protoreflect.EnumType
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetChildren() []int32
- func (x *Node) GetCost() *Cost
- func (x *Node) GetExtraOptions() string
- func (x *Node) GetGroupBy() []*Expr
- func (x *Node) GetGroupingSet() []*Expr
- func (x *Node) GetJoinType() Node_JoinFlag
- func (x *Node) GetLimit() *Expr
- func (x *Node) GetNodeId() int32
- func (x *Node) GetNodeType() Node_NodeType
- func (x *Node) GetObjRef() *ObjectRef
- func (x *Node) GetOffset() *Expr
- func (x *Node) GetOnList() []*Expr
- func (x *Node) GetOrderBy() []*OrderBySpec
- func (x *Node) GetProjectList() []*Expr
- func (x *Node) GetRowsetData() *RowsetData
- func (x *Node) GetTableDef() *TableDef
- func (x *Node) GetUpdateList() *UpdateList
- func (x *Node) GetWhereList() []*Expr
- func (x *Node) GetWinSpec() *WindowSpec
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type Node_AggMode
- func (Node_AggMode) Descriptor() protoreflect.EnumDescriptor
- func (x Node_AggMode) Enum() *Node_AggMode
- func (Node_AggMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x Node_AggMode) Number() protoreflect.EnumNumber
- func (x Node_AggMode) String() string
- func (Node_AggMode) Type() protoreflect.EnumType
- type Node_JoinFlag
- func (Node_JoinFlag) Descriptor() protoreflect.EnumDescriptor
- func (x Node_JoinFlag) Enum() *Node_JoinFlag
- func (Node_JoinFlag) EnumDescriptor() ([]byte, []int)deprecated
- func (x Node_JoinFlag) Number() protoreflect.EnumNumber
- func (x Node_JoinFlag) String() string
- func (Node_JoinFlag) Type() protoreflect.EnumType
- type Node_NodeType
- func (Node_NodeType) Descriptor() protoreflect.EnumDescriptor
- func (x Node_NodeType) Enum() *Node_NodeType
- func (Node_NodeType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Node_NodeType) Number() protoreflect.EnumNumber
- func (x Node_NodeType) String() string
- func (Node_NodeType) Type() protoreflect.EnumType
- type ObjectRef
- func (*ObjectRef) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectRef) GetDb() int64
- func (x *ObjectRef) GetDbName() string
- func (x *ObjectRef) GetObj() int64
- func (x *ObjectRef) GetObjName() string
- func (x *ObjectRef) GetSchema() int64
- func (x *ObjectRef) GetSchemaName() string
- func (x *ObjectRef) GetServer() int64
- func (x *ObjectRef) GetServerName() string
- func (*ObjectRef) ProtoMessage()
- func (x *ObjectRef) ProtoReflect() protoreflect.Message
- func (x *ObjectRef) Reset()
- func (x *ObjectRef) String() string
- type OrderBySpec
- func (*OrderBySpec) Descriptor() ([]byte, []int)deprecated
- func (x *OrderBySpec) GetOrderBy() *Expr
- func (x *OrderBySpec) GetOrderByCollations() string
- func (x *OrderBySpec) GetOrderByFlags() OrderBySpec_OrderByFlag
- func (*OrderBySpec) ProtoMessage()
- func (x *OrderBySpec) ProtoReflect() protoreflect.Message
- func (x *OrderBySpec) Reset()
- func (x *OrderBySpec) String() string
- type OrderBySpec_OrderByFlag
- func (OrderBySpec_OrderByFlag) Descriptor() protoreflect.EnumDescriptor
- func (x OrderBySpec_OrderByFlag) Enum() *OrderBySpec_OrderByFlag
- func (OrderBySpec_OrderByFlag) EnumDescriptor() ([]byte, []int)deprecated
- func (x OrderBySpec_OrderByFlag) Number() protoreflect.EnumNumber
- func (x OrderBySpec_OrderByFlag) String() string
- func (OrderBySpec_OrderByFlag) Type() protoreflect.EnumType
- type ParamRef
- type Query
- func (*Query) Descriptor() ([]byte, []int)deprecated
- func (x *Query) GetNodes() []*Node
- func (x *Query) GetParams() []*Expr
- func (x *Query) GetSteps() []int32
- func (x *Query) GetStmtType() Query_StatementType
- func (*Query) ProtoMessage()
- func (x *Query) ProtoReflect() protoreflect.Message
- func (x *Query) Reset()
- func (x *Query) String() string
- type Query_StatementType
- func (Query_StatementType) Descriptor() protoreflect.EnumDescriptor
- func (x Query_StatementType) Enum() *Query_StatementType
- func (Query_StatementType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Query_StatementType) Number() protoreflect.EnumNumber
- func (x Query_StatementType) String() string
- func (Query_StatementType) Type() protoreflect.EnumType
- type RowsetData
- type StatementType
- func (StatementType) Descriptor() protoreflect.EnumDescriptor
- func (x StatementType) Enum() *StatementType
- func (StatementType) EnumDescriptor() ([]byte, []int)deprecated
- func (x StatementType) Number() protoreflect.EnumNumber
- func (x StatementType) String() string
- func (StatementType) Type() protoreflect.EnumType
- type SubQuery
- func (*SubQuery) Descriptor() ([]byte, []int)deprecated
- func (x *SubQuery) GetIsCorrelated() bool
- func (x *SubQuery) GetIsScalar() bool
- func (x *SubQuery) GetNodeId() int32
- func (*SubQuery) ProtoMessage()
- func (x *SubQuery) ProtoReflect() protoreflect.Message
- func (x *SubQuery) Reset()
- func (x *SubQuery) String() string
- type TableDef
- type Type
- func (*Type) Descriptor() ([]byte, []int)deprecated
- func (x *Type) GetId() Type_TypeId
- func (x *Type) GetNullable() bool
- func (x *Type) GetPrecision() int32
- func (x *Type) GetWidth() int32
- func (*Type) ProtoMessage()
- func (x *Type) ProtoReflect() protoreflect.Message
- func (x *Type) Reset()
- func (x *Type) String() string
- type Type_TypeId
- func (Type_TypeId) Descriptor() protoreflect.EnumDescriptor
- func (x Type_TypeId) Enum() *Type_TypeId
- func (Type_TypeId) EnumDescriptor() ([]byte, []int)deprecated
- func (x Type_TypeId) Number() protoreflect.EnumNumber
- func (x Type_TypeId) String() string
- func (Type_TypeId) Type() protoreflect.EnumType
- type UpdateList
- type VarRef
- type WindowSpec
- func (*WindowSpec) Descriptor() ([]byte, []int)deprecated
- func (x *WindowSpec) GetLag() int32
- func (x *WindowSpec) GetLead() int32
- func (x *WindowSpec) GetOderyBy() []*OrderBySpec
- func (x *WindowSpec) GetPartitionBy() []*Expr
- func (*WindowSpec) ProtoMessage()
- func (x *WindowSpec) ProtoReflect() protoreflect.Message
- func (x *WindowSpec) Reset()
- func (x *WindowSpec) String() string
Constants ¶
This section is empty.
Variables ¶
var ( StatementType_name = map[int32]string{ 0: "UNKNOW", 1: "SELECT", 2: "INSERT", 3: "DELETE", 4: "UPDATE", 5: "MERGE", } StatementType_value = map[string]int32{ "UNKNOW": 0, "SELECT": 1, "INSERT": 2, "DELETE": 3, "UPDATE": 4, "MERGE": 5, } )
Enum value maps for StatementType.
var ( Type_TypeId_name = map[int32]string{ 0: "ANY", 1: "STAR", 10: "BOOL", 20: "INT8", 21: "INT16", 22: "INT32", 23: "INT64", 24: "INT128", 25: "UINT8", 26: "UINT16", 27: "UINT32", 28: "UINT64", 29: "UINT128", 30: "FLOAT32", 31: "FLOAT64", 32: "DECIMAL64", 33: "DECIMAL128", 34: "DECIMAL", 37: "ANYINT", 38: "ANYFLOAT", 39: "ANYNUMBER", 40: "UUID", 41: "UB160", 42: "UB184", 43: "UB192", 44: "UB224", 45: "UB256", 50: "DATE", 51: "TIME", 52: "DATETIME", 53: "TIMESTAMP", 54: "INTERVAL", 59: "ANYTIME", 60: "CHAR", 61: "VARCHAR", 62: "JSON", 70: "BINARY", 71: "VARBINARY", 90: "ARRAY", 91: "FLEXBUFFER", 100: "BYTEA8", 101: "BYTEA16", 102: "BYTEA", 200: "SEL", 201: "TUPLE", } Type_TypeId_value = map[string]int32{ "ANY": 0, "STAR": 1, "BOOL": 10, "INT8": 20, "INT16": 21, "INT32": 22, "INT64": 23, "INT128": 24, "UINT8": 25, "UINT16": 26, "UINT32": 27, "UINT64": 28, "UINT128": 29, "FLOAT32": 30, "FLOAT64": 31, "DECIMAL64": 32, "DECIMAL128": 33, "DECIMAL": 34, "ANYINT": 37, "ANYFLOAT": 38, "ANYNUMBER": 39, "UUID": 40, "UB160": 41, "UB184": 42, "UB192": 43, "UB224": 44, "UB256": 45, "DATE": 50, "TIME": 51, "DATETIME": 52, "TIMESTAMP": 53, "INTERVAL": 54, "ANYTIME": 59, "CHAR": 60, "VARCHAR": 61, "JSON": 62, "BINARY": 70, "VARBINARY": 71, "ARRAY": 90, "FLEXBUFFER": 91, "BYTEA8": 100, "BYTEA16": 101, "BYTEA": 102, "SEL": 200, "TUPLE": 201, } )
Enum value maps for Type_TypeId.
var ( Function_FuncFlag_name = map[int32]string{ 0: "NONE", 1: "INTERNAL", 2: "STABLE", 4: "VOLATILE", 8: "STRICT", 16: "PRODUCE_NULL", 32: "PRODUCE_NO_NULL", 64: "VARARG", 128: "AGG", 256: "WIN", } Function_FuncFlag_value = map[string]int32{ "NONE": 0, "INTERNAL": 1, "STABLE": 2, "VOLATILE": 4, "STRICT": 8, "PRODUCE_NULL": 16, "PRODUCE_NO_NULL": 32, "VARARG": 64, "AGG": 128, "WIN": 256, } )
Enum value maps for Function_FuncFlag.
var ( OrderBySpec_OrderByFlag_name = map[int32]string{ 0: "ASC", 1: "DESC", 2: "NULLS_FIRST", 4: "NULLS_LAST", 8: "UNIQUE", 16: "INTERNAL", } OrderBySpec_OrderByFlag_value = map[string]int32{ "ASC": 0, "DESC": 1, "NULLS_FIRST": 2, "NULLS_LAST": 4, "UNIQUE": 8, "INTERNAL": 16, } )
Enum value maps for OrderBySpec_OrderByFlag.
var ( Node_NodeType_name = map[int32]string{ 0: "UNKNOWN", 1: "VALUE_SCAN", 2: "TABLE_SCAN", 3: "FUNCTION_SCAN", 4: "EXTERNAL_SCAN", 10: "PROJECT", 11: "EXTERNAL_FUNCTION", 20: "MATERIAL", 21: "RECURSIVE_CTE", 22: "SINK", 23: "SINK_SCAN", 30: "AGG", 31: "JOIN", 32: "SAMPLE", 33: "SORT", 34: "UNION", 35: "UNION_ALL", 36: "UNIQUE", 37: "WINDOW", 40: "BROADCAST", 41: "SPLIT", 42: "GATHER", 50: "ASSERT", 51: "INSERT", 52: "UPDATE", } Node_NodeType_value = map[string]int32{ "UNKNOWN": 0, "VALUE_SCAN": 1, "TABLE_SCAN": 2, "FUNCTION_SCAN": 3, "EXTERNAL_SCAN": 4, "PROJECT": 10, "EXTERNAL_FUNCTION": 11, "MATERIAL": 20, "RECURSIVE_CTE": 21, "SINK": 22, "SINK_SCAN": 23, "AGG": 30, "JOIN": 31, "SAMPLE": 32, "SORT": 33, "UNION": 34, "UNION_ALL": 35, "UNIQUE": 36, "WINDOW": 37, "BROADCAST": 40, "SPLIT": 41, "GATHER": 42, "ASSERT": 50, "INSERT": 51, "UPDATE": 52, } )
Enum value maps for Node_NodeType.
var ( Node_JoinFlag_name = map[int32]string{ 0: "INNER", 1: "OUTER", 2: "SEMI", 4: "ANTI", 8: "SINGLE", 16: "MARK", 32: "APPLY", } Node_JoinFlag_value = map[string]int32{ "INNER": 0, "OUTER": 1, "SEMI": 2, "ANTI": 4, "SINGLE": 8, "MARK": 16, "APPLY": 32, } )
Enum value maps for Node_JoinFlag.
var ( Node_AggMode_name = map[int32]string{ 0: "FULL", 1: "BOTTOM", 2: "TOP", } Node_AggMode_value = map[string]int32{ "FULL": 0, "BOTTOM": 1, "TOP": 2, } )
Enum value maps for Node_AggMode.
var ( Query_StatementType_name = map[int32]string{ 0: "UNKNOWN", 1: "SELECT", 2: "INSERT", 3: "DELETE", 4: "UPDATE", 5: "MERGE", } Query_StatementType_value = map[string]int32{ "UNKNOWN": 0, "SELECT": 1, "INSERT": 2, "DELETE": 3, "UPDATE": 4, "MERGE": 5, } )
Enum value maps for Query_StatementType.
var File_plan_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ColData ¶
type ColData struct {
RowCount int32 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
NullCount int32 `protobuf:"varint,2,opt,name=null_count,json=nullCount,proto3" json:"null_count,omitempty"`
Nulls []bool `protobuf:"varint,3,rep,packed,name=nulls,proto3" json:"nulls,omitempty"`
I32 []int32 `protobuf:"varint,4,rep,packed,name=i32,proto3" json:"i32,omitempty"`
I64 []int64 `protobuf:"varint,5,rep,packed,name=i64,proto3" json:"i64,omitempty"`
F32 []float32 `protobuf:"fixed32,6,rep,packed,name=f32,proto3" json:"f32,omitempty"`
F64 []float64 `protobuf:"fixed64,7,rep,packed,name=f64,proto3" json:"f64,omitempty"`
S []string `protobuf:"bytes,8,rep,name=s,proto3" json:"s,omitempty"`
// contains filtered or unexported fields
}
func (*ColData) Descriptor
deprecated
func (*ColData) GetNullCount ¶
func (*ColData) GetRowCount ¶
func (*ColData) ProtoMessage ¶
func (*ColData) ProtoMessage()
func (*ColData) ProtoReflect ¶
func (x *ColData) ProtoReflect() protoreflect.Message
type ColDef ¶
type ColDef struct {
Typ *Type `protobuf:"bytes,1,opt,name=typ,proto3" json:"typ,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Pkidx int32 `protobuf:"varint,3,opt,name=pkidx,proto3" json:"pkidx,omitempty"`
// contains filtered or unexported fields
}
func (*ColDef) Descriptor
deprecated
func (*ColDef) ProtoMessage ¶
func (*ColDef) ProtoMessage()
func (*ColDef) ProtoReflect ¶
func (x *ColDef) ProtoReflect() protoreflect.Message
type ColRef ¶
type ColRef struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
RelPos int32 `protobuf:"varint,2,opt,name=rel_pos,json=relPos,proto3" json:"rel_pos,omitempty"`
ColPos int32 `protobuf:"varint,3,opt,name=col_pos,json=colPos,proto3" json:"col_pos,omitempty"`
// contains filtered or unexported fields
}
Reference a column in the proj list of a node.
func (*ColRef) Descriptor
deprecated
func (*ColRef) ProtoMessage ¶
func (*ColRef) ProtoMessage()
func (*ColRef) ProtoReflect ¶
func (x *ColRef) ProtoReflect() protoreflect.Message
type Const ¶
type Const struct {
Isnull bool `protobuf:"varint,1,opt,name=isnull,proto3" json:"isnull,omitempty"`
// Types that are assignable to Value:
// *Const_Ival
// *Const_Dval
// *Const_Sval
Value isConst_Value `protobuf_oneof:"value"`
// contains filtered or unexported fields
}
Const: if a const value can be reprensented by int64 or double, use that, otherwise store a string representation.
func (*Const) Descriptor
deprecated
func (*Const) ProtoMessage ¶
func (*Const) ProtoMessage()
func (*Const) ProtoReflect ¶
func (x *Const) ProtoReflect() protoreflect.Message
type Const_Dval ¶
type Const_Dval struct {
Dval float64 `protobuf:"fixed64,3,opt,name=dval,proto3,oneof"`
}
type Const_Ival ¶
type Const_Ival struct {
Ival int64 `protobuf:"varint,2,opt,name=ival,proto3,oneof"`
}
type Const_Sval ¶
type Const_Sval struct {
Sval string `protobuf:"bytes,4,opt,name=sval,proto3,oneof"`
}
type CorrColRef ¶
type CorrColRef struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
RelPos int32 `protobuf:"varint,2,opt,name=rel_pos,json=relPos,proto3" json:"rel_pos,omitempty"`
ColPos int32 `protobuf:"varint,3,opt,name=col_pos,json=colPos,proto3" json:"col_pos,omitempty"`
NodeId int32 `protobuf:"varint,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// contains filtered or unexported fields
}
Reference a correlated column in the proj list of a node.
func (*CorrColRef) Descriptor
deprecated
func (*CorrColRef) Descriptor() ([]byte, []int)
Deprecated: Use CorrColRef.ProtoReflect.Descriptor instead.
func (*CorrColRef) GetColPos ¶
func (x *CorrColRef) GetColPos() int32
func (*CorrColRef) GetName ¶
func (x *CorrColRef) GetName() string
func (*CorrColRef) GetNodeId ¶
func (x *CorrColRef) GetNodeId() int32
func (*CorrColRef) GetRelPos ¶
func (x *CorrColRef) GetRelPos() int32
func (*CorrColRef) ProtoMessage ¶
func (*CorrColRef) ProtoMessage()
func (*CorrColRef) ProtoReflect ¶
func (x *CorrColRef) ProtoReflect() protoreflect.Message
func (*CorrColRef) Reset ¶
func (x *CorrColRef) Reset()
func (*CorrColRef) String ¶
func (x *CorrColRef) String() string
type Cost ¶
type Cost struct {
Card float64 `protobuf:"fixed64,1,opt,name=card,proto3" json:"card,omitempty"`
Rowsize float64 `protobuf:"fixed64,2,opt,name=rowsize,proto3" json:"rowsize,omitempty"`
Ndv float64 `protobuf:"fixed64,3,opt,name=ndv,proto3" json:"ndv,omitempty"`
Start float64 `protobuf:"fixed64,4,opt,name=start,proto3" json:"start,omitempty"`
Total float64 `protobuf:"fixed64,5,opt,name=total,proto3" json:"total,omitempty"`
// contains filtered or unexported fields
}
func (*Cost) Descriptor
deprecated
func (*Cost) GetRowsize ¶
func (*Cost) ProtoMessage ¶
func (*Cost) ProtoMessage()
func (*Cost) ProtoReflect ¶
func (x *Cost) ProtoReflect() protoreflect.Message
type Expr ¶
type Expr struct {
Typ *Type `protobuf:"bytes,1,opt,name=typ,proto3" json:"typ,omitempty"`
Alias string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
// Types that are assignable to Expr:
// *Expr_C
// *Expr_P
// *Expr_V
// *Expr_Col
// *Expr_F
// *Expr_List
// *Expr_Sub
// *Expr_Corr
Expr isExpr_Expr `protobuf_oneof:"expr"`
// contains filtered or unexported fields
}
func (*Expr) Descriptor
deprecated
func (*Expr) GetCorr ¶
func (x *Expr) GetCorr() *CorrColRef
func (*Expr) ProtoMessage ¶
func (*Expr) ProtoMessage()
func (*Expr) ProtoReflect ¶
func (x *Expr) ProtoReflect() protoreflect.Message
type ExprList ¶
type ExprList struct {
List []*Expr `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
// contains filtered or unexported fields
}
ExprList is a type of Expr
func (*ExprList) Descriptor
deprecated
func (*ExprList) ProtoMessage ¶
func (*ExprList) ProtoMessage()
func (*ExprList) ProtoReflect ¶
func (x *ExprList) ProtoReflect() protoreflect.Message
type Expr_Corr ¶
type Expr_Corr struct {
Corr *CorrColRef `protobuf:"bytes,10,opt,name=corr,proto3,oneof"`
}
type Expr_List ¶
type Expr_List struct {
List *ExprList `protobuf:"bytes,8,opt,name=list,proto3,oneof"`
}
type Expr_Sub ¶
type Expr_Sub struct {
Sub *SubQuery `protobuf:"bytes,9,opt,name=sub,proto3,oneof"`
}
type Function ¶
type Function struct {
Func *ObjectRef `protobuf:"bytes,1,opt,name=func,proto3" json:"func,omitempty"`
Args []*Expr `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
// contains filtered or unexported fields
}
func (*Function) Descriptor
deprecated
func (*Function) ProtoMessage ¶
func (*Function) ProtoMessage()
func (*Function) ProtoReflect ¶
func (x *Function) ProtoReflect() protoreflect.Message
type Function_FuncFlag ¶
type Function_FuncFlag int32
Function flags
const ( Function_NONE Function_FuncFlag = 0 // Internal function is generated by system, cannot // by called by user. Function_INTERNAL Function_FuncFlag = 1 // Function, by default is immutable. Function_STABLE Function_FuncFlag = 2 Function_VOLATILE Function_FuncFlag = 4 // Nulls Function_STRICT Function_FuncFlag = 8 Function_PRODUCE_NULL Function_FuncFlag = 16 Function_PRODUCE_NO_NULL Function_FuncFlag = 32 // Vararg, all trailing args must be of the same type. Function_VARARG Function_FuncFlag = 64 // Window and Agg Function_AGG Function_FuncFlag = 128 Function_WIN Function_FuncFlag = 256 )
func (Function_FuncFlag) Descriptor ¶
func (Function_FuncFlag) Descriptor() protoreflect.EnumDescriptor
func (Function_FuncFlag) Enum ¶
func (x Function_FuncFlag) Enum() *Function_FuncFlag
func (Function_FuncFlag) EnumDescriptor
deprecated
func (Function_FuncFlag) EnumDescriptor() ([]byte, []int)
Deprecated: Use Function_FuncFlag.Descriptor instead.
func (Function_FuncFlag) Number ¶
func (x Function_FuncFlag) Number() protoreflect.EnumNumber
func (Function_FuncFlag) String ¶
func (x Function_FuncFlag) String() string
func (Function_FuncFlag) Type ¶
func (Function_FuncFlag) Type() protoreflect.EnumType
type Node ¶
type Node struct {
NodeType Node_NodeType `protobuf:"varint,1,opt,name=node_type,json=nodeType,proto3,enum=Node_NodeType" json:"node_type,omitempty"`
NodeId int32 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
Cost *Cost `protobuf:"bytes,3,opt,name=cost,proto3" json:"cost,omitempty"`
ProjectList []*Expr `protobuf:"bytes,4,rep,name=project_list,json=projectList,proto3" json:"project_list,omitempty"`
Children []int32 `protobuf:"varint,5,rep,packed,name=children,proto3" json:"children,omitempty"`
JoinType Node_JoinFlag `protobuf:"varint,6,opt,name=join_type,json=joinType,proto3,enum=Node_JoinFlag" json:"join_type,omitempty"`
OnList []*Expr `protobuf:"bytes,7,rep,name=on_list,json=onList,proto3" json:"on_list,omitempty"`
WhereList []*Expr `protobuf:"bytes,8,rep,name=where_list,json=whereList,proto3" json:"where_list,omitempty"`
GroupBy []*Expr `protobuf:"bytes,9,rep,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
GroupingSet []*Expr `protobuf:"bytes,10,rep,name=grouping_set,json=groupingSet,proto3" json:"grouping_set,omitempty"`
OrderBy []*OrderBySpec `protobuf:"bytes,11,rep,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
UpdateList *UpdateList `protobuf:"bytes,12,opt,name=update_list,json=updateList,proto3" json:"update_list,omitempty"`
WinSpec *WindowSpec `protobuf:"bytes,13,opt,name=win_spec,json=winSpec,proto3" json:"win_spec,omitempty"`
Limit *Expr `protobuf:"bytes,14,opt,name=limit,proto3" json:"limit,omitempty"`
Offset *Expr `protobuf:"bytes,15,opt,name=offset,proto3" json:"offset,omitempty"`
TableDef *TableDef `protobuf:"bytes,16,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
ObjRef *ObjectRef `protobuf:"bytes,17,opt,name=obj_ref,json=objRef,proto3" json:"obj_ref,omitempty"`
RowsetData *RowsetData `protobuf:"bytes,18,opt,name=rowset_data,json=rowsetData,proto3" json:"rowset_data,omitempty"`
ExtraOptions string `protobuf:"bytes,19,opt,name=extra_options,json=extraOptions,proto3" json:"extra_options,omitempty"`
// contains filtered or unexported fields
}
func (*Node) Descriptor
deprecated
func (*Node) GetChildren ¶
func (*Node) GetExtraOptions ¶
func (*Node) GetGroupBy ¶
func (*Node) GetGroupingSet ¶
func (*Node) GetJoinType ¶
func (x *Node) GetJoinType() Node_JoinFlag
func (*Node) GetNodeType ¶
func (x *Node) GetNodeType() Node_NodeType
func (*Node) GetOrderBy ¶
func (x *Node) GetOrderBy() []*OrderBySpec
func (*Node) GetProjectList ¶
func (*Node) GetRowsetData ¶
func (x *Node) GetRowsetData() *RowsetData
func (*Node) GetTableDef ¶
func (*Node) GetUpdateList ¶
func (x *Node) GetUpdateList() *UpdateList
func (*Node) GetWhereList ¶
func (*Node) GetWinSpec ¶
func (x *Node) GetWinSpec() *WindowSpec
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type Node_AggMode ¶
type Node_AggMode int32
const ( Node_FULL Node_AggMode = 0 Node_BOTTOM Node_AggMode = 1 Node_TOP Node_AggMode = 2 )
func (Node_AggMode) Descriptor ¶
func (Node_AggMode) Descriptor() protoreflect.EnumDescriptor
func (Node_AggMode) Enum ¶
func (x Node_AggMode) Enum() *Node_AggMode
func (Node_AggMode) EnumDescriptor
deprecated
func (Node_AggMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use Node_AggMode.Descriptor instead.
func (Node_AggMode) Number ¶
func (x Node_AggMode) Number() protoreflect.EnumNumber
func (Node_AggMode) String ¶
func (x Node_AggMode) String() string
func (Node_AggMode) Type ¶
func (Node_AggMode) Type() protoreflect.EnumType
type Node_JoinFlag ¶
type Node_JoinFlag int32
const ( Node_INNER Node_JoinFlag = 0 Node_OUTER Node_JoinFlag = 1 Node_SEMI Node_JoinFlag = 2 Node_ANTI Node_JoinFlag = 4 Node_SINGLE Node_JoinFlag = 8 Node_MARK Node_JoinFlag = 16 Node_APPLY Node_JoinFlag = 32 )
func (Node_JoinFlag) Descriptor ¶
func (Node_JoinFlag) Descriptor() protoreflect.EnumDescriptor
func (Node_JoinFlag) Enum ¶
func (x Node_JoinFlag) Enum() *Node_JoinFlag
func (Node_JoinFlag) EnumDescriptor
deprecated
func (Node_JoinFlag) EnumDescriptor() ([]byte, []int)
Deprecated: Use Node_JoinFlag.Descriptor instead.
func (Node_JoinFlag) Number ¶
func (x Node_JoinFlag) Number() protoreflect.EnumNumber
func (Node_JoinFlag) String ¶
func (x Node_JoinFlag) String() string
func (Node_JoinFlag) Type ¶
func (Node_JoinFlag) Type() protoreflect.EnumType
type Node_NodeType ¶
type Node_NodeType int32
const ( Node_UNKNOWN Node_NodeType = 0 // Node Types // Scans Node_VALUE_SCAN Node_NodeType = 1 Node_TABLE_SCAN Node_NodeType = 2 Node_FUNCTION_SCAN Node_NodeType = 3 Node_EXTERNAL_SCAN Node_NodeType = 4 // Proj, for convinience Node_PROJECT Node_NodeType = 10 // External function call (UDF) Node_EXTERNAL_FUNCTION Node_NodeType = 11 // Matrial, CTE, etc. Node_MATERIAL Node_NodeType = 20 Node_RECURSIVE_CTE Node_NodeType = 21 Node_SINK Node_NodeType = 22 Node_SINK_SCAN Node_NodeType = 23 // Proper Relational Operators Node_AGG Node_NodeType = 30 Node_JOIN Node_NodeType = 31 Node_SAMPLE Node_NodeType = 32 Node_SORT Node_NodeType = 33 Node_UNION Node_NodeType = 34 Node_UNION_ALL Node_NodeType = 35 Node_UNIQUE Node_NodeType = 36 Node_WINDOW Node_NodeType = 37 // Physical tuple mover Node_BROADCAST Node_NodeType = 40 Node_SPLIT Node_NodeType = 41 Node_GATHER Node_NodeType = 42 // Misc Node_ASSERT Node_NodeType = 50 // Node_INSERT Node_NodeType = 51 Node_UPDATE Node_NodeType = 52 )
func (Node_NodeType) Descriptor ¶
func (Node_NodeType) Descriptor() protoreflect.EnumDescriptor
func (Node_NodeType) Enum ¶
func (x Node_NodeType) Enum() *Node_NodeType
func (Node_NodeType) EnumDescriptor
deprecated
func (Node_NodeType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Node_NodeType.Descriptor instead.
func (Node_NodeType) Number ¶
func (x Node_NodeType) Number() protoreflect.EnumNumber
func (Node_NodeType) String ¶
func (x Node_NodeType) String() string
func (Node_NodeType) Type ¶
func (Node_NodeType) Type() protoreflect.EnumType
type ObjectRef ¶
type ObjectRef struct {
Server int64 `protobuf:"varint,1,opt,name=server,proto3" json:"server,omitempty"`
Db int64 `protobuf:"varint,2,opt,name=db,proto3" json:"db,omitempty"`
Schema int64 `protobuf:"varint,3,opt,name=schema,proto3" json:"schema,omitempty"`
Obj int64 `protobuf:"varint,4,opt,name=obj,proto3" json:"obj,omitempty"`
ServerName string `protobuf:"bytes,5,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
DbName string `protobuf:"bytes,6,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
SchemaName string `protobuf:"bytes,7,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
ObjName string `protobuf:"bytes,8,opt,name=obj_name,json=objName,proto3" json:"obj_name,omitempty"`
// contains filtered or unexported fields
}
Object ref, reference a object in database, 4 part name.
func (*ObjectRef) Descriptor
deprecated
func (*ObjectRef) GetObjName ¶
func (*ObjectRef) GetSchemaName ¶
func (*ObjectRef) GetServerName ¶
func (*ObjectRef) ProtoMessage ¶
func (*ObjectRef) ProtoMessage()
func (*ObjectRef) ProtoReflect ¶
func (x *ObjectRef) ProtoReflect() protoreflect.Message
type OrderBySpec ¶
type OrderBySpec struct {
OrderBy *Expr `protobuf:"bytes,1,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
OrderByCollations string `protobuf:"bytes,2,opt,name=order_by_collations,json=orderByCollations,proto3" json:"order_by_collations,omitempty"`
OrderByFlags OrderBySpec_OrderByFlag `` /* 129-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*OrderBySpec) Descriptor
deprecated
func (*OrderBySpec) Descriptor() ([]byte, []int)
Deprecated: Use OrderBySpec.ProtoReflect.Descriptor instead.
func (*OrderBySpec) GetOrderBy ¶
func (x *OrderBySpec) GetOrderBy() *Expr
func (*OrderBySpec) GetOrderByCollations ¶
func (x *OrderBySpec) GetOrderByCollations() string
func (*OrderBySpec) GetOrderByFlags ¶
func (x *OrderBySpec) GetOrderByFlags() OrderBySpec_OrderByFlag
func (*OrderBySpec) ProtoMessage ¶
func (*OrderBySpec) ProtoMessage()
func (*OrderBySpec) ProtoReflect ¶
func (x *OrderBySpec) ProtoReflect() protoreflect.Message
func (*OrderBySpec) Reset ¶
func (x *OrderBySpec) Reset()
func (*OrderBySpec) String ¶
func (x *OrderBySpec) String() string
type OrderBySpec_OrderByFlag ¶
type OrderBySpec_OrderByFlag int32
const ( OrderBySpec_ASC OrderBySpec_OrderByFlag = 0 OrderBySpec_DESC OrderBySpec_OrderByFlag = 1 OrderBySpec_NULLS_FIRST OrderBySpec_OrderByFlag = 2 OrderBySpec_NULLS_LAST OrderBySpec_OrderByFlag = 4 OrderBySpec_UNIQUE OrderBySpec_OrderByFlag = 8 OrderBySpec_INTERNAL OrderBySpec_OrderByFlag = 16 )
func (OrderBySpec_OrderByFlag) Descriptor ¶
func (OrderBySpec_OrderByFlag) Descriptor() protoreflect.EnumDescriptor
func (OrderBySpec_OrderByFlag) Enum ¶
func (x OrderBySpec_OrderByFlag) Enum() *OrderBySpec_OrderByFlag
func (OrderBySpec_OrderByFlag) EnumDescriptor
deprecated
func (OrderBySpec_OrderByFlag) EnumDescriptor() ([]byte, []int)
Deprecated: Use OrderBySpec_OrderByFlag.Descriptor instead.
func (OrderBySpec_OrderByFlag) Number ¶
func (x OrderBySpec_OrderByFlag) Number() protoreflect.EnumNumber
func (OrderBySpec_OrderByFlag) String ¶
func (x OrderBySpec_OrderByFlag) String() string
func (OrderBySpec_OrderByFlag) Type ¶
func (OrderBySpec_OrderByFlag) Type() protoreflect.EnumType
type ParamRef ¶
type ParamRef struct {
Pos int32 `protobuf:"varint,1,opt,name=pos,proto3" json:"pos,omitempty"`
// contains filtered or unexported fields
}
Bounded param for prepared statement. User fill on execution.
func (*ParamRef) Descriptor
deprecated
func (*ParamRef) ProtoMessage ¶
func (*ParamRef) ProtoMessage()
func (*ParamRef) ProtoReflect ¶
func (x *ParamRef) ProtoReflect() protoreflect.Message
type Query ¶
type Query struct {
StmtType Query_StatementType `protobuf:"varint,1,opt,name=stmt_type,json=stmtType,proto3,enum=Query_StatementType" json:"stmt_type,omitempty"`
// Each step is simply a root node. Root node refers to other
// node as children and the whole step is a DAG.
Steps []int32 `protobuf:"varint,2,rep,packed,name=steps,proto3" json:"steps,omitempty"`
// All the nodes. It is OK to have dangle nodes, we only excute nodes
// reachable from step roots.
Nodes []*Node `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"`
// Bound Parameter for the query.
Params []*Expr `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`
// contains filtered or unexported fields
}
func (*Query) Descriptor
deprecated
func (*Query) GetStmtType ¶
func (x *Query) GetStmtType() Query_StatementType
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type Query_StatementType ¶
type Query_StatementType int32
const ( Query_UNKNOWN Query_StatementType = 0 Query_SELECT Query_StatementType = 1 Query_INSERT Query_StatementType = 2 Query_DELETE Query_StatementType = 3 Query_UPDATE Query_StatementType = 4 Query_MERGE Query_StatementType = 5 )
func (Query_StatementType) Descriptor ¶
func (Query_StatementType) Descriptor() protoreflect.EnumDescriptor
func (Query_StatementType) Enum ¶
func (x Query_StatementType) Enum() *Query_StatementType
func (Query_StatementType) EnumDescriptor
deprecated
func (Query_StatementType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Query_StatementType.Descriptor instead.
func (Query_StatementType) Number ¶
func (x Query_StatementType) Number() protoreflect.EnumNumber
func (Query_StatementType) String ¶
func (x Query_StatementType) String() string
func (Query_StatementType) Type ¶
func (Query_StatementType) Type() protoreflect.EnumType
type RowsetData ¶
type RowsetData struct {
Schema *TableDef `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
Cols []*ColData `protobuf:"bytes,2,rep,name=cols,proto3" json:"cols,omitempty"`
// contains filtered or unexported fields
}
func (*RowsetData) Descriptor
deprecated
func (*RowsetData) Descriptor() ([]byte, []int)
Deprecated: Use RowsetData.ProtoReflect.Descriptor instead.
func (*RowsetData) GetCols ¶
func (x *RowsetData) GetCols() []*ColData
func (*RowsetData) GetSchema ¶
func (x *RowsetData) GetSchema() *TableDef
func (*RowsetData) ProtoMessage ¶
func (*RowsetData) ProtoMessage()
func (*RowsetData) ProtoReflect ¶
func (x *RowsetData) ProtoReflect() protoreflect.Message
func (*RowsetData) Reset ¶
func (x *RowsetData) Reset()
func (*RowsetData) String ¶
func (x *RowsetData) String() string
type StatementType ¶
type StatementType int32
const ( StatementType_UNKNOW StatementType = 0 StatementType_SELECT StatementType = 1 StatementType_INSERT StatementType = 2 StatementType_DELETE StatementType = 3 StatementType_UPDATE StatementType = 4 StatementType_MERGE StatementType = 5 )
func (StatementType) Descriptor ¶
func (StatementType) Descriptor() protoreflect.EnumDescriptor
func (StatementType) Enum ¶
func (x StatementType) Enum() *StatementType
func (StatementType) EnumDescriptor
deprecated
func (StatementType) EnumDescriptor() ([]byte, []int)
Deprecated: Use StatementType.Descriptor instead.
func (StatementType) Number ¶
func (x StatementType) Number() protoreflect.EnumNumber
func (StatementType) String ¶
func (x StatementType) String() string
func (StatementType) Type ¶
func (StatementType) Type() protoreflect.EnumType
type SubQuery ¶
type SubQuery struct {
NodeId int32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
IsScalar bool `protobuf:"varint,3,opt,name=is_scalar,json=isScalar,proto3" json:"is_scalar,omitempty"`
// contains filtered or unexported fields
}
Reference a subquery
func (*SubQuery) Descriptor
deprecated
func (*SubQuery) GetIsCorrelated ¶
func (*SubQuery) GetIsScalar ¶
func (*SubQuery) ProtoMessage ¶
func (*SubQuery) ProtoMessage()
func (*SubQuery) ProtoReflect ¶
func (x *SubQuery) ProtoReflect() protoreflect.Message
type TableDef ¶
type TableDef struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Cols []*ColDef `protobuf:"bytes,2,rep,name=cols,proto3" json:"cols,omitempty"`
// contains filtered or unexported fields
}
func (*TableDef) Descriptor
deprecated
func (*TableDef) ProtoMessage ¶
func (*TableDef) ProtoMessage()
func (*TableDef) ProtoReflect ¶
func (x *TableDef) ProtoReflect() protoreflect.Message
type Type ¶
type Type struct {
Id Type_TypeId `protobuf:"varint,1,opt,name=id,proto3,enum=Type_TypeId" json:"id,omitempty"`
Nullable bool `protobuf:"varint,2,opt,name=nullable,proto3" json:"nullable,omitempty"`
Width int32 `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"`
Precision int32 `protobuf:"varint,4,opt,name=precision,proto3" json:"precision,omitempty"`
// contains filtered or unexported fields
}
func (*Type) Descriptor
deprecated
func (*Type) GetId ¶
func (x *Type) GetId() Type_TypeId
func (*Type) GetNullable ¶
func (*Type) GetPrecision ¶
func (*Type) ProtoMessage ¶
func (*Type) ProtoMessage()
func (*Type) ProtoReflect ¶
func (x *Type) ProtoReflect() protoreflect.Message
type Type_TypeId ¶
type Type_TypeId int32
const ( Type_ANY Type_TypeId = 0 Type_STAR Type_TypeId = 1 Type_BOOL Type_TypeId = 10 // INTs Type_INT8 Type_TypeId = 20 Type_INT16 Type_TypeId = 21 Type_INT32 Type_TypeId = 22 Type_INT64 Type_TypeId = 23 Type_INT128 Type_TypeId = 24 // UINT are mysql quirks. Type_UINT8 Type_TypeId = 25 Type_UINT16 Type_TypeId = 26 Type_UINT32 Type_TypeId = 27 Type_UINT64 Type_TypeId = 28 Type_UINT128 Type_TypeId = 29 Type_FLOAT32 Type_TypeId = 30 Type_FLOAT64 Type_TypeId = 31 Type_DECIMAL64 Type_TypeId = 32 Type_DECIMAL128 Type_TypeId = 33 Type_DECIMAL Type_TypeId = 34 Type_ANYINT Type_TypeId = 37 Type_ANYFLOAT Type_TypeId = 38 Type_ANYNUMBER Type_TypeId = 39 // Some special small (<= 32 bytes) fixed len types that worth optimize Type_UUID Type_TypeId = 40 // 16 bytes, Type_UB160 Type_TypeId = 41 // 20 bytes, SHA-1 Type_UB184 Type_TypeId = 42 // 23 bytes, Type_UB192 Type_TypeId = 43 // 24 bytes, for example, BLAKE3 output of 24 bytes. Type_UB224 Type_TypeId = 44 // 28 bytes, for example, SHA-224, BLAKE3-224 Type_UB256 Type_TypeId = 45 // 32 bytes, for example, SHA-256, BLAKE3-256 // Time Type_DATE Type_TypeId = 50 Type_TIME Type_TypeId = 51 Type_DATETIME Type_TypeId = 52 Type_TIMESTAMP Type_TypeId = 53 Type_INTERVAL Type_TypeId = 54 Type_ANYTIME Type_TypeId = 59 // Strings and binaries Type_CHAR Type_TypeId = 60 Type_VARCHAR Type_TypeId = 61 Type_JSON Type_TypeId = 62 Type_BINARY Type_TypeId = 70 Type_VARBINARY Type_TypeId = 71 // Special Type_ARRAY Type_TypeId = 90 Type_FLEXBUFFER Type_TypeId = 91 // Physical for varlen Type_BYTEA8 Type_TypeId = 100 Type_BYTEA16 Type_TypeId = 101 Type_BYTEA Type_TypeId = 102 // MO Special, not sure if we really need these. Type_SEL Type_TypeId = 200 Type_TUPLE Type_TypeId = 201 )
func (Type_TypeId) Descriptor ¶
func (Type_TypeId) Descriptor() protoreflect.EnumDescriptor
func (Type_TypeId) Enum ¶
func (x Type_TypeId) Enum() *Type_TypeId
func (Type_TypeId) EnumDescriptor
deprecated
func (Type_TypeId) EnumDescriptor() ([]byte, []int)
Deprecated: Use Type_TypeId.Descriptor instead.
func (Type_TypeId) Number ¶
func (x Type_TypeId) Number() protoreflect.EnumNumber
func (Type_TypeId) String ¶
func (x Type_TypeId) String() string
func (Type_TypeId) Type ¶
func (Type_TypeId) Type() protoreflect.EnumType
type UpdateList ¶
type UpdateList struct {
Columns []*Expr `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
Values []*Expr `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateList) Descriptor
deprecated
func (*UpdateList) Descriptor() ([]byte, []int)
Deprecated: Use UpdateList.ProtoReflect.Descriptor instead.
func (*UpdateList) GetColumns ¶
func (x *UpdateList) GetColumns() []*Expr
func (*UpdateList) GetValues ¶
func (x *UpdateList) GetValues() []*Expr
func (*UpdateList) ProtoMessage ¶
func (*UpdateList) ProtoMessage()
func (*UpdateList) ProtoReflect ¶
func (x *UpdateList) ProtoReflect() protoreflect.Message
func (*UpdateList) Reset ¶
func (x *UpdateList) Reset()
func (*UpdateList) String ¶
func (x *UpdateList) String() string
type VarRef ¶
type VarRef struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Session variable ref, compiler should fold.
func (*VarRef) Descriptor
deprecated
func (*VarRef) ProtoMessage ¶
func (*VarRef) ProtoMessage()
func (*VarRef) ProtoReflect ¶
func (x *VarRef) ProtoReflect() protoreflect.Message
type WindowSpec ¶
type WindowSpec struct {
PartitionBy []*Expr `protobuf:"bytes,1,rep,name=partition_by,json=partitionBy,proto3" json:"partition_by,omitempty"`
OderyBy []*OrderBySpec `protobuf:"bytes,2,rep,name=odery_by,json=oderyBy,proto3" json:"odery_by,omitempty"`
Lead int32 `protobuf:"varint,3,opt,name=lead,proto3" json:"lead,omitempty"`
Lag int32 `protobuf:"varint,4,opt,name=lag,proto3" json:"lag,omitempty"`
// contains filtered or unexported fields
}
func (*WindowSpec) Descriptor
deprecated
func (*WindowSpec) Descriptor() ([]byte, []int)
Deprecated: Use WindowSpec.ProtoReflect.Descriptor instead.
func (*WindowSpec) GetLag ¶
func (x *WindowSpec) GetLag() int32
func (*WindowSpec) GetLead ¶
func (x *WindowSpec) GetLead() int32
func (*WindowSpec) GetOderyBy ¶
func (x *WindowSpec) GetOderyBy() []*OrderBySpec
func (*WindowSpec) GetPartitionBy ¶
func (x *WindowSpec) GetPartitionBy() []*Expr
func (*WindowSpec) ProtoMessage ¶
func (*WindowSpec) ProtoMessage()
func (*WindowSpec) ProtoReflect ¶
func (x *WindowSpec) ProtoReflect() protoreflect.Message
func (*WindowSpec) Reset ¶
func (x *WindowSpec) Reset()
func (*WindowSpec) String ¶
func (x *WindowSpec) String() string