plan

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: May 5, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

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) Descriptor() ([]byte, []int)

Deprecated: Use ColData.ProtoReflect.Descriptor instead.

func (*ColData) GetF32

func (x *ColData) GetF32() []float32

func (*ColData) GetF64

func (x *ColData) GetF64() []float64

func (*ColData) GetI32

func (x *ColData) GetI32() []int32

func (*ColData) GetI64

func (x *ColData) GetI64() []int64

func (*ColData) GetNullCount

func (x *ColData) GetNullCount() int32

func (*ColData) GetNulls

func (x *ColData) GetNulls() []bool

func (*ColData) GetRowCount

func (x *ColData) GetRowCount() int32

func (*ColData) GetS

func (x *ColData) GetS() []string

func (*ColData) ProtoMessage

func (*ColData) ProtoMessage()

func (*ColData) ProtoReflect

func (x *ColData) ProtoReflect() protoreflect.Message

func (*ColData) Reset

func (x *ColData) Reset()

func (*ColData) String

func (x *ColData) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ColDef.ProtoReflect.Descriptor instead.

func (*ColDef) GetName

func (x *ColDef) GetName() string

func (*ColDef) GetPkidx

func (x *ColDef) GetPkidx() int32

func (*ColDef) GetTyp

func (x *ColDef) GetTyp() *Type

func (*ColDef) ProtoMessage

func (*ColDef) ProtoMessage()

func (*ColDef) ProtoReflect

func (x *ColDef) ProtoReflect() protoreflect.Message

func (*ColDef) Reset

func (x *ColDef) Reset()

func (*ColDef) String

func (x *ColDef) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ColRef.ProtoReflect.Descriptor instead.

func (*ColRef) GetColPos

func (x *ColRef) GetColPos() int32

func (*ColRef) GetName

func (x *ColRef) GetName() string

func (*ColRef) GetRelPos

func (x *ColRef) GetRelPos() int32

func (*ColRef) ProtoMessage

func (*ColRef) ProtoMessage()

func (*ColRef) ProtoReflect

func (x *ColRef) ProtoReflect() protoreflect.Message

func (*ColRef) Reset

func (x *ColRef) Reset()

func (*ColRef) String

func (x *ColRef) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Const.ProtoReflect.Descriptor instead.

func (*Const) GetDval

func (x *Const) GetDval() float64

func (*Const) GetIsnull

func (x *Const) GetIsnull() bool

func (*Const) GetIval

func (x *Const) GetIval() int64

func (*Const) GetSval

func (x *Const) GetSval() string

func (*Const) GetValue

func (m *Const) GetValue() isConst_Value

func (*Const) ProtoMessage

func (*Const) ProtoMessage()

func (*Const) ProtoReflect

func (x *Const) ProtoReflect() protoreflect.Message

func (*Const) Reset

func (x *Const) Reset()

func (*Const) String

func (x *Const) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Cost.ProtoReflect.Descriptor instead.

func (*Cost) GetCard

func (x *Cost) GetCard() float64

func (*Cost) GetNdv

func (x *Cost) GetNdv() float64

func (*Cost) GetRowsize

func (x *Cost) GetRowsize() float64

func (*Cost) GetStart

func (x *Cost) GetStart() float64

func (*Cost) GetTotal

func (x *Cost) GetTotal() float64

func (*Cost) ProtoMessage

func (*Cost) ProtoMessage()

func (*Cost) ProtoReflect

func (x *Cost) ProtoReflect() protoreflect.Message

func (*Cost) Reset

func (x *Cost) Reset()

func (*Cost) String

func (x *Cost) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Expr.ProtoReflect.Descriptor instead.

func (*Expr) GetAlias

func (x *Expr) GetAlias() string

func (*Expr) GetC

func (x *Expr) GetC() *Const

func (*Expr) GetCol

func (x *Expr) GetCol() *ColRef

func (*Expr) GetCorr

func (x *Expr) GetCorr() *CorrColRef

func (*Expr) GetExpr

func (m *Expr) GetExpr() isExpr_Expr

func (*Expr) GetF

func (x *Expr) GetF() *Function

func (*Expr) GetList

func (x *Expr) GetList() *ExprList

func (*Expr) GetP

func (x *Expr) GetP() *ParamRef

func (*Expr) GetSub

func (x *Expr) GetSub() *SubQuery

func (*Expr) GetTyp

func (x *Expr) GetTyp() *Type

func (*Expr) GetV

func (x *Expr) GetV() *VarRef

func (*Expr) ProtoMessage

func (*Expr) ProtoMessage()

func (*Expr) ProtoReflect

func (x *Expr) ProtoReflect() protoreflect.Message

func (*Expr) Reset

func (x *Expr) Reset()

func (*Expr) String

func (x *Expr) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ExprList.ProtoReflect.Descriptor instead.

func (*ExprList) GetList

func (x *ExprList) GetList() []*Expr

