pull

Documentation

Index

• func CurrentQuery(ctx *execctx.ExecutionContext) exec.PullExecutor
• type Engine
  • func NewPullEngine(cluster cluster.Cluster, metaController *meta.Controller, ...) *Engine
  • func (p *Engine) BuildPullQuery(execCtx *execctx.ExecutionContext, query string, argTypes []common.ColumnType, ...) (exec.PullExecutor, error)
  • func (p *Engine) ExecuteQuery(schemaName string, query string) (rows *common.Rows, err error)
  • func (p *Engine) ExecuteRemotePullQuery(queryInfo *cluster.QueryExecutionInfo) (*common.Rows, error)
  • func (p *Engine) NodeJoined(nodeID int)
  • func (p *Engine) NodeLeft(nodeID int)
  • func (p *Engine) NumCachedExecCtxs() (int, error)
  • func (p *Engine) SetAvailable() error
  • func (p *Engine) Start() error
  • func (p *Engine) Stop() error

Functions

func CurrentQuery

func CurrentQuery(ctx *execctx.ExecutionContext) exec.PullExecutor

Types

type Engine

type Engine struct {
	// contains filtered or unexported fields
}

func NewPullEngine

func NewPullEngine(cluster cluster.Cluster, metaController *meta.Controller, shrder *sharder.Sharder) *Engine

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