pipeline

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,rep,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:"-"`
}

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:"-"`
}

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

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:"-"`
}

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:"-"`
}

type DedupJoin 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"`
	LeftCond               []*plan.Expr                `protobuf:"bytes,3,rep,name=left_cond,json=leftCond,proto3" json:"left_cond,omitempty"`
	RightCond              []*plan.Expr                `protobuf:"bytes,4,rep,name=right_cond,json=rightCond,proto3" json:"right_cond,omitempty"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec   `` /* 131-byte string literal not displayed */
	IsShuffle              bool                        `protobuf:"varint,6,opt,name=is_shuffle,json=isShuffle,proto3" json:"is_shuffle,omitempty"`
	JoinMapTag             int32                       `protobuf:"varint,7,opt,name=join_map_tag,json=joinMapTag,proto3" json:"join_map_tag,omitempty"`
	ShuffleIdx             int32                       `protobuf:"varint,8,opt,name=shuffle_idx,json=shuffleIdx,proto3" json:"shuffle_idx,omitempty"`
	OnDuplicateAction      plan.Node_OnDuplicateAction `` /* 148-byte string literal not displayed */
	DedupColName           string                      `protobuf:"bytes,10,opt,name=dedup_col_name,json=dedupColName,proto3" json:"dedup_col_name,omitempty"`
	DedupColTypes          []plan.Type                 `protobuf:"bytes,11,rep,name=dedup_col_types,json=dedupColTypes,proto3" json:"dedup_col_types"`
	LeftTypes              []plan.Type                 `protobuf:"bytes,12,rep,name=left_types,json=leftTypes,proto3" json:"left_types"`
	RightTypes             []plan.Type                 `protobuf:"bytes,13,rep,name=right_types,json=rightTypes,proto3" json:"right_types"`
	UpdateColIdxList       []int32                     `protobuf:"varint,14,rep,packed,name=update_col_idx_list,json=updateColIdxList,proto3" json:"update_col_idx_list,omitempty"`
	UpdateColExprList      []*plan.Expr                `protobuf:"bytes,15,rep,name=update_col_expr_list,json=updateColExprList,proto3" json:"update_col_expr_list,omitempty"`
	DelColIdx              int32                       `protobuf:"varint,16,opt,name=del_col_idx,json=delColIdx,proto3" json:"del_col_idx,omitempty"`
	// Parallel arrays for the REPLACE INTO merged main-table scan. Each entry
	// at index i means: at probe time, when the build bucket for a row is hit,
	// capture left (probe) column old_col_capture_probe_idx_list[i] and emit
	// it in finalize() into right (build) column old_col_capture_placeholder_idx_list[i].
	OldColCapturePlaceholderIdxList []int32  `` /* 171-byte string literal not displayed */
	OldColCaptureProbeIdxList       []int32  `` /* 153-byte string literal not displayed */
	DedupBuildKeepLast              bool     `protobuf:"varint,19,opt,name=dedup_build_keep_last,json=dedupBuildKeepLast,proto3" json:"dedup_build_keep_last,omitempty"`
	DedupDeleteKeepColIdxList       []int32  `` /* 153-byte string literal not displayed */
	DedupDeleteMarkerColIdx         int32    `` /* 138-byte string literal not displayed */
	XXX_NoUnkeyedLiteral            struct{} `json:"-"`
	XXX_unrecognized                []byte   `json:"-"`
	XXX_sizecache                   int32    `json:"-"`
}

type Deletion struct {
	AffectedRows uint64 `protobuf:"varint,1,opt,name=AffectedRows,proto3" json:"AffectedRows,omitempty"`
	RemoteDelete bool   `protobuf:"varint,2,opt,name=RemoteDelete,proto3" json:"RemoteDelete,omitempty"`
	IBucket      uint32 `protobuf:"varint,3,opt,name=IBucket,proto3" json:"IBucket,omitempty"`
	NBucket      uint32 `protobuf:"varint,4,opt,name=NBucket,proto3" json:"NBucket,omitempty"`
	// DeleteCtx
	RowIdIdx              int32            `protobuf:"varint,5,opt,name=row_id_idx,json=rowIdIdx,proto3" json:"row_id_idx,omitempty"`
	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"`
	PartitionIndexInBatch int32            `` /* 129-byte string literal not displayed */
	Ref                   *plan.ObjectRef  `protobuf:"bytes,9,opt,name=ref,proto3" json:"ref,omitempty"`
	AddAffectedRows       bool             `protobuf:"varint,10,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,12,opt,name=can_truncate,json=canTruncate,proto3" json:"can_truncate,omitempty"`
	IsEnd                 bool             `protobuf:"varint,13,opt,name=is_end,json=isEnd,proto3" json:"is_end,omitempty"`
	PrimaryKeyIdx         int32            `protobuf:"varint,14,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:"-"`
}

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"`
	RecCte               bool         `protobuf:"varint,9,opt,name=rec_cte,json=recCte,proto3" json:"rec_cte,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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:"-"`
}

