pipeline

package
v1.0.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// For cmd. Basic message type
	UnknowType = iota
	PipelineMessage
	BatchMessage
	PrepareDoneNotifyMessage // for dispatch

	// For Sid. Status type
	WaitingNext
	Last
	MessageEnd
)

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,
}
View Source 
var RuntimeFilter_RuntimeFilterType_name = map[int32]string{
	0:   "IN",
	1:   "BITMAP",
	2:   "MIN_MAX",
	3:   "BINARY_FUSE",
	100: "PASS",
	101: "DROP",
}
View Source 
var RuntimeFilter_RuntimeFilterType_value = map[string]int32{
	"IN":          0,
	"BITMAP":      1,
	"MIN_MAX":     2,
	"BINARY_FUSE": 3,
	"PASS":        100,
	"DROP":        101,
}

Functions

func EncodedMessageError 

func EncodedMessageError(ctx context.Context, err error) []byte

func GetMessageErrorInfo added in v0.7.0 

func GetMessageErrorInfo(m *Message) error

Types

type Aggregate 

type Aggregate struct {
	Op                   int64      `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"`
	Config               []byte     `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Aggregate) Descriptor 

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

func (*Aggregate) GetConfig added in v1.0.0 

func (m *Aggregate) GetConfig() []byte

func (*Aggregate) GetDist 

func (m *Aggregate) GetDist() bool

func (*Aggregate) GetExpr 

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

func (*Aggregate) GetOp 

func (m *Aggregate) GetOp() int64

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 Array added in v0.8.0 

type Array struct {
	Array                []int32  `protobuf:"varint,1,rep,packed,name=array,proto3" json:"array,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Array) Descriptor added in v0.8.0 

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

func (*Array) GetArray added in v0.8.0 

func (m *Array) GetArray() []int32

func (*Array) Marshal added in v0.8.0 

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

func (*Array) MarshalTo added in v0.8.0 

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

func (*Array) MarshalToSizedBuffer added in v0.8.0 

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

func (*Array) ProtoMessage added in v0.8.0 

func (*Array) ProtoMessage()

func (*Array) ProtoSize added in v0.8.0 

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

func (*Array) Reset added in v0.8.0 

func (m *Array) Reset()

func (*Array) String added in v0.8.0 

func (m *Array) String() string

func (*Array) Unmarshal added in v0.8.0 

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

func (*Array) XXX_DiscardUnknown added in v0.8.0 

func (m *Array) XXX_DiscardUnknown()

func (*Array) XXX_Marshal added in v0.8.0 

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

func (*Array) XXX_Merge added in v0.8.0 

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

func (*Array) XXX_Size added in v0.8.0 

func (m *Array) XXX_Size() int

func (*Array) XXX_Unmarshal added in v0.8.0 

func (m *Array) 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 Deletion added in v0.8.0 

type Deletion struct {
	Ts                    uint64           `protobuf:"varint,1,opt,name=Ts,proto3" json:"Ts,omitempty"`
	AffectedRows          uint64           `protobuf:"varint,2,opt,name=AffectedRows,proto3" json:"AffectedRows,omitempty"`
	RemoteDelete          bool             `protobuf:"varint,3,opt,name=RemoteDelete,proto3" json:"RemoteDelete,omitempty"`
	IBucket               uint32           `protobuf:"varint,4,opt,name=IBucket,proto3" json:"IBucket,omitempty"`
	NBucket               uint32           `protobuf:"varint,5,opt,name=NBucket,proto3" json:"NBucket,omitempty"`
	RowIdIdx              int32            `protobuf:"varint,6,opt,name=row_id_idx,json=rowIdIdx,proto3" json:"row_id_idx,omitempty"`
	PartitionTableIds     []uint64         `protobuf:"varint,7,rep,packed,name=partition_table_ids,json=partitionTableIds,proto3" json:"partition_table_ids,omitempty"`
	PartitionTableNames   []string         `protobuf:"bytes,8,rep,name=partition_table_names,json=partitionTableNames,proto3" json:"partition_table_names,omitempty"`
	PartitionIndexInBatch int32            `` /* 129-byte string literal not displayed */
	Ref                   *plan.ObjectRef  `protobuf:"bytes,10,opt,name=ref,proto3" json:"ref,omitempty"`
	AddAffectedRows       bool             `protobuf:"varint,11,opt,name=add_affected_rows,json=addAffectedRows,proto3" json:"add_affected_rows,omitempty"`
	SegmentMap            map[string]int32 `` /* 163-byte string literal not displayed */
	CanTruncate           bool             `protobuf:"varint,13,opt,name=can_truncate,json=canTruncate,proto3" json:"can_truncate,omitempty"`
	IsEnd                 bool             `protobuf:"varint,14,opt,name=is_end,json=isEnd,proto3" json:"is_end,omitempty"`
	PrimaryKeyIdx         int32            `protobuf:"varint,15,opt,name=primary_key_idx,json=primaryKeyIdx,proto3" json:"primary_key_idx,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}         `json:"-"`
	XXX_unrecognized      []byte           `json:"-"`
	XXX_sizecache         int32            `json:"-"`
}

func (*Deletion) Descriptor added in v0.8.0 

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

func (*Deletion) GetAddAffectedRows added in v0.8.0 

func (m *Deletion) GetAddAffectedRows() bool

func (*Deletion) GetAffectedRows added in v0.8.0 

func (m *Deletion) GetAffectedRows() uint64

func (*Deletion) GetCanTruncate added in v0.8.0 

func (m *Deletion) GetCanTruncate() bool

func (*Deletion) GetIBucket added in v0.8.0 

func (m *Deletion) GetIBucket() uint32

func (*Deletion) GetIsEnd added in v0.8.0 

func (m *Deletion) GetIsEnd() bool

func (*Deletion) GetNBucket added in v0.8.0 

func (m *Deletion) GetNBucket() uint32

func (*Deletion) GetPartitionIndexInBatch added in v0.8.0 

func (m *Deletion) GetPartitionIndexInBatch() int32

func (*Deletion) GetPartitionTableIds added in v0.8.0 

func (m *Deletion) GetPartitionTableIds() []uint64

func (*Deletion) GetPartitionTableNames added in v0.8.0 

func (m *Deletion) GetPartitionTableNames() []string

func (*Deletion) GetPrimaryKeyIdx added in v1.0.0 

func (m *Deletion) GetPrimaryKeyIdx() int32

func (*Deletion) GetRef added in v0.8.0 

func (m *Deletion) GetRef() *plan.ObjectRef

func (*Deletion) GetRemoteDelete added in v0.8.0 

func (m *Deletion) GetRemoteDelete() bool

func (*Deletion) GetRowIdIdx added in v0.8.0 

func (m *Deletion) GetRowIdIdx() int32

func (*Deletion) GetSegmentMap added in v0.8.0 

func (m *Deletion) GetSegmentMap() map[string]int32

func (*Deletion) GetTs added in v0.8.0 

func (m *Deletion) GetTs() uint64

func (*Deletion) Marshal added in v0.8.0 

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

func (*Deletion) MarshalTo added in v0.8.0 

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

func (*Deletion) MarshalToSizedBuffer added in v0.8.0 

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

func (*Deletion) ProtoMessage added in v0.8.0 

func (*Deletion) ProtoMessage()

func (*Deletion) ProtoSize added in v0.8.0 

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

func (*Deletion) Reset added in v0.8.0 

func (m *Deletion) Reset()

func (*Deletion) String added in v0.8.0 

func (m *Deletion) String() string

func (*Deletion) Unmarshal added in v0.8.0 

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

func (*Deletion) XXX_DiscardUnknown added in v0.8.0 

func (m *Deletion) XXX_DiscardUnknown()

func (*Deletion) XXX_Marshal added in v0.8.0 

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

func (*Deletion) XXX_Merge added in v0.8.0 

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

func (*Deletion) XXX_Size added in v0.8.0 

func (m *Deletion) XXX_Size() int

func (*Deletion) XXX_Unmarshal added in v0.8.0 

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

type Dispatch 

type Dispatch struct {
	FuncId               int32        `protobuf:"varint,1,opt,name=func_id,json=funcId,proto3" json:"func_id,omitempty"`
	LocalConnector       []*Connector `protobuf:"bytes,2,rep,name=local_connector,json=localConnector,proto3" json:"local_connector,omitempty"`
	RemoteConnector      []*WrapNode  `protobuf:"bytes,3,rep,name=remote_connector,json=remoteConnector,proto3" json:"remote_connector,omitempty"`
	ShuffleRegIdxLocal   []int32      `` /* 127-byte string literal not displayed */
	ShuffleRegIdxRemote  []int32      `` /* 130-byte string literal not displayed */
	ShuffleType          int32        `protobuf:"varint,6,opt,name=shuffle_type,json=shuffleType,proto3" json:"shuffle_type,omitempty"`
	IsSink               bool         `protobuf:"varint,7,opt,name=is_sink,json=isSink,proto3" json:"is_sink,omitempty"`
	RecSink              bool         `protobuf:"varint,8,opt,name=rec_sink,json=recSink,proto3" json:"rec_sink,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Dispatch) Descriptor 

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

func (*Dispatch) GetFuncId added in v0.7.0 

func (m *Dispatch) GetFuncId() int32

func (*Dispatch) GetIsSink added in v0.8.0 

func (m *Dispatch) GetIsSink() bool

func (*Dispatch) GetLocalConnector added in v0.7.0 

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

func (*Dispatch) GetRecSink added in v1.0.0 

func (m *Dispatch) GetRecSink() bool

func (*Dispatch) GetRemoteConnector added in v0.7.0 

func (m *Dispatch) GetRemoteConnector() []*WrapNode

func (*Dispatch) GetShuffleRegIdxLocal added in v0.8.0 

func (m *Dispatch) GetShuffleRegIdxLocal() []int32

func (*Dispatch) GetShuffleRegIdxRemote added in v0.8.0 

func (m *Dispatch) GetShuffleRegIdxRemote() []int32

func (*Dispatch) GetShuffleType added in v0.8.0 

func (m *Dispatch) GetShuffleType() int32

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"`
	FileSize             []int64                  `protobuf:"varint,2,rep,packed,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	FileOffsetTotal      []*FileOffset            `protobuf:"bytes,3,rep,name=file_offset_total,json=fileOffsetTotal,proto3" json:"file_offset_total,omitempty"`
	Cols                 []*plan.ColDef           `protobuf:"bytes,4,rep,name=cols,proto3" json:"cols,omitempty"`
	Name2ColIndex        []*ExternalName2ColIndex `protobuf:"bytes,5,rep,name=name2_col_index,json=name2ColIndex,proto3" json:"name2_col_index,omitempty"`
	CreateSql            string                   `protobuf:"bytes,6,opt,name=create_sql,json=createSql,proto3" json:"create_sql,omitempty"`
	FileList             []string                 `protobuf:"bytes,7,rep,name=file_list,json=fileList,proto3" json:"file_list,omitempty"`
	OriginCols           []*plan.ColDef           `protobuf:"bytes,8,rep,name=origin_cols,json=originCols,proto3" json:"origin_cols,omitempty"`
	Filter               *plan.Expr               `protobuf:"bytes,9,opt,name=filter,proto3" json:"filter,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) GetFileOffsetTotal added in v0.8.0 

func (m *ExternalScan) GetFileOffsetTotal() []*FileOffset

func (*ExternalScan) GetFileSize added in v0.8.0 

func (m *ExternalScan) GetFileSize() []int64

func (*ExternalScan) GetFilter added in v0.8.0 

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

func (*ExternalScan) GetName2ColIndex 

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

func (*ExternalScan) GetOriginCols added in v0.7.0 

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

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 FileOffset added in v0.8.0 

type FileOffset struct {
	Offset               []int64  `protobuf:"varint,1,rep,packed,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileOffset) Descriptor added in v0.8.0 

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

func (*FileOffset) GetOffset added in v0.8.0 

func (m *FileOffset) GetOffset() []int64

func (*FileOffset) Marshal added in v0.8.0 

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

func (*FileOffset) MarshalTo added in v0.8.0 

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

func (*FileOffset) MarshalToSizedBuffer added in v0.8.0 

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

func (*FileOffset) ProtoMessage added in v0.8.0 

func (*FileOffset) ProtoMessage()

func (*FileOffset) ProtoSize added in v0.8.0 

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

func (*FileOffset) Reset added in v0.8.0 

func (m *FileOffset) Reset()

func (*FileOffset) String added in v0.8.0 

func (m *FileOffset) String() string

func (*FileOffset) Unmarshal added in v0.8.0 

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

func (*FileOffset) XXX_DiscardUnknown added in v0.8.0 

func (m *FileOffset) XXX_DiscardUnknown()

func (*FileOffset) XXX_Marshal added in v0.8.0 

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

func (*FileOffset) XXX_Merge added in v0.8.0 

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

func (*FileOffset) XXX_Size added in v0.8.0 

func (m *FileOffset) XXX_Size() int

func (*FileOffset) XXX_Unmarshal added in v0.8.0 

func (m *FileOffset) 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"`
	MultiAggs            []*MultiArguemnt `protobuf:"bytes,7,rep,name=MultiAggs,proto3" json:"MultiAggs,omitempty"`
	IsShuffle            bool             `protobuf:"varint,8,opt,name=isShuffle,proto3" json:"isShuffle,omitempty"`
	PreAllocSize         uint64           `protobuf:"varint,9,opt,name=preAllocSize,proto3" json:"preAllocSize,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) GetIsShuffle added in v1.0.0 

func (m *Group) GetIsShuffle() bool

func (*Group) GetMultiAggs added in v0.8.0 

func (m *Group) GetMultiAggs() []*MultiArguemnt

func (*Group) GetNbucket 

func (m *Group) GetNbucket() uint64

func (*Group) GetNeedEval 

func (m *Group) GetNeedEval() bool

func (*Group) GetPreAllocSize added in v1.0.0 

func (m *Group) GetPreAllocSize() uint64

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"`
	HashOnPk             bool         `protobuf:"varint,7,opt,name=hash_on_pk,json=hashOnPk,proto3" json:"hash_on_pk,omitempty"`
	NeedMergedBatch      bool         `protobuf:"varint,8,opt,name=need_merged_batch,json=needMergedBatch,proto3" json:"need_merged_batch,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) GetHashOnPk added in v1.0.0 

func (m *HashBuild) GetHashOnPk() bool

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) GetNeedMergedBatch added in v1.0.0 

func (m *HashBuild) GetNeedMergedBatch() 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 Insert added in v0.7.0 

type Insert struct {
	Affected        uint64          `protobuf:"varint,1,opt,name=affected,proto3" json:"affected,omitempty"`
	ToWriteS3       bool            `protobuf:"varint,2,opt,name=ToWriteS3,proto3" json:"ToWriteS3,omitempty"`
	AddAffectedRows bool            `protobuf:"varint,3,opt,name=add_affected_rows,json=addAffectedRows,proto3" json:"add_affected_rows,omitempty"`
	Ref             *plan.ObjectRef `protobuf:"bytes,4,opt,name=ref,proto3" json:"ref,omitempty"`
	Attrs           []string        `protobuf:"bytes,5,rep,name=attrs,proto3" json:"attrs,omitempty"`
	// Align array index with the partition number
	PartitionTableIds    []uint64       `protobuf:"varint,6,rep,packed,name=partition_table_ids,json=partitionTableIds,proto3" json:"partition_table_ids,omitempty"`
	PartitionTableNames  []string       `protobuf:"bytes,7,rep,name=partition_table_names,json=partitionTableNames,proto3" json:"partition_table_names,omitempty"`
	PartitionIdx         int32          `protobuf:"varint,8,opt,name=partition_idx,json=partitionIdx,proto3" json:"partition_idx,omitempty"`
	IsEnd                bool           `protobuf:"varint,9,opt,name=is_end,json=isEnd,proto3" json:"is_end,omitempty"`
	TableDef             *plan.TableDef `protobuf:"bytes,10,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Insert) Descriptor added in v0.7.0 

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

func (*Insert) GetAddAffectedRows added in v0.8.0 

func (m *Insert) GetAddAffectedRows() bool

func (*Insert) GetAffected added in v0.7.0 

func (m *Insert) GetAffected() uint64

func (*Insert) GetAttrs added in v0.8.0 

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

func (*Insert) GetIsEnd added in v0.8.0 

func (m *Insert) GetIsEnd() bool

func (*Insert) GetPartitionIdx added in v0.8.0 

func (m *Insert) GetPartitionIdx() int32

func (*Insert) GetPartitionTableIds added in v0.8.0 

func (m *Insert) GetPartitionTableIds() []uint64

func (*Insert) GetPartitionTableNames added in v0.8.0 

func (m *Insert) GetPartitionTableNames() []string

func (*Insert) GetRef added in v0.7.0 

func (m *Insert) GetRef() *plan.ObjectRef

func (*Insert) GetTableDef added in v0.7.0 

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

func (*Insert) GetToWriteS3 added in v0.8.0 

func (m *Insert) GetToWriteS3() bool

func (*Insert) Marshal added in v0.7.0 

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

func (*Insert) MarshalTo added in v0.7.0 

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

func (*Insert) MarshalToSizedBuffer added in v0.7.0 

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

func (*Insert) ProtoMessage added in v0.7.0 

func (*Insert) ProtoMessage()

func (*Insert) ProtoSize added in v0.7.0 

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

func (*Insert) Reset added in v0.7.0 

func (m *Insert) Reset()

func (*Insert) String added in v0.7.0 

func (m *Insert) String() string

func (*Insert) Unmarshal added in v0.7.0 

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

func (*Insert) XXX_DiscardUnknown added in v0.7.0 

func (m *Insert) XXX_DiscardUnknown()

func (*Insert) XXX_Marshal added in v0.7.0 

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

func (*Insert) XXX_Merge added in v0.7.0 

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

func (*Insert) XXX_Size added in v0.7.0 

func (m *Insert) XXX_Size() int

func (*Insert) XXX_Unmarshal added in v0.7.0 

func (m *Insert) 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"`
	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"`
	Insert          *Insert             `protobuf:"bytes,17,opt,name=insert,proto3" json:"insert,omitempty"`
	OnDuplicateKey  *OnDuplicateKey     `protobuf:"bytes,18,opt,name=on_duplicate_key,json=onDuplicateKey,proto3" json:"on_duplicate_key,omitempty"`
	PreInsert       *PreInsert          `protobuf:"bytes,19,opt,name=pre_insert,json=preInsert,proto3" json:"pre_insert,omitempty"`
	PreInsertUnique *PreInsertUnique    `protobuf:"bytes,20,opt,name=pre_insert_unique,json=preInsertUnique,proto3" json:"pre_insert_unique,omitempty"`
	OrderBy         []*plan.OrderBySpec `protobuf:"bytes,21,rep,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	ProjectList     []*plan.Expr        `protobuf:"bytes,22,rep,name=project_list,json=projectList,proto3" json:"project_list,omitempty"`
	Filter          *plan.Expr          `protobuf:"bytes,23,opt,name=filter,proto3" json:"filter,omitempty"`
	Limit           uint64              `protobuf:"varint,24,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset          uint64              `protobuf:"varint,25,opt,name=offset,proto3" json:"offset,omitempty"`
	// isFirst identifies whether it is the first instruction of analyzeInfo corresponding to idx
	IsFirst bool `protobuf:"varint,26,opt,name=isFirst,proto3" json:"isFirst,omitempty"`
	// isLast identifies whether it is the last instruction of analyzeInfo corresponding to idx
	IsLast               bool           `protobuf:"varint,27,opt,name=isLast,proto3" json:"isLast,omitempty"`
	RightJoin            *RightJoin     `protobuf:"bytes,28,opt,name=right_join,json=rightJoin,proto3" json:"right_join,omitempty"`
	RightSemiJoin        *RightSemiJoin `protobuf:"bytes,29,opt,name=right_semi_join,json=rightSemiJoin,proto3" json:"right_semi_join,omitempty"`
	RightAntiJoin        *RightAntiJoin `protobuf:"bytes,30,opt,name=right_anti_join,json=rightAntiJoin,proto3" json:"right_anti_join,omitempty"`
	Delete               *Deletion      `protobuf:"bytes,31,opt,name=delete,proto3" json:"delete,omitempty"`
	LockOp               *LockOp        `protobuf:"bytes,32,opt,name=lock_op,json=lockOp,proto3" json:"lock_op,omitempty"`
	Shuffle              *Shuffle       `protobuf:"bytes,33,opt,name=shuffle,proto3" json:"shuffle,omitempty"`
	Merge                *Merge         `protobuf:"bytes,34,opt,name=merge,proto3" json:"merge,omitempty"`
	StreamScan           *StreamScan    `protobuf:"bytes,35,opt,name=stream_scan,json=streamScan,proto3" json:"stream_scan,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) GetDelete added in v0.8.0 

func (m *Instruction) GetDelete() *Deletion

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) GetInsert added in v0.7.0 

func (m *Instruction) GetInsert() *Insert

func (*Instruction) GetIsFirst added in v0.7.0 

func (m *Instruction) GetIsFirst() bool

func (*Instruction) GetIsLast added in v0.7.0 

func (m *Instruction) GetIsLast() bool

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) GetLockOp added in v0.8.0 

func (m *Instruction) GetLockOp() *LockOp

func (*Instruction) GetMarkJoin 

func (m *Instruction) GetMarkJoin() *MarkJoin

func (*Instruction) GetMerge added in v1.0.0 

func (m *Instruction) GetMerge() *Merge

func (*Instruction) GetOffset 

func (m *Instruction) GetOffset() uint64

func (*Instruction) GetOnDuplicateKey added in v0.8.0 

func (m *Instruction) GetOnDuplicateKey() *OnDuplicateKey

func (*Instruction) GetOp 

func (m *Instruction) GetOp() int32

func (*Instruction) GetOrderBy 

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

func (*Instruction) GetPreInsert added in v0.8.0 

func (m *Instruction) GetPreInsert() *PreInsert

func (*Instruction) GetPreInsertUnique added in v0.8.0 

func (m *Instruction) GetPreInsertUnique() *PreInsertUnique

func (*Instruction) GetProduct 

func (m *Instruction) GetProduct() *Product

func (*Instruction) GetProjectList 

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

func (*Instruction) GetRightAntiJoin added in v0.8.0 

func (m *Instruction) GetRightAntiJoin() *RightAntiJoin

func (*Instruction) GetRightJoin added in v0.8.0 

func (m *Instruction) GetRightJoin() *RightJoin

func (*Instruction) GetRightSemiJoin added in v0.8.0 

func (m *Instruction) GetRightSemiJoin() *RightSemiJoin

func (*Instruction) GetSemiJoin 

func (m *Instruction) GetSemiJoin() *SemiJoin

func (*Instruction) GetShuffle added in v1.0.0 

func (m *Instruction) GetShuffle() *Shuffle

func (*Instruction) GetSingleJoin 

func (m *Instruction) GetSingleJoin() *SingleJoin

func (*Instruction) GetStreamScan added in v1.0.0 

func (m *Instruction) GetStreamScan() *StreamScan

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"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 131-byte string literal not displayed */
	HashOnPk               bool                      `protobuf:"varint,10,opt,name=hash_on_pk,json=hashOnPk,proto3" json:"hash_on_pk,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) GetHashOnPk added in v1.0.0 

func (m *Join) GetHashOnPk() bool

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) GetRuntimeFilterBuildList added in v1.0.0 

func (m *Join) GetRuntimeFilterBuildList() []*plan.RuntimeFilterSpec

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"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 131-byte string literal not displayed */
	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) GetRuntimeFilterBuildList added in v1.0.0 

func (m *LeftJoin) GetRuntimeFilterBuildList() []*plan.RuntimeFilterSpec

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 LockOp added in v0.8.0 

type LockOp struct {
	Targets              []*LockTarget `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	Block                bool          `protobuf:"varint,2,opt,name=block,proto3" json:"block,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*LockOp) Descriptor added in v0.8.0 

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

func (*LockOp) GetBlock added in v0.8.0 

func (m *LockOp) GetBlock() bool

func (*LockOp) GetTargets added in v0.8.0 

func (m *LockOp) GetTargets() []*LockTarget

func (*LockOp) Marshal added in v0.8.0 

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

func (*LockOp) MarshalTo added in v0.8.0 

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

func (*LockOp) MarshalToSizedBuffer added in v0.8.0 

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

func (*LockOp) ProtoMessage added in v0.8.0 

func (*LockOp) ProtoMessage()

func (*LockOp) ProtoSize added in v0.8.0 

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

func (*LockOp) Reset added in v0.8.0 

func (m *LockOp) Reset()

func (*LockOp) String added in v0.8.0 

func (m *LockOp) String() string

func (*LockOp) Unmarshal added in v0.8.0 

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

func (*LockOp) XXX_DiscardUnknown added in v0.8.0 

func (m *LockOp) XXX_DiscardUnknown()

func (*LockOp) XXX_Marshal added in v0.8.0 

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

func (*LockOp) XXX_Merge added in v0.8.0 

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

func (*LockOp) XXX_Size added in v0.8.0 

func (m *LockOp) XXX_Size() int

func (*LockOp) XXX_Unmarshal added in v0.8.0 

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

type LockTarget added in v0.8.0 

type LockTarget struct {
	TableId              uint64        `protobuf:"varint,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	PrimaryColIdxInBat   int32         `protobuf:"varint,2,opt,name=primary_col_idx_in_bat,json=primaryColIdxInBat,proto3" json:"primary_col_idx_in_bat,omitempty"`
	PrimaryColTyp        *plan.Type    `protobuf:"bytes,3,opt,name=primary_col_typ,json=primaryColTyp,proto3" json:"primary_col_typ,omitempty"`
	RefreshTsIdxInBat    int32         `protobuf:"varint,4,opt,name=refresh_ts_idx_in_bat,json=refreshTsIdxInBat,proto3" json:"refresh_ts_idx_in_bat,omitempty"`
	FilterColIdxInBat    int32         `protobuf:"varint,5,opt,name=filter_col_idx_in_bat,json=filterColIdxInBat,proto3" json:"filter_col_idx_in_bat,omitempty"`
	LockTable            bool          `protobuf:"varint,6,opt,name=lock_table,json=lockTable,proto3" json:"lock_table,omitempty"`
	ChangeDef            bool          `protobuf:"varint,7,opt,name=ChangeDef,proto3" json:"ChangeDef,omitempty"`
	Mode                 lock.LockMode `protobuf:"varint,8,opt,name=Mode,proto3,enum=lock.LockMode" json:"Mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*LockTarget) Descriptor added in v0.8.0 

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

func (*LockTarget) GetChangeDef added in v1.0.0 

func (m *LockTarget) GetChangeDef() bool

func (*LockTarget) GetFilterColIdxInBat added in v0.8.0 

func (m *LockTarget) GetFilterColIdxInBat() int32

func (*LockTarget) GetLockTable added in v0.8.0 

func (m *LockTarget) GetLockTable() bool

func (*LockTarget) GetMode added in v1.0.0 

func (m *LockTarget) GetMode() lock.LockMode

func (*LockTarget) GetPrimaryColIdxInBat added in v0.8.0 

func (m *LockTarget) GetPrimaryColIdxInBat() int32

func (*LockTarget) GetPrimaryColTyp added in v0.8.0 

func (m *LockTarget) GetPrimaryColTyp() *plan.Type

func (*LockTarget) GetRefreshTsIdxInBat added in v0.8.0 

func (m *LockTarget) GetRefreshTsIdxInBat() int32

func (*LockTarget) GetTableId added in v0.8.0 

func (m *LockTarget) GetTableId() uint64

func (*LockTarget) Marshal added in v0.8.0 

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

func (*LockTarget) MarshalTo added in v0.8.0 

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

func (*LockTarget) MarshalToSizedBuffer added in v0.8.0 

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

func (*LockTarget) ProtoMessage added in v0.8.0 

func (*LockTarget) ProtoMessage()

func (*LockTarget) ProtoSize added in v0.8.0 

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

func (*LockTarget) Reset added in v0.8.0 

func (m *LockTarget) Reset()

func (*LockTarget) String added in v0.8.0 

func (m *LockTarget) String() string

func (*LockTarget) Unmarshal added in v0.8.0 

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

func (*LockTarget) XXX_DiscardUnknown added in v0.8.0 

func (m *LockTarget) XXX_DiscardUnknown()

func (*LockTarget) XXX_Marshal added in v0.8.0 

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

func (*LockTarget) XXX_Merge added in v0.8.0 

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

func (*LockTarget) XXX_Size added in v0.8.0 

func (m *LockTarget) XXX_Size() int

func (*LockTarget) XXX_Unmarshal added in v0.8.0 

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

type Map added in v0.8.0 

type Map struct {
	Mp                   map[string]int32 `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Map) Descriptor added in v0.8.0 

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

func (*Map) GetMp added in v0.8.0 

func (m *Map) GetMp() map[string]int32

func (*Map) Marshal added in v0.8.0 

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

func (*Map) MarshalTo added in v0.8.0 

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

func (*Map) MarshalToSizedBuffer added in v0.8.0 

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

func (*Map) ProtoMessage added in v0.8.0 

func (*Map) ProtoMessage()

func (*Map) ProtoSize added in v0.8.0 

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

func (*Map) Reset added in v0.8.0 

func (m *Map) Reset()

func (*Map) String added in v0.8.0 

func (m *Map) String() string

func (*Map) Unmarshal added in v0.8.0 

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

func (*Map) XXX_DiscardUnknown added in v0.8.0 

func (m *Map) XXX_DiscardUnknown()

func (*Map) XXX_Marshal added in v0.8.0 

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

func (*Map) XXX_Merge added in v0.8.0 

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

func (*Map) XXX_Size added in v0.8.0 

func (m *Map) XXX_Size() int

func (*Map) XXX_Unmarshal added in v0.8.0 

func (m *Map) 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"`
	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"`
	OnList               []*plan.Expr `protobuf:"bytes,8,rep,name=on_list,json=onList,proto3" json:"on_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MarkJoin) Descriptor 

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

func (*MarkJoin) GetExpr added in v0.7.0 

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

func (*MarkJoin) GetIbucket 

func (m *MarkJoin) GetIbucket() uint64

func (*MarkJoin) GetLeftCond 

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

func (*MarkJoin) GetNbucket 

func (m *MarkJoin) GetNbucket() uint64

func (*MarkJoin) GetOnList 

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

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 Merge added in v1.0.0 

type Merge struct {
	SinkScan             bool     `protobuf:"varint,1,opt,name=sinkScan,proto3" json:"sinkScan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Merge) Descriptor added in v1.0.0 

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

func (*Merge) GetSinkScan added in v1.0.0 

func (m *Merge) GetSinkScan() bool

func (*Merge) Marshal added in v1.0.0 

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

func (*Merge) MarshalTo added in v1.0.0 

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

func (*Merge) MarshalToSizedBuffer added in v1.0.0 

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

func (*Merge) ProtoMessage added in v1.0.0 

func (*Merge) ProtoMessage()

func (*Merge) ProtoSize added in v1.0.0 

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

func (*Merge) Reset added in v1.0.0 

func (m *Merge) Reset()

func (*Merge) String added in v1.0.0 

func (m *Merge) String() string

func (*Merge) Unmarshal added in v1.0.0 

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

func (*Merge) XXX_DiscardUnknown added in v1.0.0 

func (m *Merge) XXX_DiscardUnknown()

func (*Merge) XXX_Marshal added in v1.0.0 

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

func (*Merge) XXX_Merge added in v1.0.0 

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

func (*Merge) XXX_Size added in v1.0.0 

func (m *Merge) XXX_Size() int

func (*Merge) XXX_Unmarshal added in v1.0.0 

func (m *Merge) 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"`
	Uuid                 []byte   `protobuf:"bytes,8,opt,name=uuid,proto3" json:"uuid,omitempty"`
	BatchCnt             uint64   `protobuf:"varint,9,opt,name=batch_cnt,json=batchCnt,proto3" json:"batch_cnt,omitempty"`
	Checksum             uint32   `protobuf:"varint,10,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Sequence             uint64   `protobuf:"varint,11,opt,name=sequence,proto3" json:"sequence,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) GetBatchCnt added in v0.7.0 

func (m *Message) GetBatchCnt() uint64

func (*Message) GetChecksum added in v0.7.0 

func (m *Message) GetChecksum() uint32

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) GetSequence added in v0.7.0 

func (m *Message) GetSequence() uint64

func (*Message) GetSid 

func (m *Message) GetSid() uint64

func (*Message) GetUuid added in v0.7.0 

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

func (*Message) IsBatchMessage added in v0.7.0 

func (m *Message) IsBatchMessage() bool

func (*Message) IsEndMessage 

func (m *Message) IsEndMessage() bool

func (*Message) IsLast added in v0.8.0 

func (m *Message) IsLast() bool

func (*Message) IsNotifyMessage added in v0.7.0 

func (m *Message) IsNotifyMessage() bool

func (*Message) IsPipelineMessage added in v0.7.0 

func (m *Message) IsPipelineMessage() 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) SetAnalysis added in v0.7.0 

func (m *Message) SetAnalysis(data []byte)

func (*Message) SetCheckSum added in v0.7.0 

func (m *Message) SetCheckSum(sum uint32)

func (*Message) SetData added in v0.7.0 

func (m *Message) SetData(data []byte)

func (*Message) SetID 

func (m *Message) SetID(id uint64)

func (*Message) SetMessageType added in v0.7.0 

func (m *Message) SetMessageType(cmd uint64)

func (*Message) SetMoError added in v0.7.0 

func (m *Message) SetMoError(ctx context.Context, err error)

func (*Message) SetProcData added in v0.7.0 

func (m *Message) SetProcData(data []byte)

func (*Message) SetSequence added in v0.7.0 

func (m *Message) SetSequence(s uint64)

func (*Message) SetSid added in v0.7.0 

func (m *Message) SetSid(sid uint64)

func (*Message) Size 

func (m *Message) Size() int

func (*Message) String 

func (m *Message) String() string

func (*Message) TryToGetMoErr added in v0.7.0 

func (m *Message) TryToGetMoErr() (error, bool)

func (*Message) Unmarshal 

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

func (*Message) WaitingNextToMerge added in v0.7.0 

func (m *Message) WaitingNextToMerge() bool

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 MultiArguemnt added in v0.8.0 

type MultiArguemnt struct {
	Dist                 bool         `protobuf:"varint,1,opt,name=Dist,proto3" json:"Dist,omitempty"`
	GroupExpr            []*plan.Expr `protobuf:"bytes,2,rep,name=GroupExpr,proto3" json:"GroupExpr,omitempty"`
	OrderByExpr          []*plan.Expr `protobuf:"bytes,3,rep,name=OrderByExpr,proto3" json:"OrderByExpr,omitempty"`
	Separator            string       `protobuf:"bytes,4,opt,name=Separator,proto3" json:"Separator,omitempty"`
	OrderId              int32        `protobuf:"varint,5,opt,name=OrderId,proto3" json:"OrderId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MultiArguemnt) Descriptor added in v0.8.0 

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

func (*MultiArguemnt) GetDist added in v0.8.0 

func (m *MultiArguemnt) GetDist() bool

func (*MultiArguemnt) GetGroupExpr added in v0.8.0 

func (m *MultiArguemnt) GetGroupExpr() []*plan.Expr

func (*MultiArguemnt) GetOrderByExpr added in v0.8.0 

func (m *MultiArguemnt) GetOrderByExpr() []*plan.Expr

func (*MultiArguemnt) GetOrderId added in v0.8.0 

func (m *MultiArguemnt) GetOrderId() int32

func (*MultiArguemnt) GetSeparator added in v0.8.0 

func (m *MultiArguemnt) GetSeparator() string

func (*MultiArguemnt) Marshal added in v0.8.0 

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

func (*MultiArguemnt) MarshalTo added in v0.8.0 

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

func (*MultiArguemnt) MarshalToSizedBuffer added in v0.8.0 

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

func (*MultiArguemnt) ProtoMessage added in v0.8.0 

func (*MultiArguemnt) ProtoMessage()

func (*MultiArguemnt) ProtoSize added in v0.8.0 

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

func (*MultiArguemnt) Reset added in v0.8.0 

func (m *MultiArguemnt) Reset()

func (*MultiArguemnt) String added in v0.8.0 

func (m *MultiArguemnt) String() string

func (*MultiArguemnt) Unmarshal added in v0.8.0 

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

func (*MultiArguemnt) XXX_DiscardUnknown added in v0.8.0 

func (m *MultiArguemnt) XXX_DiscardUnknown()

func (*MultiArguemnt) XXX_Marshal added in v0.8.0 

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

func (*MultiArguemnt) XXX_Merge added in v0.8.0 

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

func (*MultiArguemnt) XXX_Size added in v0.8.0 

func (m *MultiArguemnt) XXX_Size() int

func (*MultiArguemnt) XXX_Unmarshal added in v0.8.0 

func (m *MultiArguemnt) 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 OnDuplicateKey added in v0.8.0 

type OnDuplicateKey struct {
	TableDef             *plan.TableDef        `protobuf:"bytes,1,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	OnDuplicateIdx       []int32               `protobuf:"varint,2,rep,packed,name=on_duplicate_idx,json=onDuplicateIdx,proto3" json:"on_duplicate_idx,omitempty"`
	OnDuplicateExpr      map[string]*plan.Expr `` /* 196-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OnDuplicateKey) Descriptor added in v0.8.0 

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

func (*OnDuplicateKey) GetOnDuplicateExpr added in v0.8.0 

func (m *OnDuplicateKey) GetOnDuplicateExpr() map[string]*plan.Expr

func (*OnDuplicateKey) GetOnDuplicateIdx added in v0.8.0 

func (m *OnDuplicateKey) GetOnDuplicateIdx() []int32

func (*OnDuplicateKey) GetTableDef added in v0.8.0 

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

func (*OnDuplicateKey) Marshal added in v0.8.0 

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

func (*OnDuplicateKey) MarshalTo added in v0.8.0 

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

func (*OnDuplicateKey) MarshalToSizedBuffer added in v0.8.0 

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

func (*OnDuplicateKey) ProtoMessage added in v0.8.0 

func (*OnDuplicateKey) ProtoMessage()

func (*OnDuplicateKey) ProtoSize added in v0.8.0 

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

func (*OnDuplicateKey) Reset added in v0.8.0 

func (m *OnDuplicateKey) Reset()

func (*OnDuplicateKey) String added in v0.8.0 

func (m *OnDuplicateKey) String() string

func (*OnDuplicateKey) Unmarshal added in v0.8.0 

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

func (*OnDuplicateKey) XXX_DiscardUnknown added in v0.8.0 

func (m *OnDuplicateKey) XXX_DiscardUnknown()

func (*OnDuplicateKey) XXX_Marshal added in v0.8.0 

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

func (*OnDuplicateKey) XXX_Merge added in v0.8.0 

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

func (*OnDuplicateKey) XXX_Size added in v0.8.0 

func (m *OnDuplicateKey) XXX_Size() int

func (*OnDuplicateKey) XXX_Unmarshal added in v0.8.0 

func (m *OnDuplicateKey) 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"`
	IsLoad               bool                  `protobuf:"varint,9,opt,name=is_load,json=isLoad,proto3" json:"is_load,omitempty"`
	Node                 *NodeInfo             `protobuf:"bytes,10,opt,name=node,proto3" json:"node,omitempty"`
	PushDownInfo         int32                 `protobuf:"varint,11,opt,name=push_down_info,json=pushDownInfo,proto3" json:"push_down_info,omitempty"`
	ChildrenCount        int32                 `protobuf:"varint,12,opt,name=children_count,json=childrenCount,proto3" json:"children_count,omitempty"`
	UuidsToRegIdx        []*UuidToRegIdx       `protobuf:"bytes,13,rep,name=uuids_to_reg_idx,json=uuidsToRegIdx,proto3" json:"uuids_to_reg_idx,omitempty"`
	BuildIdx             int32                 `protobuf:"varint,14,opt,name=build_idx,json=buildIdx,proto3" json:"build_idx,omitempty"`
	ShuffleCnt           int32                 `protobuf:"varint,15,opt,name=shuffle_cnt,json=shuffleCnt,proto3" json:"shuffle_cnt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Pipeline) Descriptor 

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

func (*Pipeline) GetBuildIdx added in v1.0.0 

func (m *Pipeline) GetBuildIdx() int32

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) GetIsLoad added in v0.8.0 

func (m *Pipeline) GetIsLoad() 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) GetShuffleCnt added in v1.0.0 

func (m *Pipeline) GetShuffleCnt() int32

func (*Pipeline) GetUuidsToRegIdx added in v0.7.0 

func (m *Pipeline) GetUuidsToRegIdx() []*UuidToRegIdx

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 PreInsert added in v0.8.0 

type PreInsert struct {
	SchemaName           string         `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	TableDef             *plan.TableDef `protobuf:"bytes,2,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	Idx                  []int32        `protobuf:"varint,3,rep,packed,name=idx,proto3" json:"idx,omitempty"`
	Attrs                []string       `protobuf:"bytes,4,rep,name=attrs,proto3" json:"attrs,omitempty"`
	HasAutoCol           bool           `protobuf:"varint,5,opt,name=has_auto_col,json=hasAutoCol,proto3" json:"has_auto_col,omitempty"`
	IsUpdate             bool           `protobuf:"varint,6,opt,name=is_update,json=isUpdate,proto3" json:"is_update,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PreInsert) Descriptor added in v0.8.0 

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

func (*PreInsert) GetAttrs added in v0.8.0 

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

func (*PreInsert) GetHasAutoCol added in v0.8.0 

func (m *PreInsert) GetHasAutoCol() bool

func (*PreInsert) GetIdx added in v0.8.0 

func (m *PreInsert) GetIdx() []int32

func (*PreInsert) GetIsUpdate added in v0.8.0 

func (m *PreInsert) GetIsUpdate() bool

func (*PreInsert) GetSchemaName added in v0.8.0 

func (m *PreInsert) GetSchemaName() string

func (*PreInsert) GetTableDef added in v0.8.0 

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

func (*PreInsert) Marshal added in v0.8.0 

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

func (*PreInsert) MarshalTo added in v0.8.0 

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

func (*PreInsert) MarshalToSizedBuffer added in v0.8.0 

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

func (*PreInsert) ProtoMessage added in v0.8.0 

func (*PreInsert) ProtoMessage()

func (*PreInsert) ProtoSize added in v0.8.0 

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

func (*PreInsert) Reset added in v0.8.0 

func (m *PreInsert) Reset()

func (*PreInsert) String added in v0.8.0 

func (m *PreInsert) String() string

func (*PreInsert) Unmarshal added in v0.8.0 

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

func (*PreInsert) XXX_DiscardUnknown added in v0.8.0 

func (m *PreInsert) XXX_DiscardUnknown()

func (*PreInsert) XXX_Marshal added in v0.8.0 

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

func (*PreInsert) XXX_Merge added in v0.8.0 

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

func (*PreInsert) XXX_Size added in v0.8.0 

func (m *PreInsert) XXX_Size() int

func (*PreInsert) XXX_Unmarshal added in v0.8.0 

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

type PreInsertUnique added in v0.8.0 

type PreInsertUnique struct {
	PreInsertUkCtx       *plan.PreInsertUkCtx `protobuf:"bytes,1,opt,name=pre_insert_uk_ctx,json=preInsertUkCtx,proto3" json:"pre_insert_uk_ctx,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PreInsertUnique) Descriptor added in v0.8.0 

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

func (*PreInsertUnique) GetPreInsertUkCtx added in v0.8.0 

func (m *PreInsertUnique) GetPreInsertUkCtx() *plan.PreInsertUkCtx

func (*PreInsertUnique) Marshal added in v0.8.0 

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

func (*PreInsertUnique) MarshalTo added in v0.8.0 

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

func (*PreInsertUnique) MarshalToSizedBuffer added in v0.8.0 

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

func (*PreInsertUnique) ProtoMessage added in v0.8.0 

func (*PreInsertUnique) ProtoMessage()

func (*PreInsertUnique) ProtoSize added in v0.8.0 

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

func (*PreInsertUnique) Reset added in v0.8.0 

func (m *PreInsertUnique) Reset()

func (*PreInsertUnique) String added in v0.8.0 

func (m *PreInsertUnique) String() string

func (*PreInsertUnique) Unmarshal added in v0.8.0 

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

func (*PreInsertUnique) XXX_DiscardUnknown added in v0.8.0 

func (m *PreInsertUnique) XXX_DiscardUnknown()

func (*PreInsertUnique) XXX_Marshal added in v0.8.0 

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

func (*PreInsertUnique) XXX_Merge added in v0.8.0 

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

func (*PreInsertUnique) XXX_Size added in v0.8.0 

func (m *PreInsertUnique) XXX_Size() int

func (*PreInsertUnique) XXX_Unmarshal added in v0.8.0 

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

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"`
	AccountId            uint32             `protobuf:"varint,4,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	Snapshot             string             `protobuf:"bytes,5,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	SessionInfo          *SessionInfo       `protobuf:"bytes,6,opt,name=session_info,json=sessionInfo,proto3" json:"session_info,omitempty"`
	AnalysisNodeList     []int32            `protobuf:"varint,7,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) GetAccountId added in v0.8.0 

func (m *ProcessInfo) GetAccountId() uint32

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 RightAntiJoin added in v0.8.0 

type RightAntiJoin 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"`
	RightTypes             []*plan.Type              `protobuf:"bytes,5,rep,name=right_types,json=rightTypes,proto3" json:"right_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"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                  `json:"-"`
	XXX_unrecognized       []byte                    `json:"-"`
	XXX_sizecache          int32                     `json:"-"`
}

func (*RightAntiJoin) Descriptor added in v0.8.0 

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

func (*RightAntiJoin) GetExpr added in v0.8.0 

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

func (*RightAntiJoin) GetIbucket added in v0.8.0 

func (m *RightAntiJoin) GetIbucket() uint64

func (*RightAntiJoin) GetLeftCond added in v0.8.0 

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

func (*RightAntiJoin) GetNbucket added in v0.8.0 

func (m *RightAntiJoin) GetNbucket() uint64

func (*RightAntiJoin) GetResult added in v0.8.0 

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

func (*RightAntiJoin) GetRightCond added in v0.8.0 

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

func (*RightAntiJoin) GetRightTypes added in v0.8.0 

func (m *RightAntiJoin) GetRightTypes() []*plan.Type

func (*RightAntiJoin) GetRuntimeFilterBuildList added in v1.0.0 

func (m *RightAntiJoin) GetRuntimeFilterBuildList() []*plan.RuntimeFilterSpec

func (*RightAntiJoin) Marshal added in v0.8.0 

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

func (*RightAntiJoin) MarshalTo added in v0.8.0 

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

func (*RightAntiJoin) MarshalToSizedBuffer added in v0.8.0 

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

func (*RightAntiJoin) ProtoMessage added in v0.8.0 

func (*RightAntiJoin) ProtoMessage()

func (*RightAntiJoin) ProtoSize added in v0.8.0 

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

func (*RightAntiJoin) Reset added in v0.8.0 

func (m *RightAntiJoin) Reset()

func (*RightAntiJoin) String added in v0.8.0 

func (m *RightAntiJoin) String() string

func (*RightAntiJoin) Unmarshal added in v0.8.0 

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

func (*RightAntiJoin) XXX_DiscardUnknown added in v0.8.0 

func (m *RightAntiJoin) XXX_DiscardUnknown()

func (*RightAntiJoin) XXX_Marshal added in v0.8.0 

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

func (*RightAntiJoin) XXX_Merge added in v0.8.0 

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

func (*RightAntiJoin) XXX_Size added in v0.8.0 

func (m *RightAntiJoin) XXX_Size() int

func (*RightAntiJoin) XXX_Unmarshal added in v0.8.0 

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

type RightJoin added in v0.8.0 

type RightJoin 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"`
	LeftTypes              []*plan.Type              `protobuf:"bytes,6,rep,name=left_types,json=leftTypes,proto3" json:"left_types,omitempty"`
	RightTypes             []*plan.Type              `protobuf:"bytes,7,rep,name=right_types,json=rightTypes,proto3" json:"right_types,omitempty"`
	LeftCond               []*plan.Expr              `protobuf:"bytes,8,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond              []*plan.Expr              `protobuf:"bytes,9,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                  `json:"-"`
	XXX_unrecognized       []byte                    `json:"-"`
	XXX_sizecache          int32                     `json:"-"`
}

func (*RightJoin) Descriptor added in v0.8.0 

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

func (*RightJoin) GetColList added in v0.8.0 

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

func (*RightJoin) GetExpr added in v0.8.0 

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

func (*RightJoin) GetIbucket added in v0.8.0 

func (m *RightJoin) GetIbucket() uint64

func (*RightJoin) GetLeftCond added in v0.8.0 

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

func (*RightJoin) GetLeftTypes added in v0.8.0 

func (m *RightJoin) GetLeftTypes() []*plan.Type

func (*RightJoin) GetNbucket added in v0.8.0 

func (m *RightJoin) GetNbucket() uint64

func (*RightJoin) GetRelList added in v0.8.0 

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

func (*RightJoin) GetRightCond added in v0.8.0 

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

func (*RightJoin) GetRightTypes added in v0.8.0 

func (m *RightJoin) GetRightTypes() []*plan.Type

func (*RightJoin) GetRuntimeFilterBuildList added in v1.0.0 

func (m *RightJoin) GetRuntimeFilterBuildList() []*plan.RuntimeFilterSpec

func (*RightJoin) Marshal added in v0.8.0 

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

func (*RightJoin) MarshalTo added in v0.8.0 

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

func (*RightJoin) MarshalToSizedBuffer added in v0.8.0 

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

func (*RightJoin) ProtoMessage added in v0.8.0 

func (*RightJoin) ProtoMessage()

func (*RightJoin) ProtoSize added in v0.8.0 

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

func (*RightJoin) Reset added in v0.8.0 

func (m *RightJoin) Reset()

func (*RightJoin) String added in v0.8.0 

func (m *RightJoin) String() string

func (*RightJoin) Unmarshal added in v0.8.0 

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

func (*RightJoin) XXX_DiscardUnknown added in v0.8.0 

func (m *RightJoin) XXX_DiscardUnknown()

func (*RightJoin) XXX_Marshal added in v0.8.0 

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

func (*RightJoin) XXX_Merge added in v0.8.0 

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

func (*RightJoin) XXX_Size added in v0.8.0 

func (m *RightJoin) XXX_Size() int

func (*RightJoin) XXX_Unmarshal added in v0.8.0 

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

type RightSemiJoin added in v0.8.0 

type RightSemiJoin 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"`
	RightTypes             []*plan.Type              `protobuf:"bytes,5,rep,name=right_types,json=rightTypes,proto3" json:"right_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"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                  `json:"-"`
	XXX_unrecognized       []byte                    `json:"-"`
	XXX_sizecache          int32                     `json:"-"`
}

func (*RightSemiJoin) Descriptor added in v0.8.0 

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

func (*RightSemiJoin) GetExpr added in v0.8.0 

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

func (*RightSemiJoin) GetIbucket added in v0.8.0 

func (m *RightSemiJoin) GetIbucket() uint64

func (*RightSemiJoin) GetLeftCond added in v0.8.0 

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

func (*RightSemiJoin) GetNbucket added in v0.8.0 

func (m *RightSemiJoin) GetNbucket() uint64

func (*RightSemiJoin) GetResult added in v0.8.0 

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

func (*RightSemiJoin) GetRightCond added in v0.8.0 

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

func (*RightSemiJoin) GetRightTypes added in v0.8.0 

func (m *RightSemiJoin) GetRightTypes() []*plan.Type

func (*RightSemiJoin) GetRuntimeFilterBuildList added in v1.0.0 

func (m *RightSemiJoin) GetRuntimeFilterBuildList() []*plan.RuntimeFilterSpec

func (*RightSemiJoin) Marshal added in v0.8.0 

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

func (*RightSemiJoin) MarshalTo added in v0.8.0 

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

func (*RightSemiJoin) MarshalToSizedBuffer added in v0.8.0 

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

func (*RightSemiJoin) ProtoMessage added in v0.8.0 

func (*RightSemiJoin) ProtoMessage()

func (*RightSemiJoin) ProtoSize added in v0.8.0 

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

func (*RightSemiJoin) Reset added in v0.8.0 

func (m *RightSemiJoin) Reset()

func (*RightSemiJoin) String added in v0.8.0 

func (m *RightSemiJoin) String() string

func (*RightSemiJoin) Unmarshal added in v0.8.0 

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

func (*RightSemiJoin) XXX_DiscardUnknown added in v0.8.0 

func (m *RightSemiJoin) XXX_DiscardUnknown()

func (*RightSemiJoin) XXX_Marshal added in v0.8.0 

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

func (*RightSemiJoin) XXX_Merge added in v0.8.0 

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

func (*RightSemiJoin) XXX_Size added in v0.8.0 

func (m *RightSemiJoin) XXX_Size() int

func (*RightSemiJoin) XXX_Unmarshal added in v0.8.0 

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

type RuntimeFilter added in v0.8.0 

type RuntimeFilter struct {
	Typ                  RuntimeFilter_RuntimeFilterType `protobuf:"varint,1,opt,name=typ,proto3,enum=pipeline.RuntimeFilter_RuntimeFilterType" json:"typ,omitempty"`
	Data                 []byte                          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*RuntimeFilter) Descriptor added in v0.8.0 

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

func (*RuntimeFilter) GetData added in v0.8.0 

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

func (*RuntimeFilter) GetTyp added in v0.8.0 

func (m *RuntimeFilter) GetTyp() RuntimeFilter_RuntimeFilterType

func (*RuntimeFilter) Marshal added in v0.8.0 

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

func (*RuntimeFilter) MarshalTo added in v0.8.0 

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

func (*RuntimeFilter) MarshalToSizedBuffer added in v0.8.0 

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

func (*RuntimeFilter) ProtoMessage added in v0.8.0 

func (*RuntimeFilter) ProtoMessage()

func (*RuntimeFilter) ProtoSize added in v0.8.0 

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

func (*RuntimeFilter) Reset added in v0.8.0 

func (m *RuntimeFilter) Reset()

func (*RuntimeFilter) String added in v0.8.0 

func (m *RuntimeFilter) String() string

func (*RuntimeFilter) Unmarshal added in v0.8.0 

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

func (*RuntimeFilter) XXX_DiscardUnknown added in v0.8.0 

func (m *RuntimeFilter) XXX_DiscardUnknown()

func (*RuntimeFilter) XXX_Marshal added in v0.8.0 

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

func (*RuntimeFilter) XXX_Merge added in v0.8.0 

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

func (*RuntimeFilter) XXX_Size added in v0.8.0 

func (m *RuntimeFilter) XXX_Size() int

func (*RuntimeFilter) XXX_Unmarshal added in v0.8.0 

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

type RuntimeFilter_RuntimeFilterType added in v0.8.0 

type RuntimeFilter_RuntimeFilterType int32
const (
	RuntimeFilter_IN          RuntimeFilter_RuntimeFilterType = 0
	RuntimeFilter_BITMAP      RuntimeFilter_RuntimeFilterType = 1
	RuntimeFilter_MIN_MAX     RuntimeFilter_RuntimeFilterType = 2
	RuntimeFilter_BINARY_FUSE RuntimeFilter_RuntimeFilterType = 3
	RuntimeFilter_PASS        RuntimeFilter_RuntimeFilterType = 100
	RuntimeFilter_DROP        RuntimeFilter_RuntimeFilterType = 101
)

func (RuntimeFilter_RuntimeFilterType) EnumDescriptor added in v0.8.0 

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

func (RuntimeFilter_RuntimeFilterType) String added in v0.8.0 

func (x RuntimeFilter_RuntimeFilterType) String() string

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"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 131-byte string literal not displayed */
	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) GetRuntimeFilterBuildList added in v1.0.0 

func (m *SemiJoin) GetRuntimeFilterBuildList() []*plan.RuntimeFilterSpec

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"`
	Account              string   `protobuf:"bytes,8,opt,name=account,proto3" json:"account,omitempty"`
	QueryId              []string `protobuf:"bytes,9,rep,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SessionInfo) Descriptor 

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

func (*SessionInfo) GetAccount added in v0.7.0 

func (m *SessionInfo) GetAccount() string

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) GetQueryId added in v0.8.0 

func (m *SessionInfo) GetQueryId() []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 Shuffle added in v1.0.0 

type Shuffle struct {
	ShuffleColIdx        int32    `protobuf:"varint,1,opt,name=ShuffleColIdx,proto3" json:"ShuffleColIdx,omitempty"`
	ShuffleType          int32    `protobuf:"varint,2,opt,name=ShuffleType,proto3" json:"ShuffleType,omitempty"`
	ShuffleColMin        int64    `protobuf:"varint,3,opt,name=ShuffleColMin,proto3" json:"ShuffleColMin,omitempty"`
	ShuffleColMax        int64    `protobuf:"varint,4,opt,name=ShuffleColMax,proto3" json:"ShuffleColMax,omitempty"`
	AliveRegCnt          int32    `protobuf:"varint,5,opt,name=AliveRegCnt,proto3" json:"AliveRegCnt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Shuffle) Descriptor added in v1.0.0 

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

func (*Shuffle) GetAliveRegCnt added in v1.0.0 

func (m *Shuffle) GetAliveRegCnt() int32

func (*Shuffle) GetShuffleColIdx added in v1.0.0 

func (m *Shuffle) GetShuffleColIdx() int32

func (*Shuffle) GetShuffleColMax added in v1.0.0 

func (m *Shuffle) GetShuffleColMax() int64

func (*Shuffle) GetShuffleColMin added in v1.0.0 

func (m *Shuffle) GetShuffleColMin() int64

func (*Shuffle) GetShuffleType added in v1.0.0 

func (m *Shuffle) GetShuffleType() int32

func (*Shuffle) Marshal added in v1.0.0 

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

func (*Shuffle) MarshalTo added in v1.0.0 

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

func (*Shuffle) MarshalToSizedBuffer added in v1.0.0 

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

func (*Shuffle) ProtoMessage added in v1.0.0 

func (*Shuffle) ProtoMessage()

func (*Shuffle) ProtoSize added in v1.0.0 

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

func (*Shuffle) Reset added in v1.0.0 

func (m *Shuffle) Reset()

func (*Shuffle) String added in v1.0.0 

func (m *Shuffle) String() string

func (*Shuffle) Unmarshal added in v1.0.0 

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

func (*Shuffle) XXX_DiscardUnknown added in v1.0.0 

func (m *Shuffle) XXX_DiscardUnknown()

func (*Shuffle) XXX_Marshal added in v1.0.0 

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

func (*Shuffle) XXX_Merge added in v1.0.0 

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

func (*Shuffle) XXX_Size added in v1.0.0 

func (m *Shuffle) XXX_Size() int

func (*Shuffle) XXX_Unmarshal added in v1.0.0 

func (m *Shuffle) 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"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 131-byte string literal not displayed */
	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) GetRuntimeFilterBuildList added in v1.0.0 

func (m *SingleJoin) GetRuntimeFilterBuildList() []*plan.RuntimeFilterSpec

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"`
	RuntimeFilterProbeList []*plan.RuntimeFilterSpec `` /* 132-byte string literal not displayed */
	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) GetRuntimeFilterProbeList added in v1.0.0 

