Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JoinEngine ¶
type JoinEngine struct {
// contains filtered or unexported fields
}
JoinEngine represents join executor.
func NewJoinEngine ¶
func NewJoinEngine(log *xlog.Log, node *builder.JoinNode, txn backend.Transaction) *JoinEngine
NewJoinEngine creates the new join executor.
func (*JoinEngine) Execute ¶
func (j *JoinEngine) Execute(ctx *xcontext.ResultContext) error
Execute used to execute the executor.
type MergeEngine ¶
type MergeEngine struct {
// contains filtered or unexported fields
}
MergeEngine represents merge executor.
func NewMergeEngine ¶
func NewMergeEngine(log *xlog.Log, node *builder.MergeNode, txn backend.Transaction) *MergeEngine
NewMergeEngine creates the new merge executor.
func (*MergeEngine) Execute ¶
func (m *MergeEngine) Execute(ctx *xcontext.ResultContext) error
Execute used to execute the executor.
type PlanEngine ¶
type PlanEngine interface {
Execute(ctx *xcontext.ResultContext) error
// contains filtered or unexported methods
}
PlanEngine interface.
func BuildEngine ¶
func BuildEngine(log *xlog.Log, plan builder.PlanNode, txn backend.Transaction) PlanEngine
BuildEngine used to build the executor tree.
type UnionEngine ¶
type UnionEngine struct {
// contains filtered or unexported fields
}
UnionEngine represents merge executor.
func NewUnionEngine ¶
func NewUnionEngine(log *xlog.Log, node *builder.UnionNode, txn backend.Transaction) *UnionEngine
NewUnionEngine creates the new union executor.
func (*UnionEngine) Execute ¶
func (u *UnionEngine) Execute(ctx *xcontext.ResultContext) error
Execute used to execute the executor.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.