pipeline

package
v0.6.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const MessageEnd = 1

Variables

View Source 
var (
	ErrInvalidLengthPipeline        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPipeline          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPipeline = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Pipeline_PipelineType_name = map[int32]string{
	0: "Merge",
	1: "Normal",
	2: "Remote",
	3: "Parallel",
}
View Source 
var Pipeline_PipelineType_value = map[string]int32{
	"Merge":    0,
	"Normal":   1,
	"Remote":   2,
	"Parallel": 3,
}

Functions

func DecodeMessageError 

func DecodeMessageError(m *Message) error

func EncodedMessageError 

func EncodedMessageError(err error) []byte

Types

type Aggregate 

type Aggregate struct {
	Op                   int32      `protobuf:"varint,1,opt,name=op,proto3" json:"op,omitempty"`
	Dist                 bool       `protobuf:"varint,2,opt,name=dist,proto3" json:"dist,omitempty"`
	Expr                 *plan.Expr `protobuf:"bytes,3,opt,name=expr,proto3" json:"expr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Aggregate) Descriptor 

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

func (*Aggregate) GetDist 

func (m *Aggregate) GetDist() bool

func (*Aggregate) GetExpr 

func (m *Aggregate) GetExpr() *plan.Expr

func (*Aggregate) GetOp 

func (m *Aggregate) GetOp() int32

func (*Aggregate) Marshal 

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

func (*Aggregate) MarshalTo 

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

func (*Aggregate) MarshalToSizedBuffer 

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

func (*Aggregate) ProtoMessage 

func (*Aggregate) ProtoMessage()

func (*Aggregate) ProtoSize 

func (m *Aggregate) ProtoSize() (n int)

func (*Aggregate) Reset 

func (m *Aggregate) Reset()

func (*Aggregate) String 

func (m *Aggregate) String() string

func (*Aggregate) Unmarshal 

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

func (*Aggregate) XXX_DiscardUnknown 

func (m *Aggregate) XXX_DiscardUnknown()

func (*Aggregate) XXX_Marshal 

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

func (*Aggregate) XXX_Merge 

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

func (*Aggregate) XXX_Size 

func (m *Aggregate) XXX_Size() int

func (*Aggregate) XXX_Unmarshal 

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

type AnalysisList 

type AnalysisList struct {
	List                 []*plan.AnalyzeInfo `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*AnalysisList) Descriptor 

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

func (*AnalysisList) GetList 

func (m *AnalysisList) GetList() []*plan.AnalyzeInfo

func (*AnalysisList) Marshal 

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

func (*AnalysisList) MarshalTo 

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

func (*AnalysisList) MarshalToSizedBuffer 

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

func (*AnalysisList) ProtoMessage 

func (*AnalysisList) ProtoMessage()

func (*AnalysisList) ProtoSize 

func (m *AnalysisList) ProtoSize() (n int)

func (*AnalysisList) Reset 

func (m *AnalysisList) Reset()

func (*AnalysisList) String 

func (m *AnalysisList) String() string

func (*AnalysisList) Unmarshal 

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

func (*AnalysisList) XXX_DiscardUnknown 

func (m *AnalysisList) XXX_DiscardUnknown()

func (*AnalysisList) XXX_Marshal 

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

func (*AnalysisList) XXX_Merge 

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

func (*AnalysisList) XXX_Size 

func (m *AnalysisList) XXX_Size() int

func (*AnalysisList) XXX_Unmarshal 

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

type AntiJoin 

type AntiJoin struct {
	Ibucket              uint64       `protobuf:"varint,1,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,2,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	Result               []int32      `protobuf:"varint,3,rep,packed,name=result,proto3" json:"result,omitempty"`
	Expr                 *plan.Expr   `protobuf:"bytes,4,opt,name=expr,proto3" json:"expr,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,5,rep,name=types,proto3" json:"types,omitempty"`
	LeftCond             []*plan.Expr `protobuf:"bytes,6,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond            []*plan.Expr `protobuf:"bytes,7,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*AntiJoin) Descriptor 

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

func (*AntiJoin) GetExpr 

func (m *AntiJoin) GetExpr() *plan.Expr

func (*AntiJoin) GetIbucket 

func (m *AntiJoin) GetIbucket() uint64

func (*AntiJoin) GetLeftCond 

func (m *AntiJoin) GetLeftCond() []*plan.Expr

func (*AntiJoin) GetNbucket 

func (m *AntiJoin) GetNbucket() uint64

func (*AntiJoin) GetResult 

func (m *AntiJoin) GetResult() []int32

func (*AntiJoin) GetRightCond 

func (m *AntiJoin) GetRightCond() []*plan.Expr

func (*AntiJoin) GetTypes 

func (m *AntiJoin) GetTypes() []*plan.Type

func (*AntiJoin) Marshal 

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

func (*AntiJoin) MarshalTo 

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

func (*AntiJoin) MarshalToSizedBuffer 

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

func (*AntiJoin) ProtoMessage 

func (*AntiJoin) ProtoMessage()

func (*AntiJoin) ProtoSize 

func (m *AntiJoin) ProtoSize() (n int)

func (*AntiJoin) Reset 

func (m *AntiJoin) Reset()

func (*AntiJoin) String 

func (m *AntiJoin) String() string

func (*AntiJoin) Unmarshal 

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

func (*AntiJoin) XXX_DiscardUnknown 

func (m *AntiJoin) XXX_DiscardUnknown()

func (*AntiJoin) XXX_Marshal 

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

func (*AntiJoin) XXX_Merge 

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

func (*AntiJoin) XXX_Size 

func (m *AntiJoin) XXX_Size() int

func (*AntiJoin) XXX_Unmarshal 

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

type Connector 

type Connector struct {
	PipelineId           int32    `protobuf:"varint,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	ConnectorIndex       int32    `protobuf:"varint,2,opt,name=connector_index,json=connectorIndex,proto3" json:"connector_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Connector) Descriptor 

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

func (*Connector) GetConnectorIndex 

func (m *Connector) GetConnectorIndex() int32

func (*Connector) GetPipelineId 

func (m *Connector) GetPipelineId() int32

func (*Connector) Marshal 

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

func (*Connector) MarshalTo 

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

func (*Connector) MarshalToSizedBuffer 

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

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoSize 

func (m *Connector) ProtoSize() (n int)

func (*Connector) Reset 

func (m *Connector) Reset()

func (*Connector) String 

func (m *Connector) String() string

func (*Connector) Unmarshal 

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

func (*Connector) XXX_DiscardUnknown 

func (m *Connector) XXX_DiscardUnknown()

func (*Connector) XXX_Marshal 

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

func (*Connector) XXX_Merge 

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

func (*Connector) XXX_Size 

func (m *Connector) XXX_Size() int

func (*Connector) XXX_Unmarshal 

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

type Dispatch 

type Dispatch struct {
	All                  bool         `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	Connector            []*Connector `protobuf:"bytes,2,rep,name=connector,proto3" json:"connector,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Dispatch) Descriptor 

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

func (*Dispatch) GetAll 

func (m *Dispatch) GetAll() bool

func (*Dispatch) GetConnector 

func (m *Dispatch) GetConnector() []*Connector

func (*Dispatch) Marshal 

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

func (*Dispatch) MarshalTo 

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

func (*Dispatch) MarshalToSizedBuffer 

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

func (*Dispatch) ProtoMessage 

func (*Dispatch) ProtoMessage()

func (*Dispatch) ProtoSize 

func (m *Dispatch) ProtoSize() (n int)

func (*Dispatch) Reset 

func (m *Dispatch) Reset()

func (*Dispatch) String 

func (m *Dispatch) String() string

func (*Dispatch) Unmarshal 

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

func (*Dispatch) XXX_DiscardUnknown 

func (m *Dispatch) XXX_DiscardUnknown()

func (*Dispatch) XXX_Marshal 

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

func (*Dispatch) XXX_Merge 

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

func (*Dispatch) XXX_Size 

func (m *Dispatch) XXX_Size() int

func (*Dispatch) XXX_Unmarshal 

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

type ExternalName2ColIndex 

type ExternalName2ColIndex struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Index                int32    `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExternalName2ColIndex) Descriptor 

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

func (*ExternalName2ColIndex) GetIndex 

func (m *ExternalName2ColIndex) GetIndex() int32

func (*ExternalName2ColIndex) GetName 

func (m *ExternalName2ColIndex) GetName() string

func (*ExternalName2ColIndex) Marshal 

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

func (*ExternalName2ColIndex) MarshalTo 

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

func (*ExternalName2ColIndex) MarshalToSizedBuffer 

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

func (*ExternalName2ColIndex) ProtoMessage 

func (*ExternalName2ColIndex) ProtoMessage()

func (*ExternalName2ColIndex) ProtoSize 

func (m *ExternalName2ColIndex) ProtoSize() (n int)

func (*ExternalName2ColIndex) Reset 

func (m *ExternalName2ColIndex) Reset()

func (*ExternalName2ColIndex) String 

func (m *ExternalName2ColIndex) String() string

func (*ExternalName2ColIndex) Unmarshal 

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

func (*ExternalName2ColIndex) XXX_DiscardUnknown 

func (m *ExternalName2ColIndex) XXX_DiscardUnknown()

func (*ExternalName2ColIndex) XXX_Marshal 

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

func (*ExternalName2ColIndex) XXX_Merge 

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

func (*ExternalName2ColIndex) XXX_Size 

func (m *ExternalName2ColIndex) XXX_Size() int

func (*ExternalName2ColIndex) XXX_Unmarshal 

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

type ExternalScan 

type ExternalScan struct {
	Attrs                []string                 `protobuf:"bytes,1,rep,name=attrs,proto3" json:"attrs,omitempty"`
	Cols                 []*plan.ColDef           `protobuf:"bytes,2,rep,name=cols,proto3" json:"cols,omitempty"`
	Name2ColIndex        []*ExternalName2ColIndex `protobuf:"bytes,3,rep,name=name2_col_index,json=name2ColIndex,proto3" json:"name2_col_index,omitempty"`
	CreateSql            string                   `protobuf:"bytes,4,opt,name=create_sql,json=createSql,proto3" json:"create_sql,omitempty"`
	FileList             []string                 `protobuf:"bytes,5,rep,name=file_list,json=fileList,proto3" json:"file_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ExternalScan) Descriptor 

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

func (*ExternalScan) GetAttrs 

func (m *ExternalScan) GetAttrs() []string

func (*ExternalScan) GetCols 

func (m *ExternalScan) GetCols() []*plan.ColDef

func (*ExternalScan) GetCreateSql 

func (m *ExternalScan) GetCreateSql() string

func (*ExternalScan) GetFileList 

func (m *ExternalScan) GetFileList() []string

func (*ExternalScan) GetName2ColIndex 

func (m *ExternalScan) GetName2ColIndex() []*ExternalName2ColIndex

func (*ExternalScan) Marshal 

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

func (*ExternalScan) MarshalTo 

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

func (*ExternalScan) MarshalToSizedBuffer 

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

func (*ExternalScan) ProtoMessage 

func (*ExternalScan) ProtoMessage()

func (*ExternalScan) ProtoSize 

func (m *ExternalScan) ProtoSize() (n int)

func (*ExternalScan) Reset 

func (m *ExternalScan) Reset()

func (*ExternalScan) String 

func (m *ExternalScan) String() string

func (*ExternalScan) Unmarshal 

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

func (*ExternalScan) XXX_DiscardUnknown 

func (m *ExternalScan) XXX_DiscardUnknown()

func (*ExternalScan) XXX_Marshal 

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

func (*ExternalScan) XXX_Merge 

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

func (*ExternalScan) XXX_Size 

func (m *ExternalScan) XXX_Size() int

func (*ExternalScan) XXX_Unmarshal 

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

type Group 

type Group struct {
	NeedEval             bool         `protobuf:"varint,1,opt,name=need_eval,json=needEval,proto3" json:"need_eval,omitempty"`
	Ibucket              uint64       `protobuf:"varint,2,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,3,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	Exprs                []*plan.Expr `protobuf:"bytes,4,rep,name=exprs,proto3" json:"exprs,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,5,rep,name=types,proto3" json:"types,omitempty"`
	Aggs                 []*Aggregate `protobuf:"bytes,6,rep,name=aggs,proto3" json:"aggs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Group) Descriptor 

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

func (*Group) GetAggs 

func (m *Group) GetAggs() []*Aggregate

func (*Group) GetExprs 

func (m *Group) GetExprs() []*plan.Expr

func (*Group) GetIbucket 

func (m *Group) GetIbucket() uint64

func (*Group) GetNbucket 

func (m *Group) GetNbucket() uint64

func (*Group) GetNeedEval 

func (m *Group) GetNeedEval() bool

func (*Group) GetTypes 

func (m *Group) GetTypes() []*plan.Type

func (*Group) Marshal 

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

func (*Group) MarshalTo 

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

func (*Group) MarshalToSizedBuffer 

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

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) ProtoSize 

func (m *Group) ProtoSize() (n int)

func (*Group) Reset 

func (m *Group) Reset()

func (*Group) String 

func (m *Group) String() string

func (*Group) Unmarshal 

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

func (*Group) XXX_DiscardUnknown 

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal 

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

func (*Group) XXX_Merge 

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

func (*Group) XXX_Size 

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal 

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

type HashBuild 

type HashBuild struct {
	NeedExpr             bool         `protobuf:"varint,1,opt,name=need_expr,json=needExpr,proto3" json:"need_expr,omitempty"`
	NeedHash             bool         `protobuf:"varint,2,opt,name=need_hash,json=needHash,proto3" json:"need_hash,omitempty"`
	Ibucket              uint64       `protobuf:"varint,3,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,4,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,5,rep,name=types,proto3" json:"types,omitempty"`
	Conds                []*plan.Expr `protobuf:"bytes,6,rep,name=conds,proto3" json:"conds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*HashBuild) Descriptor 

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

func (*HashBuild) GetConds 

func (m *HashBuild) GetConds() []*plan.Expr

func (*HashBuild) GetIbucket 

func (m *HashBuild) GetIbucket() uint64

func (*HashBuild) GetNbucket 

func (m *HashBuild) GetNbucket() uint64

func (*HashBuild) GetNeedExpr 

func (m *HashBuild) GetNeedExpr() bool

func (*HashBuild) GetNeedHash 

func (m *HashBuild) GetNeedHash() bool

func (*HashBuild) GetTypes 

func (m *HashBuild) GetTypes() []*plan.Type

func (*HashBuild) Marshal 

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

func (*HashBuild) MarshalTo 

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

func (*HashBuild) MarshalToSizedBuffer 

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

func (*HashBuild) ProtoMessage 

func (*HashBuild) ProtoMessage()

func (*HashBuild) ProtoSize 

func (m *HashBuild) ProtoSize() (n int)

func (*HashBuild) Reset 

func (m *HashBuild) Reset()

func (*HashBuild) String 

func (m *HashBuild) String() string

func (*HashBuild) Unmarshal 

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

func (*HashBuild) XXX_DiscardUnknown 

func (m *HashBuild) XXX_DiscardUnknown()

func (*HashBuild) XXX_Marshal 

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

func (*HashBuild) XXX_Merge 

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

func (*HashBuild) XXX_Size 

func (m *HashBuild) XXX_Size() int

func (*HashBuild) XXX_Unmarshal 

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

type InnerJoin 

type InnerJoin struct {
	Ibucket              uint64       `protobuf:"varint,1,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,2,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	RelList              []int32      `protobuf:"varint,3,rep,packed,name=rel_list,json=relList,proto3" json:"rel_list,omitempty"`
	ColList              []int32      `protobuf:"varint,4,rep,packed,name=col_list,json=colList,proto3" json:"col_list,omitempty"`
	Expr                 *plan.Expr   `protobuf:"bytes,5,opt,name=expr,proto3" json:"expr,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,6,rep,name=types,proto3" json:"types,omitempty"`
	LeftCond             []*plan.Expr `protobuf:"bytes,7,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond            []*plan.Expr `protobuf:"bytes,8,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*InnerJoin) Descriptor 

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

func (*InnerJoin) GetColList 

func (m *InnerJoin) GetColList() []int32

func (*InnerJoin) GetExpr 

func (m *InnerJoin) GetExpr() *plan.Expr

func (*InnerJoin) GetIbucket 

func (m *InnerJoin) GetIbucket() uint64

func (*InnerJoin) GetLeftCond 

func (m *InnerJoin) GetLeftCond() []*plan.Expr

func (*InnerJoin) GetNbucket 

func (m *InnerJoin) GetNbucket() uint64

func (*InnerJoin) GetRelList 

func (m *InnerJoin) GetRelList() []int32

func (*InnerJoin) GetRightCond 

func (m *InnerJoin) GetRightCond() []*plan.Expr

func (*InnerJoin) GetTypes 

func (m *InnerJoin) GetTypes() []*plan.Type

func (*InnerJoin) Marshal 

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

func (*InnerJoin) MarshalTo 

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

func (*InnerJoin) MarshalToSizedBuffer 

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

func (*InnerJoin) ProtoMessage 

func (*InnerJoin) ProtoMessage()

func (*InnerJoin) ProtoSize 

func (m *InnerJoin) ProtoSize() (n int)

func (*InnerJoin) Reset 

func (m *InnerJoin) Reset()

func (*InnerJoin) String 

func (m *InnerJoin) String() string

func (*InnerJoin) Unmarshal 

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

func (*InnerJoin) XXX_DiscardUnknown 

func (m *InnerJoin) XXX_DiscardUnknown()

func (*InnerJoin) XXX_Marshal 

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

func (*InnerJoin) XXX_Merge 

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

func (*InnerJoin) XXX_Size 

func (m *InnerJoin) XXX_Size() int

func (*InnerJoin) XXX_Unmarshal 

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

type Instruction 

type Instruction struct {
	// Op specified the operator code of an instruction.
	Op int32 `protobuf:"varint,1,opt,name=op,proto3" json:"op,omitempty"`
	// Idx specified the anaylze information index.
	Idx                  int32               `protobuf:"varint,2,opt,name=idx,proto3" json:"idx,omitempty"`
	Anti                 *AntiJoin           `protobuf:"bytes,3,opt,name=anti,proto3" json:"anti,omitempty"`
	Connect              *Connector          `protobuf:"bytes,4,opt,name=connect,proto3" json:"connect,omitempty"`
	Dispatch             *Dispatch           `protobuf:"bytes,5,opt,name=dispatch,proto3" json:"dispatch,omitempty"`
	Agg                  *Group              `protobuf:"bytes,6,opt,name=agg,proto3" json:"agg,omitempty"`
	InnerJoin            *InnerJoin          `protobuf:"bytes,7,opt,name=inner_join,json=innerJoin,proto3" json:"inner_join,omitempty"`
	LeftJoin             *LeftJoin           `protobuf:"bytes,8,opt,name=left_join,json=leftJoin,proto3" json:"left_join,omitempty"`
	SemiJoin             *SemiJoin           `protobuf:"bytes,9,opt,name=semi_join,json=semiJoin,proto3" json:"semi_join,omitempty"`
	SingleJoin           *SingleJoin         `protobuf:"bytes,10,opt,name=single_join,json=singleJoin,proto3" json:"single_join,omitempty"`
	MarkJoin             *MarkJoin           `protobuf:"bytes,11,opt,name=mark_join,json=markJoin,proto3" json:"mark_join,omitempty"`
	Join                 *Join               `protobuf:"bytes,12,opt,name=join,proto3" json:"join,omitempty"`
	Product              *Product            `protobuf:"bytes,13,opt,name=product,proto3" json:"product,omitempty"`
	TableFunction        *TableFunction      `protobuf:"bytes,14,opt,name=table_function,json=tableFunction,proto3" json:"table_function,omitempty"`
	HashBuild            *HashBuild          `protobuf:"bytes,15,opt,name=hash_build,json=hashBuild,proto3" json:"hash_build,omitempty"`
	ExternalScan         *ExternalScan       `protobuf:"bytes,16,opt,name=external_scan,json=externalScan,proto3" json:"external_scan,omitempty"`
	OrderBy              []*plan.OrderBySpec `protobuf:"bytes,17,rep,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	ProjectList          []*plan.Expr        `protobuf:"bytes,18,rep,name=project_list,json=projectList,proto3" json:"project_list,omitempty"`
	Filter               *plan.Expr          `protobuf:"bytes,19,opt,name=filter,proto3" json:"filter,omitempty"`
	Limit                uint64              `protobuf:"varint,20,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               uint64              `protobuf:"varint,21,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Instruction) Descriptor 

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

func (*Instruction) GetAgg 

func (m *Instruction) GetAgg() *Group

func (*Instruction) GetAnti 

func (m *Instruction) GetAnti() *AntiJoin

func (*Instruction) GetConnect 

func (m *Instruction) GetConnect() *Connector

func (*Instruction) GetDispatch 

func (m *Instruction) GetDispatch() *Dispatch

func (*Instruction) GetExternalScan 

func (m *Instruction) GetExternalScan() *ExternalScan

func (*Instruction) GetFilter 

func (m *Instruction) GetFilter() *plan.Expr

func (*Instruction) GetHashBuild 

func (m *Instruction) GetHashBuild() *HashBuild

func (*Instruction) GetIdx 

func (m *Instruction) GetIdx() int32

func (*Instruction) GetInnerJoin 

func (m *Instruction) GetInnerJoin() *InnerJoin

func (*Instruction) GetJoin 

func (m *Instruction) GetJoin() *Join

func (*Instruction) GetLeftJoin 

func (m *Instruction) GetLeftJoin() *LeftJoin

func (*Instruction) GetLimit 

func (m *Instruction) GetLimit() uint64

func (*Instruction) GetMarkJoin 

func (m *Instruction) GetMarkJoin() *MarkJoin

func (*Instruction) GetOffset 

func (m *Instruction) GetOffset() uint64

func (*Instruction) GetOp 

func (m *Instruction) GetOp() int32

func (*Instruction) GetOrderBy 

func (m *Instruction) GetOrderBy() []*plan.OrderBySpec

func (*Instruction) GetProduct 

func (m *Instruction) GetProduct() *Product

func (*Instruction) GetProjectList 

func (m *Instruction) GetProjectList() []*plan.Expr

func (*Instruction) GetSemiJoin 

func (m *Instruction) GetSemiJoin() *SemiJoin

func (*Instruction) GetSingleJoin 

func (m *Instruction) GetSingleJoin() *SingleJoin

func (*Instruction) GetTableFunction 

func (m *Instruction) GetTableFunction() *TableFunction

func (*Instruction) Marshal 

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

func (*Instruction) MarshalTo 

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

func (*Instruction) MarshalToSizedBuffer 

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

func (*Instruction) ProtoMessage 

func (*Instruction) ProtoMessage()

func (*Instruction) ProtoSize 

func (m *Instruction) ProtoSize() (n int)

func (*Instruction) Reset 

func (m *Instruction) Reset()

func (*Instruction) String 

func (m *Instruction) String() string

func (*Instruction) Unmarshal 

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

func (*Instruction) XXX_DiscardUnknown 

func (m *Instruction) XXX_DiscardUnknown()

func (*Instruction) XXX_Marshal 

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

func (*Instruction) XXX_Merge 

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

func (*Instruction) XXX_Size 

func (m *Instruction) XXX_Size() int

func (*Instruction) XXX_Unmarshal 

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

type Join 

type Join struct {
	Ibucket              uint64       `protobuf:"varint,1,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,2,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	RelList              []int32      `protobuf:"varint,3,rep,packed,name=rel_list,json=relList,proto3" json:"rel_list,omitempty"`
	ColList              []int32      `protobuf:"varint,4,rep,packed,name=col_list,json=colList,proto3" json:"col_list,omitempty"`
	Expr                 *plan.Expr   `protobuf:"bytes,5,opt,name=expr,proto3" json:"expr,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,6,rep,name=types,proto3" json:"types,omitempty"`
	LeftCond             []*plan.Expr `protobuf:"bytes,7,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond            []*plan.Expr `protobuf:"bytes,8,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Join) Descriptor 

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

func (*Join) GetColList 

func (m *Join) GetColList() []int32

func (*Join) GetExpr 

func (m *Join) GetExpr() *plan.Expr

func (*Join) GetIbucket 

func (m *Join) GetIbucket() uint64

func (*Join) GetLeftCond 

func (m *Join) GetLeftCond() []*plan.Expr

func (*Join) GetNbucket 

func (m *Join) GetNbucket() uint64

func (*Join) GetRelList 

func (m *Join) GetRelList() []int32

func (*Join) GetRightCond 

func (m *Join) GetRightCond() []*plan.Expr

func (*Join) GetTypes 

func (m *Join) GetTypes() []*plan.Type

func (*Join) Marshal 

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

func (*Join) MarshalTo 

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

func (*Join) MarshalToSizedBuffer 

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

func (*Join) ProtoMessage 

func (*Join) ProtoMessage()

func (*Join) ProtoSize 

func (m *Join) ProtoSize() (n int)

func (*Join) Reset 

func (m *Join) Reset()

func (*Join) String 

func (m *Join) String() string

func (*Join) Unmarshal 

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

func (*Join) XXX_DiscardUnknown 

func (m *Join) XXX_DiscardUnknown()

func (*Join) XXX_Marshal 

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

func (*Join) XXX_Merge 

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

func (*Join) XXX_Size 

func (m *Join) XXX_Size() int

func (*Join) XXX_Unmarshal 

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

type LeftJoin 

type LeftJoin struct {
	Ibucket              uint64       `protobuf:"varint,1,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,2,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	RelList              []int32      `protobuf:"varint,3,rep,packed,name=rel_list,json=relList,proto3" json:"rel_list,omitempty"`
	ColList              []int32      `protobuf:"varint,4,rep,packed,name=col_list,json=colList,proto3" json:"col_list,omitempty"`
	Expr                 *plan.Expr   `protobuf:"bytes,5,opt,name=expr,proto3" json:"expr,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,6,rep,name=types,proto3" json:"types,omitempty"`
	LeftCond             []*plan.Expr `protobuf:"bytes,7,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond            []*plan.Expr `protobuf:"bytes,8,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*LeftJoin) Descriptor 

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

func (*LeftJoin) GetColList 

func (m *LeftJoin) GetColList() []int32

func (*LeftJoin) GetExpr 

func (m *LeftJoin) GetExpr() *plan.Expr

func (*LeftJoin) GetIbucket 

func (m *LeftJoin) GetIbucket() uint64

func (*LeftJoin) GetLeftCond 

func (m *LeftJoin) GetLeftCond() []*plan.Expr

func (*LeftJoin) GetNbucket 

func (m *LeftJoin) GetNbucket() uint64

func (*LeftJoin) GetRelList 

func (m *LeftJoin) GetRelList() []int32

func (*LeftJoin) GetRightCond 

func (m *LeftJoin) GetRightCond() []*plan.Expr

func (*LeftJoin) GetTypes 

func (m *LeftJoin) GetTypes() []*plan.Type

func (*LeftJoin) Marshal 

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

func (*LeftJoin) MarshalTo 

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

func (*LeftJoin) MarshalToSizedBuffer 

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

func (*LeftJoin) ProtoMessage 

func (*LeftJoin) ProtoMessage()

func (*LeftJoin) ProtoSize 

func (m *LeftJoin) ProtoSize() (n int)

func (*LeftJoin) Reset 

func (m *LeftJoin) Reset()

func (*LeftJoin) String 

func (m *LeftJoin) String() string

func (*LeftJoin) Unmarshal 

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

func (*LeftJoin) XXX_DiscardUnknown 

func (m *LeftJoin) XXX_DiscardUnknown()

func (*LeftJoin) XXX_Marshal 

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

func (*LeftJoin) XXX_Merge 

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

func (*LeftJoin) XXX_Size 

func (m *LeftJoin) XXX_Size() int

func (*LeftJoin) XXX_Unmarshal 

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

type MarkJoin 

type MarkJoin struct {
	Ibucket              uint64       `protobuf:"varint,1,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,2,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	Result               []int32      `protobuf:"varint,3,rep,packed,name=result,proto3" json:"result,omitempty"`
	LeftCond             []*plan.Expr `protobuf:"bytes,4,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond            []*plan.Expr `protobuf:"bytes,5,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,6,rep,name=types,proto3" json:"types,omitempty"`
	Cond                 *plan.Expr   `protobuf:"bytes,7,opt,name=cond,proto3" json:"cond,omitempty"`
	OnList               []*plan.Expr `protobuf:"bytes,8,rep,name=on_list,json=onList,proto3" json:"on_list,omitempty"`
	OutputNull           bool         `protobuf:"varint,9,opt,name=output_null,json=outputNull,proto3" json:"output_null,omitempty"`
	OutputMark           bool         `protobuf:"varint,10,opt,name=output_mark,json=outputMark,proto3" json:"output_mark,omitempty"`
	OutputAnyway         bool         `protobuf:"varint,11,opt,name=output_anyway,json=outputAnyway,proto3" json:"output_anyway,omitempty"`
	MarkMeaning          bool         `protobuf:"varint,12,opt,name=mark_meaning,json=markMeaning,proto3" json:"mark_meaning,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MarkJoin) Descriptor 

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

func (*MarkJoin) GetCond 

func (m *MarkJoin) GetCond() *plan.Expr

func (*MarkJoin) GetIbucket 

func (m *MarkJoin) GetIbucket() uint64

func (*MarkJoin) GetLeftCond 

func (m *MarkJoin) GetLeftCond() []*plan.Expr

func (*MarkJoin) GetMarkMeaning 

func (m *MarkJoin) GetMarkMeaning() bool

func (*MarkJoin) GetNbucket 

func (m *MarkJoin) GetNbucket() uint64

func (*MarkJoin) GetOnList 

func (m *MarkJoin) GetOnList() []*plan.Expr

func (*MarkJoin) GetOutputAnyway 

func (m *MarkJoin) GetOutputAnyway() bool

func (*MarkJoin) GetOutputMark 

func (m *MarkJoin) GetOutputMark() bool

func (*MarkJoin) GetOutputNull 

func (m *MarkJoin) GetOutputNull() bool

func (*MarkJoin) GetResult 

func (m *MarkJoin) GetResult() []int32

func (*MarkJoin) GetRightCond 

func (m *MarkJoin) GetRightCond() []*plan.Expr

func (*MarkJoin) GetTypes 

func (m *MarkJoin) GetTypes() []*plan.Type

func (*MarkJoin) Marshal 

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

func (*MarkJoin) MarshalTo 

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

func (*MarkJoin) MarshalToSizedBuffer 

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

func (*MarkJoin) ProtoMessage 

func (*MarkJoin) ProtoMessage()

func (*MarkJoin) ProtoSize 

func (m *MarkJoin) ProtoSize() (n int)

func (*MarkJoin) Reset 

func (m *MarkJoin) Reset()

func (*MarkJoin) String 

func (m *MarkJoin) String() string

func (*MarkJoin) Unmarshal 

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

func (*MarkJoin) XXX_DiscardUnknown 

func (m *MarkJoin) XXX_DiscardUnknown()

func (*MarkJoin) XXX_Marshal 

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

func (*MarkJoin) XXX_Merge 

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

func (*MarkJoin) XXX_Size 

func (m *MarkJoin) XXX_Size() int

func (*MarkJoin) XXX_Unmarshal 

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

type Message 

type Message struct {
	Sid                  uint64   `protobuf:"varint,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Cmd                  uint64   `protobuf:"varint,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Err                  []byte   `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
	Data                 []byte   `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	ProcInfoData         []byte   `protobuf:"bytes,5,opt,name=proc_info_data,json=procInfoData,proto3" json:"proc_info_data,omitempty"`
	Analyse              []byte   `protobuf:"bytes,6,opt,name=analyse,proto3" json:"analyse,omitempty"`
	Id                   uint64   `protobuf:"varint,7,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) DebugString 

func (m *Message) DebugString() string

func (*Message) Descriptor 

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

func (*Message) GetAnalyse 

func (m *Message) GetAnalyse() []byte

func (*Message) GetCmd 

func (m *Message) GetCmd() uint64

func (*Message) GetData 

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

func (*Message) GetErr 

func (m *Message) GetErr() []byte

func (*Message) GetID 

func (m *Message) GetID() uint64

func (*Message) GetId 

func (m *Message) GetId() uint64

func (*Message) GetProcInfoData 

func (m *Message) GetProcInfoData() []byte

func (*Message) GetSid 

func (m *Message) GetSid() uint64

func (*Message) IsEndMessage 

func (m *Message) IsEndMessage() bool

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoSize 

func (m *Message) ProtoSize() (n int)

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) SetID 

func (m *Message) SetID(id uint64)

func (*Message) Size 

func (m *Message) Size() int

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type NodeInfo 

type NodeInfo struct {
	Mcpu                 int32    `protobuf:"varint,1,opt,name=mcpu,proto3" json:"mcpu,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Addr                 string   `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Payload              []string `protobuf:"bytes,4,rep,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetAddr 

func (m *NodeInfo) GetAddr() string

func (*NodeInfo) GetId 

func (m *NodeInfo) GetId() string

func (*NodeInfo) GetMcpu 

func (m *NodeInfo) GetMcpu() int32

func (*NodeInfo) GetPayload 

func (m *NodeInfo) GetPayload() []string

func (*NodeInfo) Marshal 

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

func (*NodeInfo) MarshalTo 

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

func (*NodeInfo) MarshalToSizedBuffer 

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

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoSize 

func (m *NodeInfo) ProtoSize() (n int)

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal 

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

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

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

func (*NodeInfo) XXX_Merge 

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

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

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

type Pipeline 

type Pipeline struct {
	PipelineType         Pipeline_PipelineType `` /* 134-byte string literal not displayed */
	PipelineId           int32                 `protobuf:"varint,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Qry                  *plan.Plan            `protobuf:"bytes,3,opt,name=qry,proto3" json:"qry,omitempty"`
	DataSource           *Source               `protobuf:"bytes,4,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	Children             []*Pipeline           `protobuf:"bytes,5,rep,name=children,proto3" json:"children,omitempty"`
	InstructionList      []*Instruction        `protobuf:"bytes,6,rep,name=instruction_list,json=instructionList,proto3" json:"instruction_list,omitempty"`
	IsEnd                bool                  `protobuf:"varint,7,opt,name=is_end,json=isEnd,proto3" json:"is_end,omitempty"`
	IsJoin               bool                  `protobuf:"varint,8,opt,name=is_join,json=isJoin,proto3" json:"is_join,omitempty"`
	Node                 *NodeInfo             `protobuf:"bytes,9,opt,name=node,proto3" json:"node,omitempty"`
	PushDownInfo         int32                 `protobuf:"varint,10,opt,name=push_down_info,json=pushDownInfo,proto3" json:"push_down_info,omitempty"`
	ChildrenCount        int32                 `protobuf:"varint,11,opt,name=children_count,json=childrenCount,proto3" json:"children_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Pipeline) Descriptor 

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

func (*Pipeline) GetChildren 

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

func (*Pipeline) GetChildrenCount 

func (m *Pipeline) GetChildrenCount() int32

func (*Pipeline) GetDataSource 

func (m *Pipeline) GetDataSource() *Source

func (*Pipeline) GetInstructionList 

func (m *Pipeline) GetInstructionList() []*Instruction

func (*Pipeline) GetIsEnd 

func (m *Pipeline) GetIsEnd() bool

func (*Pipeline) GetIsJoin 

func (m *Pipeline) GetIsJoin() bool

func (*Pipeline) GetNode 

func (m *Pipeline) GetNode() *NodeInfo

func (*Pipeline) GetPipelineId 

func (m *Pipeline) GetPipelineId() int32

func (*Pipeline) GetPipelineType 

func (m *Pipeline) GetPipelineType() Pipeline_PipelineType

func (*Pipeline) GetPushDownInfo 

func (m *Pipeline) GetPushDownInfo() int32

func (*Pipeline) GetQry 

func (m *Pipeline) GetQry() *plan.Plan

func (*Pipeline) Marshal 

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

func (*Pipeline) MarshalTo 

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

func (*Pipeline) MarshalToSizedBuffer 

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

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) ProtoSize 

func (m *Pipeline) ProtoSize() (n int)

func (*Pipeline) Reset 

func (m *Pipeline) Reset()

func (*Pipeline) String 

func (m *Pipeline) String() string

func (*Pipeline) Unmarshal 

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

func (*Pipeline) XXX_DiscardUnknown 

func (m *Pipeline) XXX_DiscardUnknown()

func (*Pipeline) XXX_Marshal 

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

func (*Pipeline) XXX_Merge 

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

func (*Pipeline) XXX_Size 

func (m *Pipeline) XXX_Size() int

func (*Pipeline) XXX_Unmarshal 

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

type Pipeline_PipelineType 

type Pipeline_PipelineType int32
const (
	Pipeline_Merge    Pipeline_PipelineType = 0
	Pipeline_Normal   Pipeline_PipelineType = 1
	Pipeline_Remote   Pipeline_PipelineType = 2
	Pipeline_Parallel Pipeline_PipelineType = 3
)

func (Pipeline_PipelineType) EnumDescriptor 

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

func (Pipeline_PipelineType) String 

func (x Pipeline_PipelineType) String() string

type ProcessInfo 

type ProcessInfo struct {
	Id                   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Lim                  *ProcessLimitation `protobuf:"bytes,2,opt,name=lim,proto3" json:"lim,omitempty"`
	UnixTime             int64              `protobuf:"varint,3,opt,name=unix_time,json=unixTime,proto3" json:"unix_time,omitempty"`
	Snapshot             string             `protobuf:"bytes,4,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	SessionInfo          *SessionInfo       `protobuf:"bytes,5,opt,name=session_info,json=sessionInfo,proto3" json:"session_info,omitempty"`
	AnalysisNodeList     []int32            `protobuf:"varint,6,rep,packed,name=analysis_node_list,json=analysisNodeList,proto3" json:"analysis_node_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ProcessInfo) Descriptor 

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

func (*ProcessInfo) GetAnalysisNodeList 

func (m *ProcessInfo) GetAnalysisNodeList() []int32

func (*ProcessInfo) GetId 

func (m *ProcessInfo) GetId() string

func (*ProcessInfo) GetLim 

func (m *ProcessInfo) GetLim() *ProcessLimitation

func (*ProcessInfo) GetSessionInfo 

func (m *ProcessInfo) GetSessionInfo() *SessionInfo

func (*ProcessInfo) GetSnapshot 

func (m *ProcessInfo) GetSnapshot() string

func (*ProcessInfo) GetUnixTime 

func (m *ProcessInfo) GetUnixTime() int64

func (*ProcessInfo) Marshal 

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

func (*ProcessInfo) MarshalTo 

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

func (*ProcessInfo) MarshalToSizedBuffer 

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

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoSize 

func (m *ProcessInfo) ProtoSize() (n int)

func (*ProcessInfo) Reset 

func (m *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (m *ProcessInfo) String() string

func (*ProcessInfo) Unmarshal 

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

func (*ProcessInfo) XXX_DiscardUnknown 

func (m *ProcessInfo) XXX_DiscardUnknown()

func (*ProcessInfo) XXX_Marshal 

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

func (*ProcessInfo) XXX_Merge 

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

func (*ProcessInfo) XXX_Size 

func (m *ProcessInfo) XXX_Size() int

func (*ProcessInfo) XXX_Unmarshal 

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

type ProcessLimitation 

type ProcessLimitation struct {
	Size                 int64    `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	BatchRows            int64    `protobuf:"varint,2,opt,name=batch_rows,json=batchRows,proto3" json:"batch_rows,omitempty"`
	BatchSize            int64    `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	PartitionRows        int64    `protobuf:"varint,4,opt,name=partition_rows,json=partitionRows,proto3" json:"partition_rows,omitempty"`
	ReaderSize           int64    `protobuf:"varint,5,opt,name=reader_size,json=readerSize,proto3" json:"reader_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessLimitation) Descriptor 

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

func (*ProcessLimitation) GetBatchRows 

func (m *ProcessLimitation) GetBatchRows() int64

func (*ProcessLimitation) GetBatchSize 

func (m *ProcessLimitation) GetBatchSize() int64

func (*ProcessLimitation) GetPartitionRows 

func (m *ProcessLimitation) GetPartitionRows() int64

func (*ProcessLimitation) GetReaderSize 

func (m *ProcessLimitation) GetReaderSize() int64

func (*ProcessLimitation) GetSize 

func (m *ProcessLimitation) GetSize() int64

func (*ProcessLimitation) Marshal 

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

func (*ProcessLimitation) MarshalTo 

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

func (*ProcessLimitation) MarshalToSizedBuffer 

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

func (*ProcessLimitation) ProtoMessage 

func (*ProcessLimitation) ProtoMessage()

func (*ProcessLimitation) ProtoSize 

func (m *ProcessLimitation) ProtoSize() (n int)

func (*ProcessLimitation) Reset 

func (m *ProcessLimitation) Reset()

func (*ProcessLimitation) String 

func (m *ProcessLimitation) String() string

func (*ProcessLimitation) Unmarshal 

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

func (*ProcessLimitation) XXX_DiscardUnknown 

func (m *ProcessLimitation) XXX_DiscardUnknown()

func (*ProcessLimitation) XXX_Marshal 

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

func (*ProcessLimitation) XXX_Merge 

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

func (*ProcessLimitation) XXX_Size 

func (m *ProcessLimitation) XXX_Size() int

func (*ProcessLimitation) XXX_Unmarshal 

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

type Product 

type Product struct {
	RelList              []int32      `protobuf:"varint,1,rep,packed,name=rel_list,json=relList,proto3" json:"rel_list,omitempty"`
	ColList              []int32      `protobuf:"varint,2,rep,packed,name=col_list,json=colList,proto3" json:"col_list,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,3,rep,name=types,proto3" json:"types,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Product) Descriptor 

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

func (*Product) GetColList 

func (m *Product) GetColList() []int32

func (*Product) GetRelList 

func (m *Product) GetRelList() []int32

func (*Product) GetTypes 

func (m *Product) GetTypes() []*plan.Type

func (*Product) Marshal 

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

func (*Product) MarshalTo 

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

func (*Product) MarshalToSizedBuffer 

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

func (*Product) ProtoMessage 

func (*Product) ProtoMessage()

func (*Product) ProtoSize 

func (m *Product) ProtoSize() (n int)

func (*Product) Reset 

func (m *Product) Reset()

func (*Product) String 

func (m *Product) String() string

func (*Product) Unmarshal 

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

func (*Product) XXX_DiscardUnknown 

func (m *Product) XXX_DiscardUnknown()

func (*Product) XXX_Marshal 

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

func (*Product) XXX_Merge 

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

func (*Product) XXX_Size 

func (m *Product) XXX_Size() int

func (*Product) XXX_Unmarshal 

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

type SemiJoin 

type SemiJoin struct {
	Ibucket              uint64       `protobuf:"varint,1,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,2,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	Result               []int32      `protobuf:"varint,3,rep,packed,name=result,proto3" json:"result,omitempty"`
	Expr                 *plan.Expr   `protobuf:"bytes,4,opt,name=expr,proto3" json:"expr,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,5,rep,name=types,proto3" json:"types,omitempty"`
	LeftCond             []*plan.Expr `protobuf:"bytes,6,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond            []*plan.Expr `protobuf:"bytes,7,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SemiJoin) Descriptor 

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

func (*SemiJoin) GetExpr 

func (m *SemiJoin) GetExpr() *plan.Expr

func (*SemiJoin) GetIbucket 

func (m *SemiJoin) GetIbucket() uint64

func (*SemiJoin) GetLeftCond 

func (m *SemiJoin) GetLeftCond() []*plan.Expr

func (*SemiJoin) GetNbucket 

func (m *SemiJoin) GetNbucket() uint64

func (*SemiJoin) GetResult 

func (m *SemiJoin) GetResult() []int32

func (*SemiJoin) GetRightCond 

func (m *SemiJoin) GetRightCond() []*plan.Expr

func (*SemiJoin) GetTypes 

func (m *SemiJoin) GetTypes() []*plan.Type

func (*SemiJoin) Marshal 

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

func (*SemiJoin) MarshalTo 

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

func (*SemiJoin) MarshalToSizedBuffer 

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

func (*SemiJoin) ProtoMessage 

func (*SemiJoin) ProtoMessage()

func (*SemiJoin) ProtoSize 

func (m *SemiJoin) ProtoSize() (n int)

func (*SemiJoin) Reset 

func (m *SemiJoin) Reset()

func (*SemiJoin) String 

func (m *SemiJoin) String() string

func (*SemiJoin) Unmarshal 

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

func (*SemiJoin) XXX_DiscardUnknown 

func (m *SemiJoin) XXX_DiscardUnknown()

func (*SemiJoin) XXX_Marshal 

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

func (*SemiJoin) XXX_Merge 

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

func (*SemiJoin) XXX_Size 

func (m *SemiJoin) XXX_Size() int

func (*SemiJoin) XXX_Unmarshal 

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

type SessionInfo 

type SessionInfo struct {
	User                 string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Role                 string   `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	ConnectionId         uint64   `protobuf:"varint,4,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Database             string   `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
	Version              string   `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	TimeZone             []byte   `protobuf:"bytes,7,opt,name=time_zone,json=timeZone,proto3" json:"time_zone,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SessionInfo) Descriptor 

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

func (*SessionInfo) GetConnectionId 

func (m *SessionInfo) GetConnectionId() uint64

func (*SessionInfo) GetDatabase 

func (m *SessionInfo) GetDatabase() string

func (*SessionInfo) GetHost 

func (m *SessionInfo) GetHost() string

func (*SessionInfo) GetRole 

func (m *SessionInfo) GetRole() string

func (*SessionInfo) GetTimeZone 

func (m *SessionInfo) GetTimeZone() []byte

func (*SessionInfo) GetUser 

func (m *SessionInfo) GetUser() string

func (*SessionInfo) GetVersion 

func (m *SessionInfo) GetVersion() string

func (*SessionInfo) Marshal 

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

func (*SessionInfo) MarshalTo 

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

func (*SessionInfo) MarshalToSizedBuffer 

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

func (*SessionInfo) ProtoMessage 

func (*SessionInfo) ProtoMessage()

func (*SessionInfo) ProtoSize 

func (m *SessionInfo) ProtoSize() (n int)

func (*SessionInfo) Reset 

func (m *SessionInfo) Reset()

func (*SessionInfo) String 

func (m *SessionInfo) String() string

func (*SessionInfo) Unmarshal 

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

func (*SessionInfo) XXX_DiscardUnknown 

func (m *SessionInfo) XXX_DiscardUnknown()

func (*SessionInfo) XXX_Marshal 

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

func (*SessionInfo) XXX_Merge 

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

func (*SessionInfo) XXX_Size 

func (m *SessionInfo) XXX_Size() int

func (*SessionInfo) XXX_Unmarshal 

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

type SingleJoin 

type SingleJoin struct {
	Ibucket              uint64       `protobuf:"varint,1,opt,name=ibucket,proto3" json:"ibucket,omitempty"`
	Nbucket              uint64       `protobuf:"varint,2,opt,name=nbucket,proto3" json:"nbucket,omitempty"`
	RelList              []int32      `protobuf:"varint,3,rep,packed,name=rel_list,json=relList,proto3" json:"rel_list,omitempty"`
	ColList              []int32      `protobuf:"varint,4,rep,packed,name=col_list,json=colList,proto3" json:"col_list,omitempty"`
	Expr                 *plan.Expr   `protobuf:"bytes,5,opt,name=expr,proto3" json:"expr,omitempty"`
	Types                []*plan.Type `protobuf:"bytes,6,rep,name=types,proto3" json:"types,omitempty"`
	LeftCond             []*plan.Expr `protobuf:"bytes,7,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond            []*plan.Expr `protobuf:"bytes,8,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SingleJoin) Descriptor 

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

func (*SingleJoin) GetColList 

func (m *SingleJoin) GetColList() []int32

func (*SingleJoin) GetExpr 

func (m *SingleJoin) GetExpr() *plan.Expr

func (*SingleJoin) GetIbucket 

func (m *SingleJoin) GetIbucket() uint64

func (*SingleJoin) GetLeftCond 

func (m *SingleJoin) GetLeftCond() []*plan.Expr

func (*SingleJoin) GetNbucket 

func (m *SingleJoin) GetNbucket() uint64

func (*SingleJoin) GetRelList 

func (m *SingleJoin) GetRelList() []int32

func (*SingleJoin) GetRightCond 

func (m *SingleJoin) GetRightCond() []*plan.Expr

func (*SingleJoin) GetTypes 

func (m *SingleJoin) GetTypes() []*plan.Type

func (*SingleJoin) Marshal 

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

func (*SingleJoin) MarshalTo 

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

func (*SingleJoin) MarshalToSizedBuffer 

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

func (*SingleJoin) ProtoMessage 

func (*SingleJoin) ProtoMessage()

func (*SingleJoin) ProtoSize 

func (m *SingleJoin) ProtoSize() (n int)

func (*SingleJoin) Reset 

func (m *SingleJoin) Reset()

func (*SingleJoin) String 

func (m *SingleJoin) String() string

func (*SingleJoin) Unmarshal 

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

func (*SingleJoin) XXX_DiscardUnknown 

func (m *SingleJoin) XXX_DiscardUnknown()

func (*SingleJoin) XXX_Marshal 

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

func (*SingleJoin) XXX_Merge 

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

func (*SingleJoin) XXX_Size 

func (m *SingleJoin) XXX_Size() int

func (*SingleJoin) XXX_Unmarshal 

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

type Source 

type Source struct {
	SchemaName           string               `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	TableName            string               `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColList              []string             `protobuf:"bytes,3,rep,name=col_list,json=colList,proto3" json:"col_list,omitempty"`
	Block                string               `protobuf:"bytes,4,opt,name=block,proto3" json:"block,omitempty"`
	PushdownId           uint64               `protobuf:"varint,5,opt,name=pushdown_id,json=pushdownId,proto3" json:"pushdown_id,omitempty"`
	PushdownAddr         string               `protobuf:"bytes,6,opt,name=pushdown_addr,json=pushdownAddr,proto3" json:"pushdown_addr,omitempty"`
	Expr                 *plan.Expr           `protobuf:"bytes,7,opt,name=expr,proto3" json:"expr,omitempty"`
	TableDef             *plan.TableDef       `protobuf:"bytes,8,opt,name=tableDef,proto3" json:"tableDef,omitempty"`
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Source) Descriptor 

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

func (*Source) GetBlock 

func (m *Source) GetBlock() string

func (*Source) GetColList 

func (m *Source) GetColList() []string

func (*Source) GetExpr 

func (m *Source) GetExpr() *plan.Expr

func (*Source) GetPushdownAddr 

func (m *Source) GetPushdownAddr() string

func (*Source) GetPushdownId 

func (m *Source) GetPushdownId() uint64

func (*Source) GetSchemaName 

func (m *Source) GetSchemaName() string

func (*Source) GetTableDef 

func (m *Source) GetTableDef() *plan.TableDef

func (*Source) GetTableName 

func (m *Source) GetTableName() string

func (*Source) GetTimestamp 

func (m *Source) GetTimestamp() *timestamp.Timestamp

func (*Source) Marshal 

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

func (*Source) MarshalTo 

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

func (*Source) MarshalToSizedBuffer 

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

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoSize 

func (m *Source) ProtoSize() (n int)

func (*Source) Reset 

func (m *Source) Reset()

func (*Source) String 

func (m *Source) String() string

func (*Source) Unmarshal 

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

func (*Source) XXX_DiscardUnknown 

func (m *Source) XXX_DiscardUnknown()

func (*Source) XXX_Marshal 

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

func (*Source) XXX_Merge 

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

func (*Source) XXX_Size 

func (m *Source) XXX_Size() int

func (*Source) XXX_Unmarshal 

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

type TableFunction 

type TableFunction struct {
	Attrs                []string       `protobuf:"bytes,1,rep,name=attrs,proto3" json:"attrs,omitempty"`
	Cols                 []*plan.ColDef `protobuf:"bytes,2,rep,name=cols,proto3" json:"cols,omitempty"`
	Exprs                []*plan.Expr   `protobuf:"bytes,3,rep,name=exprs,proto3" json:"exprs,omitempty"`
	Param                []byte         `protobuf:"bytes,4,opt,name=param,proto3" json:"param,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TableFunction) Descriptor 

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

func (*TableFunction) GetAttrs 

func (m *TableFunction) GetAttrs() []string

func (*TableFunction) GetCols 

func (m *TableFunction) GetCols() []*plan.ColDef

func (*TableFunction) GetExprs 

func (m *TableFunction) GetExprs() []*plan.Expr

func (*TableFunction) GetParam 

func (m *TableFunction) GetParam() []byte

func (*TableFunction) Marshal 

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

func (*TableFunction) MarshalTo 

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

func (*TableFunction) MarshalToSizedBuffer 

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

func (*TableFunction) ProtoMessage 

func (*TableFunction) ProtoMessage()

func (*TableFunction) ProtoSize 

func (m *TableFunction) ProtoSize() (n int)

func (*TableFunction) Reset 

func (m *TableFunction) Reset()

func (*TableFunction) String 

func (m *TableFunction) String() string

func (*TableFunction) Unmarshal 

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

func (*TableFunction) XXX_DiscardUnknown 

func (m *TableFunction) XXX_DiscardUnknown()

func (*TableFunction) XXX_Marshal 

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

func (*TableFunction) XXX_Merge 

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

func (*TableFunction) XXX_Size 

func (m *TableFunction) XXX_Size() int

func (*TableFunction) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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