Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregateOperator ¶
type AggregateOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
AggregateOperator 聚合算子
func NewAggregateOperator ¶
func NewAggregateOperator(p *plan.Plan, das dataaccess.Service) (*AggregateOperator, error)
NewAggregateOperator 创建聚合算子
func (*AggregateOperator) Execute ¶
func (op *AggregateOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行聚合
type BaseOperator ¶
type BaseOperator struct {
// contains filtered or unexported fields
}
BaseOperator 算子基类
func NewBaseOperator ¶
func NewBaseOperator(p *plan.Plan, das dataaccess.Service) *BaseOperator
NewBaseOperator 创建算子基类
func (*BaseOperator) BuildChildOperators ¶
BuildChildOperators 构建子算子
func (*BaseOperator) GetChildren ¶
func (op *BaseOperator) GetChildren() []Operator
GetChildren 获取子算子
func (*BaseOperator) GetSchema ¶
func (op *BaseOperator) GetSchema() []domain.ColumnInfo
GetSchema 获取输出Schema
type DeleteOperator ¶
type DeleteOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
DeleteOperator DELETE算子
func NewDeleteOperator ¶
func NewDeleteOperator(p *plan.Plan, das dataaccess.Service) (*DeleteOperator, error)
NewDeleteOperator 创建DELETE算子
func (*DeleteOperator) Execute ¶
func (op *DeleteOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行DELETE
type HashJoinOperator ¶
type HashJoinOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
HashJoinOperator Hash Join算子
func NewHashJoinOperator ¶
func NewHashJoinOperator(p *plan.Plan, das dataaccess.Service) (*HashJoinOperator, error)
NewHashJoinOperator 创建Hash Join算子
func (*HashJoinOperator) Execute ¶
func (op *HashJoinOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行Hash Join
type InsertOperator ¶
type InsertOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
InsertOperator INSERT算子
func NewInsertOperator ¶
func NewInsertOperator(p *plan.Plan, das dataaccess.Service) (*InsertOperator, error)
NewInsertOperator 创建INSERT算子
func (*InsertOperator) Execute ¶
func (op *InsertOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行INSERT
type LimitOperator ¶
type LimitOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
LimitOperator Limit算子
func NewLimitOperator ¶
func NewLimitOperator(p *plan.Plan, das dataaccess.Service) (*LimitOperator, error)
NewLimitOperator 创建Limit算子
func (*LimitOperator) Execute ¶
func (op *LimitOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行Limit
type Operator ¶
type Operator interface {
// Execute 执行算子
Execute(ctx context.Context) (*domain.QueryResult, error)
// GetChildren 获取子算子
GetChildren() []Operator
// GetSchema 获取输出Schema
GetSchema() []domain.ColumnInfo
}
Operator 算子接口
type ProjectionOperator ¶
type ProjectionOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
ProjectionOperator 投影算子
func NewProjectionOperator ¶
func NewProjectionOperator(p *plan.Plan, das dataaccess.Service) (*ProjectionOperator, error)
NewProjectionOperator 创建投影算子
func (*ProjectionOperator) Execute ¶
func (op *ProjectionOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行投影
type SelectionOperator ¶
type SelectionOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
SelectionOperator 选择算子
func NewSelectionOperator ¶
func NewSelectionOperator(p *plan.Plan, das dataaccess.Service) (*SelectionOperator, error)
NewSelectionOperator 创建选择算子
func (*SelectionOperator) Execute ¶
func (op *SelectionOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行选择
type SortOperator ¶
type SortOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
SortOperator 排序算子
func NewSortOperator ¶
func NewSortOperator(p *plan.Plan, das dataaccess.Service) (*SortOperator, error)
NewSortOperator 创建排序算子
func (*SortOperator) Execute ¶
func (op *SortOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行排序
type TableScanOperator ¶
type TableScanOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
TableScanOperator 表扫描算子
func NewTableScanOperator ¶
func NewTableScanOperator(p *plan.Plan, das dataaccess.Service) (*TableScanOperator, error)
NewTableScanOperator 创建表扫描算子
func (*TableScanOperator) Execute ¶
func (op *TableScanOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行表扫描
type UnionOperator ¶
type UnionOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
UnionOperator UNION算子
func NewUnionOperator ¶
func NewUnionOperator(p *plan.Plan, das dataaccess.Service) (*UnionOperator, error)
NewUnionOperator 创建UNION算子
func (*UnionOperator) Execute ¶
func (op *UnionOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行UNION
type UpdateOperator ¶
type UpdateOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
UpdateOperator UPDATE算子
func NewUpdateOperator ¶
func NewUpdateOperator(p *plan.Plan, das dataaccess.Service) (*UpdateOperator, error)
NewUpdateOperator 创建UPDATE算子
func (*UpdateOperator) Execute ¶
func (op *UpdateOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行UPDATE
type VectorScanOperator ¶
type VectorScanOperator struct {
*BaseOperator
// contains filtered or unexported fields
}
VectorScanOperator 向量扫描算子
func NewVectorScanOperator ¶
func NewVectorScanOperator(p *plan.Plan, das dataaccess.Service, idxMgr *memory.IndexManager) (*VectorScanOperator, error)
NewVectorScanOperator 创建向量扫描算子
func (*VectorScanOperator) Execute ¶
func (v *VectorScanOperator) Execute(ctx context.Context) (*domain.QueryResult, error)
Execute 执行向量扫描
Source Files
Click to show internal directories.
Click to hide internal directories.