type ExternalScan struct {
	Attrs                  []plan.ExternAttr       `protobuf:"bytes,1,rep,name=attrs,proto3" json:"attrs"`
	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"`
	CreateSql              string                  `protobuf:"bytes,5,opt,name=create_sql,json=createSql,proto3" json:"create_sql,omitempty"`
	FileList               []string                `protobuf:"bytes,6,rep,name=file_list,json=fileList,proto3" json:"file_list,omitempty"`
	OriginCols             []*plan.ColDef          `protobuf:"bytes,7,rep,name=origin_cols,json=originCols,proto3" json:"origin_cols,omitempty"`
	Filter                 *plan.Expr              `protobuf:"bytes,8,opt,name=filter,proto3" json:"filter,omitempty"`
	StrictSqlMode          bool                    `protobuf:"varint,9,opt,name=strict_sql_mode,json=strictSqlMode,proto3" json:"strict_sql_mode,omitempty"`
	ColumnListLen          int32                   `protobuf:"varint,10,opt,name=column_list_len,json=columnListLen,proto3" json:"column_list_len,omitempty"`
	ParallelLoad           bool                    `protobuf:"varint,11,opt,name=parallel_load,json=parallelLoad,proto3" json:"parallel_load,omitempty"`
	LoadEmptyNumericAsZero bool                    `` /* 135-byte string literal not displayed */
	ParquetRowGroupShards  []*ParquetRowGroupShard `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                `json:"-"`
	XXX_unrecognized       []byte                  `json:"-"`
	XXX_sizecache          int32                   `json:"-"`
}

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:"-"`
}