func (m *Source) GetRuntimeFilterProbeList() []*plan.RuntimeFilterSpec

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 StreamScan added in v1.0.0 

type StreamScan struct {
	TblDef               *plan.TableDef `protobuf:"bytes,1,opt,name=tbl_def,json=tblDef,proto3" json:"tbl_def,omitempty"`
	Offset               int64          `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit                int64          `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StreamScan) Descriptor added in v1.0.0 

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

func (*StreamScan) GetLimit added in v1.0.0 

func (m *StreamScan) GetLimit() int64

func (*StreamScan) GetOffset added in v1.0.0 

func (m *StreamScan) GetOffset() int64

func (*StreamScan) GetTblDef added in v1.0.0 

func (m *StreamScan) GetTblDef() *plan.TableDef

func (*StreamScan) Marshal added in v1.0.0 

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

func (*StreamScan) MarshalTo added in v1.0.0 

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

func (*StreamScan) MarshalToSizedBuffer added in v1.0.0 

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

func (*StreamScan) ProtoMessage added in v1.0.0 

func (*StreamScan) ProtoMessage()

func (*StreamScan) ProtoSize added in v1.0.0 

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

func (*StreamScan) Reset added in v1.0.0 

func (m *StreamScan) Reset()

func (*StreamScan) String added in v1.0.0 