func (*ExprList) ProtoMessage

func (*ExprList) ProtoMessage()

func (*ExprList) ProtoReflect

func (x *ExprList) ProtoReflect() protoreflect.Message

func (*ExprList) Reset

func (x *ExprList) Reset()

func (*ExprList) String

func (x *ExprList) String() string

type Expr_C

type Expr_C struct {
	C *Const `protobuf:"bytes,3,opt,name=c,proto3,oneof"`
}

type Expr_Col

type Expr_Col struct {
	Col *ColRef `protobuf:"bytes,6,opt,name=col,proto3,oneof"`
}

type Expr_Corr

type Expr_Corr struct {
	Corr *CorrColRef `protobuf:"bytes,10,opt,name=corr,proto3,oneof"`
}

type Expr_F

type Expr_F struct {
	F *Function `protobuf:"bytes,7,opt,name=f,proto3,oneof"`
}

type Expr_List

type Expr_List struct {
	List *ExprList `protobuf:"bytes,8,opt,name=list,proto3,oneof"`
}

type Expr_P

type Expr_P struct {
	P *ParamRef `protobuf:"bytes,4,opt,name=p,proto3,oneof"`
}

type Expr_Sub

type Expr_Sub struct {
	Sub *SubQuery `protobuf:"bytes,9,opt,name=sub,proto3,oneof"`
}

type Expr_V

