exec

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConnectPushExecutors 

func ConnectPushExecutors(childExecutors []PushExecutor, parent PushExecutor)

Types

type AggregateFunctionInfo 

type AggregateFunctionInfo struct {
	FuncType   aggfuncs.AggFunctionType
	Distinct   bool
	ArgExpr    *common.Expression
	ReturnType common.ColumnType
}

type Aggregator 

type Aggregator struct {
	PartialAggTableInfo *common.TableInfo
	FullAggTableInfo    *common.TableInfo
	// contains filtered or unexported fields
}

func NewAggregator 

func NewAggregator(pkCols []int, aggFunctions []*AggregateFunctionInfo, partialAggTableInfo *common.TableInfo,
	fullAggTableInfo *common.TableInfo, groupByCols []int, storage cluster.Cluster, sharder *sharder.Sharder) (*Aggregator, error)

func (*Aggregator) AddChild 

func (p *Aggregator) AddChild(child PushExecutor)

func (*Aggregator) ClearChildren 

func (p *Aggregator) ClearChildren()

func (*Aggregator) ColNames 

func (p *Aggregator) ColNames() []string

func (*Aggregator) ColTypes 

func (p *Aggregator) ColTypes() []common.ColumnType

func (*Aggregator) ColsVisible 

func (p *Aggregator) ColsVisible() []bool

func (*Aggregator) GetChildren 

func (p *Aggregator) GetChildren() []PushExecutor

func (*Aggregator) GetParent 

func (p *Aggregator) GetParent() PushExecutor

func (*Aggregator) HandleRemoteRows 

func (a *Aggregator) HandleRemoteRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

HandleRemoteRows is called when partial aggregation is forwarded from another shard

func (*Aggregator) HandleRows 

func (a *Aggregator) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*Aggregator) KeyCols 

func (p *Aggregator) KeyCols() []int

func (*Aggregator) ReCalcSchemaFromChildren 

func (a *Aggregator) ReCalcSchemaFromChildren() error

func (*Aggregator) SetColNames 

func (p *Aggregator) SetColNames(colNames []string)

func (*Aggregator) SetParent 

func (p *Aggregator) SetParent(parent PushExecutor)

type ExecutionContext 

type ExecutionContext struct {
	WriteBatch               *cluster.WriteBatch
	RemoteBatches            map[uint64]*cluster.WriteBatch
	BatchSequence            uint32
	EnableDuplicateDetection bool
}

func NewExecutionContext 

func NewExecutionContext(writeBatch *cluster.WriteBatch, enableDuplicateDetection bool) *ExecutionContext

func (*ExecutionContext) AddToForwardBatch 

func (e *ExecutionContext) AddToForwardBatch(shardID uint64, key []byte, value []byte)

type IndexExecutor 

type IndexExecutor struct {
	IndexInfo *common.IndexInfo
	TableInfo *common.TableInfo // The table info of the table (source or MV) that we are creating the index on
	// contains filtered or unexported fields
}

IndexExecutor maintains a secondary index

func NewIndexExecutor 

func NewIndexExecutor(tableInfo *common.TableInfo, indexInfo *common.IndexInfo, store cluster.Cluster) *IndexExecutor

func (*IndexExecutor) AddChild 

func (p *IndexExecutor) AddChild(child PushExecutor)

func (*IndexExecutor) ClearChildren 

func (p *IndexExecutor) ClearChildren()

func (*IndexExecutor) ColNames 

func (p *IndexExecutor) ColNames() []string

func (*IndexExecutor) ColTypes 

func (p *IndexExecutor) ColTypes() []common.ColumnType

func (*IndexExecutor) ColsVisible 

func (p *IndexExecutor) ColsVisible() []bool

func (*IndexExecutor) GetChildren 

func (p *IndexExecutor) GetChildren() []PushExecutor

func (*IndexExecutor) GetParent 

func (p *IndexExecutor) GetParent() PushExecutor

func (*IndexExecutor) HandleRows 

func (t *IndexExecutor) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*IndexExecutor) KeyCols 

func (p *IndexExecutor) KeyCols() []int

func (*IndexExecutor) ReCalcSchemaFromChildren 

func (t *IndexExecutor) ReCalcSchemaFromChildren() error

func (*IndexExecutor) SetColNames 

func (p *IndexExecutor) SetColNames(colNames []string)

func (*IndexExecutor) SetParent 

func (p *IndexExecutor) SetParent(parent PushExecutor)

type PushExecutor 

type PushExecutor interface {
	HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

	SetParent(parent PushExecutor)
	GetParent() PushExecutor
	AddChild(parent PushExecutor)
	GetChildren() []PushExecutor
	ClearChildren()
	ReCalcSchemaFromChildren() error
	ColNames() []string
	SetColNames(colNames []string)
	ColTypes() []common.ColumnType
	KeyCols() []int
	ColsVisible() []bool
}

type PushProjection 

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

func NewPushProjection 

func NewPushProjection(projColumns []*common.Expression) *PushProjection

func (*PushProjection) AddChild 

func (p *PushProjection) AddChild(child PushExecutor)

func (*PushProjection) ClearChildren 

