process

Jun 28, 2024

Changes in this version

+ var NormalEndRegisterMessage = NewRegMsg(nil)

type Process

+ CloneTxnOperator client.TxnOperator

+ func (proc *Process) Debug(ctx context.Context, msg string, fields ...zap.Field)

+ func (proc *Process) Debugf(ctx context.Context, msg string, args ...any)

+ func (proc *Process) Error(ctx context.Context, msg string, fields ...zap.Field)

+ func (proc *Process) Errorf(ctx context.Context, msg string, args ...any)

+ func (proc *Process) Fatal(ctx context.Context, msg string, fields ...zap.Field)

+ func (proc *Process) Fatalf(ctx context.Context, msg string, args ...any)

+ func (proc *Process) GetCloneTxnOperator() client.TxnOperator

+ func (proc *Process) Info(ctx context.Context, msg string, fields ...zap.Field)

+ func (proc *Process) Infof(ctx context.Context, msg string, args ...any)

+ func (proc *Process) SetCloneTxnOperator(op client.TxnOperator)

+ func (proc *Process) Warn(ctx context.Context, msg string, fields ...zap.Field)

+ func (proc *Process) Warnf(ctx context.Context, msg string, args ...any)

+ type RegisterMessage struct

+ Batch *batch.Batch

+ Err error

+ func NewRegMsg(bat *batch.Batch) *RegisterMessage

type SessionInfo

+ LogLevel zapcore.Level

+ SessionId uuid.UUID

type StmtProfile

+ func NewStmtProfile(txnId, stmtId uuid.UUID) *StmtProfile

May 17, 2024

Changes in this version

+ const ALLCN

+ const CURRENTCN

+ const DefaultBatchSize

+ const RuntimeFilter_BINARY_FUSE

+ const RuntimeFilter_BITMAP

+ const RuntimeFilter_DROP

+ const RuntimeFilter_IN

+ const RuntimeFilter_MIN_MAX

+ const RuntimeFilter_PASS

+ func MatchAddress(m Message, raddr *MessageAddress) bool

type AnalyzeInfo

+ func (a AnalyzeInfo) TypeName() string

+ type Message interface

+ Deserialize func([]byte) Message

+ GetMsgTag func() int32

+ GetReceiverAddr func() MessageAddress

+ NeedBlock func() bool

+ Serialize func() []byte

+ type MessageAddress struct

+ CnAddr string

+ OperatorID int32

+ ParallelID int32

+ func AddrBroadCastOnALLCN() MessageAddress

+ func AddrBroadCastOnCurrentCN() MessageAddress

+ type MessageBoard struct

+ Messages []*Message

+ RwMutex *sync.RWMutex

+ Waiters []chan bool

+ func NewMessageBoard() *MessageBoard

+ func (m *MessageBoard) Reset()

+ type MessageReceiver struct

+ func (mr *MessageReceiver) Free()

+ func (mr *MessageReceiver) ReceiveMessage(needBlock bool, ctx context.Context) ([]Message, bool)

+ type MsgType int32

+ const MaxMessage

+ const MsgHashMap

+ const MsgPipelineStart

+ const MsgPipelineStop

+ const MsgRuntimeFilter

+ const MsgTopValue

+ func (m MsgType) MessageName() string

type Process

+ MessageBoard *MessageBoard

+ QueryClient qclient.QueryClient

+ WaitPolicy lock.WaitPolicy

+ func (proc *Process) AppendToFixedSizeFromOffset(dst *batch.Batch, src *batch.Batch, offset int) (*batch.Batch, int, error)

+ func (proc *Process) FinalizeRuntimeFilter(m *plan.RuntimeFilterSpec)

+ func (proc *Process) NewBatchFromSrc(src *batch.Batch, preAllocSize int) (*batch.Batch, error)

+ func (proc *Process) NewMessageReceiver(tags []int32, addr MessageAddress) *MessageReceiver

+ func (proc *Process) SendMessage(m Message)