func (m *StreamScan) String() string

func (*StreamScan) Unmarshal added in v1.0.0 

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

func (*StreamScan) XXX_DiscardUnknown added in v1.0.0 

func (m *StreamScan) XXX_DiscardUnknown()

func (*StreamScan) XXX_Marshal added in v1.0.0 

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

func (*StreamScan) XXX_Merge added in v1.0.0 

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

func (*StreamScan) XXX_Size added in v1.0.0 

func (m *StreamScan) XXX_Size() int

func (*StreamScan) XXX_Unmarshal added in v1.0.0 

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

type TableFunction 

type TableFunction struct {
	Attrs                []string       `protobuf:"bytes,1,rep,name=attrs,proto3" json:"attrs,omitempty"`
	Rets                 []*plan.ColDef `protobuf:"bytes,2,rep,name=rets,proto3" json:"rets,omitempty"`
	Args                 []*plan.Expr   `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	Params               []byte         `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
	Name                 string         `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TableFunction) Descriptor 

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

func (*TableFunction) GetArgs added in v0.7.0 

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

func (*TableFunction) GetAttrs 

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

func (*TableFunction) GetName added in v0.7.0 

func (m *TableFunction) GetName() string

func (*TableFunction) GetParams added in v0.7.0 

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

func (*TableFunction) GetRets added in v0.7.0 

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

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

type UuidToRegIdx added in v0.7.0 

type UuidToRegIdx struct {
	Idx                  int32    `protobuf:"varint,1,opt,name=idx,proto3" json:"idx,omitempty"`
	Uuid                 []byte   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	FromAddr             string   `protobuf:"bytes,3,opt,name=from_addr,json=fromAddr,proto3" json:"from_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UuidToRegIdx) Descriptor added in v0.7.0 

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

func (*UuidToRegIdx) GetFromAddr added in v0.7.0 

func (m *UuidToRegIdx) GetFromAddr() string

func (*UuidToRegIdx) GetIdx added in v0.7.0 

func (m *UuidToRegIdx) GetIdx() int32

func (*UuidToRegIdx) GetUuid added in v0.7.0 

func (m *UuidToRegIdx) GetUuid() []byte

func (*UuidToRegIdx) Marshal added in v0.7.0 

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

func (*UuidToRegIdx) MarshalTo added in v0.7.0 

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

func (*UuidToRegIdx) MarshalToSizedBuffer added in v0.7.0 

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

func (*UuidToRegIdx) ProtoMessage added in v0.7.0 

func (*UuidToRegIdx) ProtoMessage()

func (*UuidToRegIdx) ProtoSize added in v0.7.0 

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

func (*UuidToRegIdx) Reset added in v0.7.0 

func (m *UuidToRegIdx) Reset()

func (*UuidToRegIdx) String added in v0.7.0 

func (m *UuidToRegIdx) String() string

func (*UuidToRegIdx) Unmarshal added in v0.7.0 

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

func (*UuidToRegIdx) XXX_DiscardUnknown added in v0.7.0 

func (m *UuidToRegIdx) XXX_DiscardUnknown()

func (*UuidToRegIdx) XXX_Marshal added in v0.7.0 

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

func (*UuidToRegIdx) XXX_Merge added in v0.7.0 

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

func (*UuidToRegIdx) XXX_Size added in v0.7.0 

func (m *UuidToRegIdx) XXX_Size() int

func (*UuidToRegIdx) XXX_Unmarshal added in v0.7.0 

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

type WrapNode added in v0.7.0 

type WrapNode struct {
	NodeAddr             string   `protobuf:"bytes,1,opt,name=node_addr,json=nodeAddr,proto3" json:"node_addr,omitempty"`
	Uuid                 []byte   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WrapNode) Descriptor added in v0.7.0 

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

func (*WrapNode) GetNodeAddr added in v0.7.0 

func (m *WrapNode) GetNodeAddr() string

func (*WrapNode) GetUuid added in v0.7.0 

func (m *WrapNode) GetUuid() []byte

func (*WrapNode) Marshal added in v0.7.0 

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

func (*WrapNode) MarshalTo added in v0.7.0 

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

func (*WrapNode) MarshalToSizedBuffer added in v0.7.0 

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

func (*WrapNode) ProtoMessage added in v0.7.0 

func (*WrapNode) ProtoMessage()

func (*WrapNode) ProtoSize added in v0.7.0 

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

func (*WrapNode) Reset added in v0.7.0 

func (m *WrapNode) Reset()

func (*WrapNode) String added in v0.7.0 

func (m *WrapNode) String() string

func (*WrapNode) Unmarshal added in v0.7.0 

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

func (*WrapNode) XXX_DiscardUnknown added in v0.7.0 

func (m *WrapNode) XXX_DiscardUnknown()

func (*WrapNode) XXX_Marshal added in v0.7.0 

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

func (*WrapNode) XXX_Merge added in v0.7.0 

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

func (*WrapNode) XXX_Size added in v0.7.0 

func (m *WrapNode) XXX_Size() int

func (*WrapNode) XXX_Unmarshal added in v0.7.0 

func (m *WrapNode) 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.