func (p *PushProjection) ClearChildren()

func (*PushProjection) ColNames 

func (p *PushProjection) ColNames() []string

func (*PushProjection) ColTypes 

func (p *PushProjection) ColTypes() []common.ColumnType

func (*PushProjection) ColsVisible 

func (p *PushProjection) ColsVisible() []bool

func (*PushProjection) GetChildren 

func (p *PushProjection) GetChildren() []PushExecutor

func (*PushProjection) GetParent 

func (p *PushProjection) GetParent() PushExecutor

func (*PushProjection) HandleRows 

func (p *PushProjection) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*PushProjection) KeyCols 

func (p *PushProjection) KeyCols() []int

func (*PushProjection) ReCalcSchemaFromChildren 

func (p *PushProjection) ReCalcSchemaFromChildren() error

func (*PushProjection) SetColNames 

func (p *PushProjection) SetColNames(colNames []string)

func (*PushProjection) SetParent 

func (p *PushProjection) SetParent(parent PushExecutor)

type PushSelect 

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

func NewPushSelect 

func NewPushSelect(predicates []*common.Expression) *PushSelect

func (*PushSelect) AddChild 

func (p *PushSelect) AddChild(child PushExecutor)

func (*PushSelect) ClearChildren 

func (p *PushSelect) ClearChildren()

func (*PushSelect) ColNames 

func (p *PushSelect) ColNames() []string

func (*PushSelect) ColTypes 

func (p *PushSelect) ColTypes() []common.ColumnType

func (*PushSelect) ColsVisible 

func (p *PushSelect) ColsVisible() []bool

func (*PushSelect) GetChildren 

func (p *PushSelect) GetChildren() []PushExecutor

func (*PushSelect) GetParent 

func (p *PushSelect) GetParent() PushExecutor

func (*PushSelect) HandleRows 

func (p *PushSelect) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*PushSelect) KeyCols 

func (p *PushSelect) KeyCols() []int

func (*PushSelect) ReCalcSchemaFromChildren 

func (p *PushSelect) ReCalcSchemaFromChildren() error

func (*PushSelect) SetColNames 

func (p *PushSelect) SetColNames(colNames []string)

func (*PushSelect) SetParent 

func (p *PushSelect) SetParent(parent PushExecutor)

type RowWithIndexForwarder 

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

func (*RowWithIndexForwarder) AddChild 

func (p *RowWithIndexForwarder) AddChild(child PushExecutor)

func (*RowWithIndexForwarder) ClearChildren 

func (p *RowWithIndexForwarder) ClearChildren()

func (*RowWithIndexForwarder) ColNames 

func (p *RowWithIndexForwarder) ColNames() []string

func (*RowWithIndexForwarder) ColTypes 

func (p *RowWithIndexForwarder) ColTypes() []common.ColumnType

func (*RowWithIndexForwarder) ColsVisible 

func (p *RowWithIndexForwarder) ColsVisible() []bool

func (*RowWithIndexForwarder) GetChildren 

func (p *RowWithIndexForwarder) GetChildren() []PushExecutor

func (*RowWithIndexForwarder) GetParent 

func (p *RowWithIndexForwarder) GetParent() PushExecutor

func (*RowWithIndexForwarder) HandleRows 

func (r *RowWithIndexForwarder) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*RowWithIndexForwarder) KeyCols 

func (p *RowWithIndexForwarder) KeyCols() []int

func (*RowWithIndexForwarder) ReCalcSchemaFromChildren 

func (p *RowWithIndexForwarder) ReCalcSchemaFromChildren() error

func (*RowWithIndexForwarder) SetColNames 

func (p *RowWithIndexForwarder) SetColNames(colNames []string)

func (*RowWithIndexForwarder) SetParent 

func (p *RowWithIndexForwarder) SetParent(parent PushExecutor)

type RowsBatch 

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

func NewCurrentRowsBatch 

func NewCurrentRowsBatch(currentRows *common.Rows) RowsBatch

func NewRowsBatch 

func NewRowsBatch(rows *common.Rows, entries []RowsEntry) RowsBatch

func (*RowsBatch) AppendEntry 

func (r *RowsBatch) AppendEntry(rowPrev *common.Row, rowCurr *common.Row)

func (*RowsBatch) CurrentRow 

func (r *RowsBatch) CurrentRow(index int) *common.Row

func (*RowsBatch) Len 

func (r *RowsBatch) Len() int

func (*RowsBatch) PreviousRow 

func (r *RowsBatch) PreviousRow(index int) *common.Row

func (*RowsBatch) Rows 

func (r *RowsBatch) Rows() *common.Rows

func (*RowsBatch) String 

func (r *RowsBatch) String() string

type RowsEntry 

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

func NewRowsEntry 

func NewRowsEntry(prevIndex int, currIndex int) RowsEntry

type Scan 

type Scan struct {
	TableName string
	// contains filtered or unexported fields
}

func NewScan 

func NewScan(tableName string, cols []int) (*Scan, error)

func (*Scan) AddChild 

func (p *Scan) AddChild(child PushExecutor)

func (*Scan) ClearChildren 