+ func (proc *Process) SendRuntimeFilter(rt RuntimeFilterMessage, m *plan.RuntimeFilterSpec)

+ type RuntimeFilterMessage struct

+ Card int32

+ Data []byte

+ Tag int32

+ Typ int32

+ func (rt RuntimeFilterMessage) Deserialize([]byte) Message

+ func (rt RuntimeFilterMessage) GetMsgTag() int32

+ func (rt RuntimeFilterMessage) GetReceiverAddr() MessageAddress

+ func (rt RuntimeFilterMessage) NeedBlock() bool

+ func (rt RuntimeFilterMessage) Serialize() []byte

+ type TopValueMessage struct

+ Tag int32

+ TopValueZM objectio.ZoneMap

+ func (t TopValueMessage) Deserialize([]byte) Message

+ func (t TopValueMessage) GetMsgTag() int32

+ func (t TopValueMessage) GetReceiverAddr() MessageAddress

+ func (t TopValueMessage) NeedBlock() bool

+ func (t TopValueMessage) Serialize() []byte

Dec 29, 2023

Changes in this version

type Analyze

+ ChildrenCallStop func(time.Time)

type AnalyzeInfo

+ TimeConsumedArrayMajor []int64

+ TimeConsumedArrayMinor []int64

+ func (a *AnalyzeInfo) AddNewParallel(major bool) int

+ func (a *AnalyzeInfo) AddSingleParallelTimeConsumed(major bool, parallelIdx int, t int64)

+ func (a *AnalyzeInfo) DeepCopyArray(pa *plan.AnalyzeInfo)

+ func (a *AnalyzeInfo) MergeArray(pa *plan.AnalyzeInfo)

+ func (a AnalyzeInfo) Name() string

type Process

+ Hakeeper logservice.CNHAKeeperClient

+ UdfService udf.Service

type SessionInfo

+ SourceInMemScanBatch []*kafka.Message

type WrapCs

+ Err chan error

Nov 13, 2023

Changes in this version

+ const ExecHasMore

+ const ExecNext

+ const ExecStop

type AnalyzeInfo

+ func (a *AnalyzeInfo) Reset()

+ type ExecStatus int

type Process

+ QueryService queryservice.QueryService

+ StmtProfile *StmtProfile

+ func (proc *Process) CleanValueScanBatchs()

+ func (proc *Process) GetStmtProfile() *StmtProfile

+ func (proc *Process) SetStmtProfile(sp *StmtProfile)

+ func (proc *Process) SetVectorPoolSize(limit int)

type SessionInfo

+ Buf *buffer.Buffer

+ type StmtProfile struct

+ func (sp *StmtProfile) Clear()

+ func (sp *StmtProfile) GetQueryStart() time.Time

+ func (sp *StmtProfile) GetQueryType() string

+ func (sp *StmtProfile) GetSqlOfStmt() string

+ func (sp *StmtProfile) GetSqlSourceType() string

+ func (sp *StmtProfile) GetStmtId() uuid.UUID

+ func (sp *StmtProfile) GetStmtType() string

+ func (sp *StmtProfile) GetTxnId() uuid.UUID

+ func (sp *StmtProfile) SetQueryStart(t time.Time)

+ func (sp *StmtProfile) SetQueryType(qt string)

+ func (sp *StmtProfile) SetSqlOfStmt(sot string)

+ func (sp *StmtProfile) SetSqlSourceType(st string)

+ func (sp *StmtProfile) SetStmtId(id uuid.UUID)

+ func (sp *StmtProfile) SetStmtType(st string)

+ func (sp *StmtProfile) SetTxnId(id []byte)

type WaitRegister

+ func (wreg *WaitRegister) CleanChannel(m *mpool.MPool)

Jun 30, 2023

Changes in this version

+ const VectorLimit

type Analyze

+ S3IOInputCount func(int)

+ S3IOOutputCount func(int)

type AnalyzeInfo

+ S3IOInputCount int64

+ S3IOOutputCount int64

type Process

