pull

func (*Engine) BuildPullQuery ¶

func (p *Engine) BuildPullQuery(execCtx *execctx.ExecutionContext, query string, argTypes []common.ColumnType,
	args []interface{}) (exec.PullExecutor, error)

func (*Engine) ExecuteQuery ¶

func (p *Engine) ExecuteQuery(schemaName string, query string) (rows *common.Rows, err error)

ExecuteQuery - Lightweight query interface - used internally for loading a moderate amount of rows

func (*Engine) ExecuteRemotePullQuery ¶

func (p *Engine) ExecuteRemotePullQuery(queryInfo *cluster.QueryExecutionInfo) (*common.Rows, error)

ExecuteRemotePullQuery - executes a pull query received from another node

func (*Engine) NodeJoined ¶

func (p *Engine) NodeJoined(nodeID int)

func (*Engine) NodeLeft ¶

func (p *Engine) NodeLeft(nodeID int)

func (*Engine) NumCachedExecCtxs ¶

func (p *Engine) NumCachedExecCtxs() (int, error)

func (*Engine) SetAvailable ¶

func (p *Engine) SetAvailable() error

func (*Engine) Start ¶

func (p *Engine) Start() error

func (*Engine) Stop ¶

func (p *Engine) Stop() error