type FuzzyFilter struct {
	N                    float32   `protobuf:"fixed32,1,opt,name=N,proto3" json:"N,omitempty"`
	PkName               string    `protobuf:"bytes,2,opt,name=PkName,proto3" json:"PkName,omitempty"`
	PkTyp                plan.Type `protobuf:"bytes,3,opt,name=PkTyp,proto3" json:"PkTyp"`
	BuildIdx             int32     `protobuf:"varint,4,opt,name=BuildIdx,proto3" json:"BuildIdx,omitempty"`
	IfInsertFromUnique   bool      `protobuf:"varint,5,opt,name=IfInsertFromUnique,proto3" json:"IfInsertFromUnique,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

type Group struct {
	NeedEval             bool             `protobuf:"varint,1,opt,name=need_eval,json=needEval,proto3" json:"need_eval,omitempty"`
	Exprs                []*plan.Expr     `protobuf:"bytes,2,rep,name=exprs,proto3" json:"exprs,omitempty"`
	Types                []plan.Type      `protobuf:"bytes,3,rep,name=types,proto3" json:"types"`
	Aggs                 []*Aggregate     `protobuf:"bytes,4,rep,name=aggs,proto3" json:"aggs,omitempty"`
	MultiAggs            []*MultiArguemnt `protobuf:"bytes,5,rep,name=MultiAggs,proto3" json:"MultiAggs,omitempty"`
	IsShuffle            bool             `protobuf:"varint,6,opt,name=isShuffle,proto3" json:"isShuffle,omitempty"`
	PreAllocSize         uint64           `protobuf:"varint,7,opt,name=preAllocSize,proto3" json:"preAllocSize,omitempty"`
	PartialResults       []byte           `protobuf:"bytes,8,opt,name=PartialResults,proto3" json:"PartialResults,omitempty"`
	PartialResultTypes   []uint32         `protobuf:"varint,9,rep,packed,name=PartialResultTypes,proto3" json:"PartialResultTypes,omitempty"`
	GroupingFlag         []bool           `protobuf:"varint,10,rep,packed,name=grouping_flag,json=groupingFlag,proto3" json:"grouping_flag,omitempty"`
	SpillMem             int64            `protobuf:"varint,11,opt,name=spill_mem,json=spillMem,proto3" json:"spill_mem,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

type HashBuild struct {
	NeedHashMap               bool                        `protobuf:"varint,1,opt,name=need_hash_map,json=needHashMap,proto3" json:"need_hash_map,omitempty"`
	HashOnPk                  bool                        `protobuf:"varint,2,opt,name=hash_on_pk,json=hashOnPk,proto3" json:"hash_on_pk,omitempty"`
	NeedBatches               bool                        `protobuf:"varint,3,opt,name=need_batches,json=needBatches,proto3" json:"need_batches,omitempty"`
	NeedAllocateSels          bool                        `protobuf:"varint,4,opt,name=need_allocate_sels,json=needAllocateSels,proto3" json:"need_allocate_sels,omitempty"`
	IsShuffle                 bool                        `protobuf:"varint,5,opt,name=is_shuffle,json=isShuffle,proto3" json:"is_shuffle,omitempty"`
	Conditions                []*plan.Expr                `protobuf:"bytes,6,rep,name=conditions,proto3" json:"conditions,omitempty"`
	JoinMapTag                int32                       `protobuf:"varint,7,opt,name=join_map_tag,json=joinMapTag,proto3" json:"join_map_tag,omitempty"`
	JoinMapRefCnt             int32                       `protobuf:"varint,8,opt,name=join_map_ref_cnt,json=joinMapRefCnt,proto3" json:"join_map_ref_cnt,omitempty"`
	ShuffleIdx                int32                       `protobuf:"varint,9,opt,name=shuffle_idx,json=shuffleIdx,proto3" json:"shuffle_idx,omitempty"`
	RuntimeFilterSpec         *plan.RuntimeFilterSpec     `protobuf:"bytes,10,opt,name=runtime_filter_spec,json=runtimeFilterSpec,proto3" json:"runtime_filter_spec,omitempty"`
	IsDedup                   bool                        `protobuf:"varint,11,opt,name=is_dedup,json=isDedup,proto3" json:"is_dedup,omitempty"`
	OnDuplicateAction         plan.Node_OnDuplicateAction `` /* 149-byte string literal not displayed */
	DedupColName              string                      `protobuf:"bytes,13,opt,name=dedup_col_name,json=dedupColName,proto3" json:"dedup_col_name,omitempty"`
	DedupColTypes             []plan.Type                 `protobuf:"bytes,14,rep,name=dedup_col_types,json=dedupColTypes,proto3" json:"dedup_col_types"`
	DelColIdx                 int32                       `protobuf:"varint,15,opt,name=del_col_idx,json=delColIdx,proto3" json:"del_col_idx,omitempty"`
	DedupBuildKeepLast        bool                        `protobuf:"varint,16,opt,name=dedup_build_keep_last,json=dedupBuildKeepLast,proto3" json:"dedup_build_keep_last,omitempty"`
	DedupDeleteMarkerColIdx   int32                       `` /* 138-byte string literal not displayed */
	DedupDeleteKeepColIdxList []int32                     `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}                    `json:"-"`
	XXX_unrecognized          []byte                      `json:"-"`
	XXX_sizecache             int32                       `json:"-"`
}

type HashJoin struct {
	JoinType               plan.Node_JoinType        `protobuf:"varint,1,opt,name=join_type,json=joinType,proto3,enum=plan.Node_JoinType" json:"join_type,omitempty"`
	IsRightJoin            bool                      `protobuf:"varint,2,opt,name=is_right_join,json=isRightJoin,proto3" json:"is_right_join,omitempty"`
	HashOnPk               bool                      `protobuf:"varint,3,opt,name=hash_on_pk,json=hashOnPk,proto3" json:"hash_on_pk,omitempty"`
	IsShuffle              bool                      `protobuf:"varint,4,opt,name=is_shuffle,json=isShuffle,proto3" json:"is_shuffle,omitempty"`
	CanSkipProbe           bool                      `protobuf:"varint,5,opt,name=can_skip_probe,json=canSkipProbe,proto3" json:"can_skip_probe,omitempty"`
	ShuffleIdx             int32                     `protobuf:"varint,6,opt,name=shuffle_idx,json=shuffleIdx,proto3" json:"shuffle_idx,omitempty"`
	RelList                []int32                   `protobuf:"varint,7,rep,packed,name=rel_list,json=relList,proto3" json:"rel_list,omitempty"`
	ColList                []int32                   `protobuf:"varint,8,rep,packed,name=col_list,json=colList,proto3" json:"col_list,omitempty"`
	LeftConds              []*plan.Expr              `protobuf:"bytes,9,rep,name=left_conds,json=leftConds,proto3" json:"left_conds,omitempty"`
	RightConds             []*plan.Expr              `protobuf:"bytes,10,rep,name=right_conds,json=rightConds,proto3" json:"right_conds,omitempty"`
	NonEqCond              *plan.Expr                `protobuf:"bytes,11,opt,name=non_eq_cond,json=nonEqCond,proto3" json:"non_eq_cond,omitempty"`
	LeftTypes              []plan.Type               `protobuf:"bytes,12,rep,name=left_types,json=leftTypes,proto3" json:"left_types"`
	RightTypes             []plan.Type               `protobuf:"bytes,13,rep,name=right_types,json=rightTypes,proto3" json:"right_types"`
	JoinMapTag             int32                     `protobuf:"varint,14,opt,name=join_map_tag,json=joinMapTag,proto3" json:"join_map_tag,omitempty"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                  `json:"-"`
	XXX_unrecognized       []byte                    `json:"-"`
	XXX_sizecache          int32                     `json:"-"`
}

type IndexJoin struct {
	Result                 []int32                   `protobuf:"varint,1,rep,packed,name=result,proto3" json:"result,omitempty"`
	RuntimeFilterBuildList []*plan.RuntimeFilterSpec `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                  `json:"-"`
	XXX_unrecognized       []byte                    `json:"-"`
	XXX_sizecache          int32                     `json:"-"`
}

type Indexbuild struct {
	RuntimeFilterSpec    *plan.RuntimeFilterSpec `protobuf:"bytes,1,opt,name=runtime_filter_spec,json=runtimeFilterSpec,proto3" json:"runtime_filter_spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

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"`
	// Writable external table: this insert writes stage files instead of an
	// engine relation. The writer config is rebuilt on the receiving CN from
	// table_def's stored ExternParam; the statement-start timestamp (used to
	// expand WRITE_FILE_PATTERN time directives consistently) and the session
	// time zone (name + offset-at-statement-time fallback; the generic session
	// codec round-trips zones lossily) travel here.
	ToExternal           bool     `protobuf:"varint,11,opt,name=to_external,json=toExternal,proto3" json:"to_external,omitempty"`
	ExternalStmtUnixNano int64    `` /* 127-byte string literal not displayed */
	ExternalTzName       string   `protobuf:"bytes,13,opt,name=external_tz_name,json=externalTzName,proto3" json:"external_tz_name,omitempty"`
	ExternalTzOffsetSec  int32    `protobuf:"varint,14,opt,name=external_tz_offset_sec,json=externalTzOffsetSec,proto3" json:"external_tz_offset_sec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	Connect         *Connector          `protobuf:"bytes,3,opt,name=connect,proto3" json:"connect,omitempty"`
	Dispatch        *Dispatch           `protobuf:"bytes,4,opt,name=dispatch,proto3" json:"dispatch,omitempty"`
	Agg             *Group              `protobuf:"bytes,5,opt,name=agg,proto3" json:"agg,omitempty"`
	HashJoin        *HashJoin           `protobuf:"bytes,6,opt,name=hash_join,json=hashJoin,proto3" json:"hash_join,omitempty"`
	LoopJoin        *LoopJoin           `protobuf:"bytes,7,opt,name=loop_join,json=loopJoin,proto3" json:"loop_join,omitempty"`
	SetOp           *SetOp              `protobuf:"bytes,8,opt,name=set_op,json=setOp,proto3" json:"set_op,omitempty"`
	DedupJoin       *DedupJoin          `protobuf:"bytes,9,opt,name=dedup_join,json=dedupJoin,proto3" json:"dedup_join,omitempty"`
	RightDedupJoin  *RightDedupJoin     `protobuf:"bytes,10,opt,name=right_dedup_join,json=rightDedupJoin,proto3" json:"right_dedup_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"`
	ExternalScan    *ExternalScan       `protobuf:"bytes,15,opt,name=external_scan,json=externalScan,proto3" json:"external_scan,omitempty"`
	Insert          *Insert             `protobuf:"bytes,16,opt,name=insert,proto3" json:"insert,omitempty"`
	PreInsert       *PreInsert          `protobuf:"bytes,18,opt,name=pre_insert,json=preInsert,proto3" json:"pre_insert,omitempty"`
	PreInsertUnique *PreInsertUnique    `protobuf:"bytes,19,opt,name=pre_insert_unique,json=preInsertUnique,proto3" json:"pre_insert_unique,omitempty"`
	OrderBy         []*plan.OrderBySpec `protobuf:"bytes,20,rep,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	ProjectList     []*plan.Expr        `protobuf:"bytes,21,rep,name=project_list,json=projectList,proto3" json:"project_list,omitempty"`
	Filters         []*plan.Expr        `protobuf:"bytes,22,rep,name=filters,proto3" json:"filters,omitempty"`
	RuntimeFilters  []*plan.Expr        `protobuf:"bytes,23,rep,name=runtime_filters,json=runtimeFilters,proto3" json:"runtime_filters,omitempty"`
	Limit           *plan.Expr          `protobuf:"bytes,24,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset          *plan.Expr          `protobuf:"bytes,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"`
	Delete                  *Deletion                `protobuf:"bytes,32,opt,name=delete,proto3" json:"delete,omitempty"`
	LockOp                  *LockOp                  `protobuf:"bytes,33,opt,name=lock_op,json=lockOp,proto3" json:"lock_op,omitempty"`
	Shuffle                 *Shuffle                 `protobuf:"bytes,34,opt,name=shuffle,proto3" json:"shuffle,omitempty"`
	Merge                   *Merge                   `protobuf:"bytes,35,opt,name=merge,proto3" json:"merge,omitempty"`
	StreamScan              *StreamScan              `protobuf:"bytes,36,opt,name=stream_scan,json=streamScan,proto3" json:"stream_scan,omitempty"`
	PreInsertSecondaryIndex *PreInsertSecondaryIndex `` /* 135-byte string literal not displayed */
	SampleFunc              *SampleFunc              `protobuf:"bytes,38,opt,name=sample_func,json=sampleFunc,proto3" json:"sample_func,omitempty"`
	FuzzyFilter             *FuzzyFilter             `protobuf:"bytes,39,opt,name=fuzzy_filter,json=fuzzyFilter,proto3" json:"fuzzy_filter,omitempty"`
	CnAddr                  string                   `protobuf:"bytes,40,opt,name=cn_addr,json=cnAddr,proto3" json:"cn_addr,omitempty"`
	OperatorId              int32                    `protobuf:"varint,41,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	ParallelId              int32                    `protobuf:"varint,42,opt,name=parallel_id,json=parallelId,proto3" json:"parallel_id,omitempty"`
	MaxParallel             int32                    `protobuf:"varint,43,opt,name=max_parallel,json=maxParallel,proto3" json:"max_parallel,omitempty"`
	IndexJoin               *IndexJoin               `protobuf:"bytes,44,opt,name=index_join,json=indexJoin,proto3" json:"index_join,omitempty"`
	ProductL2               *ProductL2               `protobuf:"bytes,45,opt,name=product_l2,json=productL2,proto3" json:"product_l2,omitempty"`
	TableScan               *TableScan               `protobuf:"bytes,46,opt,name=table_scan,json=tableScan,proto3" json:"table_scan,omitempty"`
	ValueScan               *ValueScan               `protobuf:"bytes,47,opt,name=value_scan,json=valueScan,proto3" json:"value_scan,omitempty"`
	UnionAll                *UnionAll                `protobuf:"bytes,48,opt,name=union_all,json=unionAll,proto3" json:"union_all,omitempty"`
	HashBuild               *HashBuild               `protobuf:"bytes,49,opt,name=hash_build,json=hashBuild,proto3" json:"hash_build,omitempty"`
	IndexBuild              *Indexbuild              `protobuf:"bytes,50,opt,name=index_build,json=indexBuild,proto3" json:"index_build,omitempty"`
	Apply                   *Apply                   `protobuf:"bytes,51,opt,name=apply,proto3" json:"apply,omitempty"`
	MultiUpdate             *MultiUpdate             `protobuf:"bytes,52,opt,name=multi_update,json=multiUpdate,proto3" json:"multi_update,omitempty"`
	PostDml                 *PostDml                 `protobuf:"bytes,53,opt,name=post_dml,json=postDml,proto3" json:"post_dml,omitempty"`
	SpillMem                int64                    `protobuf:"varint,54,opt,name=spill_mem,json=spillMem,proto3" json:"spill_mem,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}                 `json:"-"`
	XXX_unrecognized        []byte                   `json:"-"`
	XXX_sizecache           int32                    `json:"-"`
}