+ Aicm *defines.AutoIncrCacheManager

+ IncrService incrservice.AutoIncrementService

+ LockService lockservice.LockService

+ func (proc *Process) CopyValueScanBatch(src *Process)

+ func (proc *Process) CopyVectorPool(src *Process)

+ func (proc *Process) FreeVectors()

+ func (proc *Process) GetPrepareBatch() *batch.Batch

+ func (proc *Process) GetPrepareExprList() any

+ func (proc *Process) GetPrepareParams() *vector.Vector

+ func (proc *Process) GetPrepareParamsAt(i int) (*vector.Vector, error)

+ func (proc *Process) GetResolveVariableFunc() func(varName string, isSystemVar, isGlobalVar bool) (interface{}, error)

+ func (proc *Process) GetSessionInfo() *SessionInfo

+ func (proc *Process) GetValueScanBatch(key uuid.UUID) *batch.Batch

+ func (proc *Process) GetValueScanBatchs() []*batch.Batch

+ func (proc *Process) GetVector(typ types.Type) *vector.Vector

+ func (proc *Process) InitSeq()

+ func (proc *Process) PutBatch(bat *batch.Batch)

+ func (proc *Process) PutVector(vec *vector.Vector)

+ func (proc *Process) ResetContextFromParent(parent context.Context) context.Context

+ func (proc *Process) SetCacheForAutoCol(name string)

+ func (proc *Process) SetPrepareBatch(bat *batch.Batch)

+ func (proc *Process) SetPrepareExprList(exprList any)

+ func (proc *Process) SetPrepareParams(prepareParams *vector.Vector)

+ func (proc *Process) SetResolveVariableFunc(f func(varName string, isSystemVar, isGlobalVar bool) (interface{}, error))

+ func (proc *Process) SetValueScanBatch(key uuid.UUID, batch *batch.Batch)

type SessionInfo

+ SeqAddValues map[uint64]string

+ SeqCurValues map[uint64]string

+ SeqDeleteKeys []uint64

+ SeqLastValue []string

+ SqlHelper sqlHelper

Feb 18, 2023

Changes in this version

type Analyze

+ AddInsertTime func(t time.Time)

+ AddScanTime func(t time.Time)

+ DiskIO func(*batch.Batch)

+ Network func(*batch.Batch)

+ S3IOByte func(*batch.Batch)

+ S3IOCount func(int)

+ WaitStop func(time.Time)

type AnalyzeInfo

+ DiskIO int64

+ InsertTime int64

+ NetworkIO int64

+ S3IOByte int64

+ S3IOCount int64

+ ScanTime int64

+ WaitTimeConsumed int64

type Process

+ DispatchNotifyCh chan WrapCs

+ LastInsertID *uint64

+ LoadLocalReader *io.PipeReader

+ func (proc *Process) GetLastInsertID() uint64

+ func (proc *Process) SetLastInsertID(num uint64)

+ func (proc *Process) WithSpanContext(sc trace.SpanContext)

type SessionInfo

+ Account string

+ AutoIncrCacheSize uint64

+ AutoIncrCaches defines.AutoIncrCaches

+ LastInsertID uint64

+ QueryId []string

+ ResultColTypes []types.Type

+ type WrapCs struct

+ Cs morpc.ClientSession

+ DoneCh chan struct{}

+ MsgId uint64

+ Uid uuid.UUID

Nov 29, 2022

Changes in this version

+ type Analyze interface

+ Alloc func(int64)

+ Input func(*batch.Batch)

+ Output func(*batch.Batch)

+ Start func()

+ Stop func()

type AnalyzeInfo

+ func NewAnalyzeInfo(nodeId int32) *AnalyzeInfo

type Limitation

+ MaxMsgSize uint64

type Process

+ AnalInfos []*AnalyzeInfo

+ Ctx context.Context

+ FileService fileservice.FileService

+ GetClusterDetails engine.GetClusterDetailsFunc

+ LoadTag bool

+ TxnClient client.TxnClient