func (p *Scan) ClearChildren()

func (*Scan) ColNames 

func (p *Scan) ColNames() []string

func (*Scan) ColTypes 

func (p *Scan) ColTypes() []common.ColumnType

func (*Scan) ColsVisible 

func (p *Scan) ColsVisible() []bool

func (*Scan) GetChildren 

func (p *Scan) GetChildren() []PushExecutor

func (*Scan) GetParent 

func (p *Scan) GetParent() PushExecutor

func (*Scan) HandleRows 

func (t *Scan) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*Scan) KeyCols 

func (p *Scan) KeyCols() []int

func (*Scan) ReCalcSchemaFromChildren 

func (t *Scan) ReCalcSchemaFromChildren() error

func (*Scan) SetColNames 

func (p *Scan) SetColNames(colNames []string)

func (*Scan) SetParent 

func (p *Scan) SetParent(parent PushExecutor)

func (*Scan) SetSchema 

func (t *Scan) SetSchema(tableInfo *common.TableInfo)

type TableExecutor 

type TableExecutor struct {
	TableInfo *common.TableInfo
	// contains filtered or unexported fields
}

TableExecutor updates the changes into the associated table - used to persist state of a materialized view or source

func NewTableExecutor 

func NewTableExecutor(tableInfo *common.TableInfo, store cluster.Cluster) *TableExecutor

func (*TableExecutor) AddChild 

func (p *TableExecutor) AddChild(child PushExecutor)

func (*TableExecutor) AddConsumingNode 

func (t *TableExecutor) AddConsumingNode(consumerName string, node PushExecutor)

func (*TableExecutor) ClearChildren 

func (p *TableExecutor) ClearChildren()

func (*TableExecutor) ColNames 

func (p *TableExecutor) ColNames() []string

func (*TableExecutor) ColTypes 

func (p *TableExecutor) ColTypes() []common.ColumnType

func (*TableExecutor) ColsVisible 

func (p *TableExecutor) ColsVisible() []bool

func (*TableExecutor) FillTo 

func (t *TableExecutor) FillTo(pe PushExecutor, consumerName string, newTableID uint64,
	schedulers map[uint64]*sched.ShardScheduler, failInject failinject.Injector) error

FillTo - fills the specified PushExecutor with all the rows in the table and also captures any new changes that might arrive while the fill is in progress. Once the fill is complete and the table executor and the push executor are in sync then the operation completes

func (*TableExecutor) ForwardToConsumingNodes 

func (t *TableExecutor) ForwardToConsumingNodes(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*TableExecutor) GetChildren 

func (p *TableExecutor) GetChildren() []PushExecutor

func (*TableExecutor) GetConsumingMvNames 

func (t *TableExecutor) GetConsumingMvNames() []string

func (*TableExecutor) GetParent 

func (p *TableExecutor) GetParent() PushExecutor

func (*TableExecutor) HandleRemoteRows 

func (t *TableExecutor) HandleRemoteRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*TableExecutor) HandleRows 

func (t *TableExecutor) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*TableExecutor) KeyCols 

func (p *TableExecutor) KeyCols() []int

func (*TableExecutor) ReCalcSchemaFromChildren 

func (t *TableExecutor) ReCalcSchemaFromChildren() error

func (*TableExecutor) RemoveConsumingNode 

func (t *TableExecutor) RemoveConsumingNode(consumerName string)

func (*TableExecutor) RowsFactory 

func (t *TableExecutor) RowsFactory() *common.RowsFactory

func (*TableExecutor) SetColNames 

func (p *TableExecutor) SetColNames(colNames []string)

func (*TableExecutor) SetParent 

func (p *TableExecutor) SetParent(parent PushExecutor)

type UnionAll 

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

func NewUnionAll 

func NewUnionAll() (*UnionAll, error)

func (*UnionAll) AddChild 

func (p *UnionAll) AddChild(child PushExecutor)

func (*UnionAll) ClearChildren 

func (p *UnionAll) ClearChildren()

func (*UnionAll) ColNames 

func (p *UnionAll) ColNames() []string

func (*UnionAll) ColTypes 

func (p *UnionAll) ColTypes() []common.ColumnType

func (*UnionAll) ColsVisible 

func (p *UnionAll) ColsVisible() []bool

func (*UnionAll) GetChildren 

func (p *UnionAll) GetChildren() []PushExecutor

func (*UnionAll) GetParent 

func (p *UnionAll) GetParent() PushExecutor

func (*UnionAll) HandleRows 

func (u *UnionAll) HandleRows(rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*UnionAll) HandleRowsWithIndex 

func (u *UnionAll) HandleRowsWithIndex(index int, rowsBatch RowsBatch, ctx *ExecutionContext) error

func (*UnionAll) KeyCols 

func (p *UnionAll) KeyCols() []int

func (*UnionAll) ReCalcSchemaFromChildren 

func (u *UnionAll) ReCalcSchemaFromChildren() error

func (*UnionAll) SetColNames 

func (p *UnionAll) SetColNames(colNames []string)

func (*UnionAll) SetParent 

func (p *UnionAll) SetParent(parent PushExecutor)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.