engine

Dec 2, 2019

Changes in this version

+ type JoinEngine struct

+ func NewJoinEngine(log *xlog.Log, node *builder.JoinNode, txn backend.Transaction) *JoinEngine

+ func (j *JoinEngine) Execute(ctx *xcontext.ResultContext) error

+ type MergeEngine struct

+ func NewMergeEngine(log *xlog.Log, node *builder.MergeNode, txn backend.Transaction) *MergeEngine

+ func (m *MergeEngine) Execute(ctx *xcontext.ResultContext) error

+ type PlanEngine interface

+ Execute func(ctx *xcontext.ResultContext) error

+ func BuildEngine(log *xlog.Log, plan builder.PlanNode, txn backend.Transaction) PlanEngine

+ type UnionEngine struct

+ func NewUnionEngine(log *xlog.Log, node *builder.UnionNode, txn backend.Transaction) *UnionEngine

+ func (u *UnionEngine) Execute(ctx *xcontext.ResultContext) error