+ TxnOperator client.TxnOperator

+ func NewWithAnalyze(p *Process, ctx context.Context, regNumber int, anals []*AnalyzeInfo) *Process

+ func (proc *Process) AllocBoolScalarVector(v bool) *vector.Vector

+ func (proc *Process) AllocInt64ScalarVector(v int64) *vector.Vector

+ func (proc *Process) AllocVectorOfRows(typ types.Type, nele int64, nsp *nulls.Nulls) (*vector.Vector, error)

+ func (proc *Process) GetAnalyze(idx int) Analyze

+ func (proc *Process) GetMPool() *mpool.MPool

+ func (proc *Process) InputBatch() *batch.Batch

+ func (proc *Process) MarshalBinary() ([]byte, error)

+ func (proc *Process) OperatorOutofMemory(size int64) bool

+ func (proc *Process) QueryId() string

+ func (proc *Process) SetInputBatch(bat *batch.Batch)

+ func (proc *Process) SetQueryId(id string)

+ func (proc *Process) UnmarshalBinary(_ []byte) error

type SessionInfo

+ AccountId uint32

+ RoleId uint32

+ StorageEngine engine.Engine

+ TimeZone *time.Location

+ UserId uint32

type WaitRegister

+ func (wreg *WaitRegister) MarshalBinary() ([]byte, error)

+ func (wreg *WaitRegister) UnmarshalBinary(_ []byte) error

Aug 17, 2022

Changes in this version

+ type AnalyzeInfo struct

+ InputRows int64

+ InputSize int64

+ MemorySize int64

+ NodeId int32

+ OutputRows int64

+ OutputSize int64

+ TimeConsumed int64

type Limitation

+ ReaderSize int64

type Process

+ AnalInfo *AnalyzeInfo

+ func (proc *Process) AllocConstNullVector(typ types.Type, cnt int) *vector.Vector

Jul 14, 2022

Changes in this version

type Process

+ SessionInfo SessionInfo

+ Snapshot []byte

+ UnixTime int64

+ func NewFromProc(m *mheap.Mheap, p *Process, regNumber int) *Process

+ func (proc *Process) AllocScalarNullVector(typ types.Type) *vector.Vector

+ func (proc *Process) AllocScalarVector(typ types.Type) *vector.Vector

+ func (proc *Process) AllocVector(typ types.Type, size int64) (*vector.Vector, error)

+ func (proc *Process) GetBoolTyp(typ types.Type) (typ2 types.Type)

+ type SessionInfo struct

+ ConnectionID uint64

+ Database string

+ Host string

+ Role string

+ User string

+ Version string

+ func (si *SessionInfo) GetCharset() string

+ func (si *SessionInfo) GetCollation() string

+ func (si *SessionInfo) GetConnectionID() uint64

+ func (si *SessionInfo) GetDatabase() string

+ func (si *SessionInfo) GetHost() string

+ func (si *SessionInfo) GetRole() string

+ func (si *SessionInfo) GetUser() string

+ func (si *SessionInfo) GetUserHost() string

+ func (si *SessionInfo) GetVersion() string

May 5, 2022

Changes in this version

+ func FreeRegisters(proc *Process)

+ func Get(proc *Process, size int64, typ types.Type) (*vector.Vector, error)

+ func GetSels(proc *Process) []int64

+ func Put(proc *Process, vec *vector.Vector)

+ func PutSels(sels []int64, proc *Process)

+ type Limitation struct

+ BatchRows int64

+ BatchSize int64

+ PartitionRows int64

+ Size int64

+ type Process struct

+ Cancel context.CancelFunc

+ Id string

+ Lim Limitation

+ Mp *mheap.Mheap

+ Reg Register

+ func New(m *mheap.Mheap) *Process

+ type Register struct

+ InputBatch *batch.Batch

+ MergeReceivers []*WaitRegister

+ Ss [][]int64

+ Vecs []*vector.Vector

+ type WaitRegister struct

+ Ch chan *batch.Batch

+ Ctx context.Context