type Expr_V struct {
	V *VarRef `protobuf:"bytes,5,opt,name=v,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) Descriptor() ([]byte, []int)

Deprecated: Use Function.ProtoReflect.Descriptor instead.

func (*Function) GetArgs

func (x *Function) GetArgs() []*Expr

func (*Function) GetFunc

func (x *Function) GetFunc() *ObjectRef

func (*Function) ProtoMessage

func (*Function) ProtoMessage()

func (*Function) ProtoReflect

func (x *Function) ProtoReflect() protoreflect.Message

func (*Function) Reset

func (x *Function) Reset()

func (*Function) String

func (x *Function) String() string

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

func (Function_FuncFlag) EnumDescriptor deprecated

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

Deprecated: Use Function_FuncFlag.Descriptor instead.

func (Function_FuncFlag) Number

func (Function_FuncFlag) String

func (x Function_FuncFlag) String() string

func (Function_FuncFlag) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetChildren

func (x *Node) GetChildren() []int32

func (*Node) GetCost

func (x *Node) GetCost() *Cost

func (*Node) GetExtraOptions

func (x *Node) GetExtraOptions() string

func (*Node) GetGroupBy

func (x *Node) GetGroupBy() []*Expr

func (*Node) GetGroupingSet

func (x *Node) GetGroupingSet() []*Expr

func (*Node) GetJoinType

func (x *Node) GetJoinType() Node_JoinFlag

func (*Node) GetLimit

func (x *Node) GetLimit() *Expr

func (*Node) GetNodeId

func (x *Node) GetNodeId() int32

func (*Node) GetNodeType

func (x *Node) GetNodeType() Node_NodeType

func (*Node) GetObjRef

func (x *Node) GetObjRef() *ObjectRef

func (*Node) GetOffset

func (x *Node) GetOffset() *Expr

func (*Node) GetOnList

func (x *Node) GetOnList() []*Expr

func (*Node) GetOrderBy

func (x *Node) GetOrderBy() []*OrderBySpec

func (*Node) GetProjectList

func (x *Node) GetProjectList() []*Expr

func (*Node) GetRowsetData

func (x *Node) GetRowsetData() *RowsetData

func (*Node) GetTableDef

func (x *Node) GetTableDef() *TableDef

func (*Node) GetUpdateList

func (x *Node) GetUpdateList() *UpdateList

func (*Node) GetWhereList

func (x *Node) GetWhereList() []*Expr

func (*Node) GetWinSpec

func (x *Node) GetWinSpec() *WindowSpec

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

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) 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 (Node_AggMode) String

func (x Node_AggMode) String() string

func (Node_AggMode) Type

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) 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 (Node_JoinFlag) String

func (x Node_JoinFlag) String() string

func (Node_JoinFlag) Type

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) 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 (Node_NodeType) String

func (x Node_NodeType) String() string

func (Node_NodeType) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use ObjectRef.ProtoReflect.Descriptor instead.

func (*ObjectRef) GetDb

func (x *ObjectRef) GetDb() int64

func (*ObjectRef) GetDbName

func (x *ObjectRef) GetDbName() string

func (*ObjectRef) GetObj

func (x *ObjectRef) GetObj() int64

func (*ObjectRef) GetObjName

func (x *ObjectRef) GetObjName() string

func (*ObjectRef) GetSchema

func (x *ObjectRef) GetSchema() int64

func (*ObjectRef) GetSchemaName

func (x *ObjectRef) GetSchemaName() string

func (*ObjectRef) GetServer

func (x *ObjectRef) GetServer() int64

func (*ObjectRef) GetServerName

func (x *ObjectRef) GetServerName() string

func (*ObjectRef) ProtoMessage

func (*ObjectRef) ProtoMessage()

func (*ObjectRef) ProtoReflect

func (x *ObjectRef) ProtoReflect() protoreflect.Message

func (*ObjectRef) Reset

func (x *ObjectRef) Reset()

func (*ObjectRef) String

func (x *ObjectRef) String() string

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

func (OrderBySpec_OrderByFlag) EnumDescriptor deprecated

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

Deprecated: Use OrderBySpec_OrderByFlag.Descriptor instead.

func (OrderBySpec_OrderByFlag) Number

func (OrderBySpec_OrderByFlag) String

func (x OrderBySpec_OrderByFlag) String() string

func (OrderBySpec_OrderByFlag) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use ParamRef.ProtoReflect.Descriptor instead.

func (*ParamRef) GetPos

func (x *ParamRef) GetPos() int32

func (*ParamRef) ProtoMessage

func (*ParamRef) ProtoMessage()

func (*ParamRef) ProtoReflect

func (x *ParamRef) ProtoReflect() protoreflect.Message

func (*ParamRef) Reset

func (x *ParamRef) Reset()

func (*ParamRef) String

func (x *ParamRef) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetNodes

func (x *Query) GetNodes() []*Node

func (*Query) GetParams

func (x *Query) GetParams() []*Expr

func (*Query) GetSteps

func (x *Query) GetSteps() []int32

func (*Query) GetStmtType

func (x *Query) GetStmtType() Query_StatementType

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) ProtoReflect

func (x *Query) ProtoReflect() protoreflect.Message

func (*Query) Reset

func (x *Query) Reset()

func (*Query) String

func (x *Query) String() string

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

func (Query_StatementType) EnumDescriptor deprecated

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

Deprecated: Use Query_StatementType.Descriptor instead.

func (Query_StatementType) Number

func (Query_StatementType) String

func (x Query_StatementType) String() string

func (Query_StatementType) Type

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

func (x StatementType) Enum() *StatementType

func (StatementType) EnumDescriptor deprecated

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

Deprecated: Use StatementType.Descriptor instead.

func (StatementType) Number

func (StatementType) String

func (x StatementType) String() string

func (StatementType) Type

type SubQuery

type SubQuery struct {
	NodeId       int32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	IsCorrelated bool  `protobuf:"varint,2,opt,name=is_correlated,json=isCorrelated,proto3" json:"is_correlated,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) Descriptor() ([]byte, []int)

Deprecated: Use SubQuery.ProtoReflect.Descriptor instead.

func (*SubQuery) GetIsCorrelated

func (x *SubQuery) GetIsCorrelated() bool

func (*SubQuery) GetIsScalar

func (x *SubQuery) GetIsScalar() bool

func (*SubQuery) GetNodeId

func (x *SubQuery) GetNodeId() int32

func (*SubQuery) ProtoMessage

func (*SubQuery) ProtoMessage()

func (*SubQuery) ProtoReflect

func (x *SubQuery) ProtoReflect() protoreflect.Message

func (*SubQuery) Reset

func (x *SubQuery) Reset()

func (*SubQuery) String

func (x *SubQuery) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TableDef.ProtoReflect.Descriptor instead.

func (*TableDef) GetCols

func (x *TableDef) GetCols() []*ColDef

func (*TableDef) GetName

func (x *TableDef) GetName() string

func (*TableDef) ProtoMessage

func (*TableDef) ProtoMessage()

func (*TableDef) ProtoReflect

func (x *TableDef) ProtoReflect() protoreflect.Message

func (*TableDef) Reset

func (x *TableDef) Reset()

func (*TableDef) String

func (x *TableDef) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Type.ProtoReflect.Descriptor instead.

func (*Type) GetId

func (x *Type) GetId() Type_TypeId

func (*Type) GetNullable

func (x *Type) GetNullable() bool

func (*Type) GetPrecision

func (x *Type) GetPrecision() int32

func (*Type) GetWidth

func (x *Type) GetWidth() int32

func (*Type) ProtoMessage

func (*Type) ProtoMessage()

func (*Type) ProtoReflect

func (x *Type) ProtoReflect() protoreflect.Message

func (*Type) Reset

func (x *Type) Reset()

func (*Type) String

func (x *Type) String() string

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

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) Descriptor() ([]byte, []int)

Deprecated: Use VarRef.ProtoReflect.Descriptor instead.

func (*VarRef) GetName

func (x *VarRef) GetName() string

func (*VarRef) ProtoMessage

func (*VarRef) ProtoMessage()

func (*VarRef) ProtoReflect

func (x *VarRef) ProtoReflect() protoreflect.Message

func (*VarRef) Reset

func (x *VarRef) Reset()

func (*VarRef) String

func (x *VarRef) String() string

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

Jump to

Keyboard shortcuts

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