planner

package

Go to main page

Versions in this module

v3

v3.35.0

Mar 30, 2023

v3.34.0

Mar 16, 2023

v3.33.0

Mar 2, 2023

Changes in this version

type OrderByExpression

+ Expr types.PlanExpression

type PlanOpOrderBy

+ func (n *PlanOpOrderBy) Expressions() []types.PlanExpression

+ func (n *PlanOpOrderBy) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

type PlanOpPQLDistinctScan

+ func (p *PlanOpPQLDistinctScan) IsFilterable() bool

+ func (p *PlanOpPQLDistinctScan) UpdateTimeQuantumFilters(filters ...types.PlanExpression) (types.PlanOperator, error)

type PlanOpPQLTableScan

+ func (p *PlanOpPQLTableScan) IsFilterable() bool

+ func (p *PlanOpPQLTableScan) PrimaryKeyType() (parser.ExprDataType, error)

+ func (p *PlanOpPQLTableScan) UpdateTimeQuantumFilters(filters ...types.PlanExpression) (types.PlanOperator, error)

type PlanOpRelAlias

+ func (p *PlanOpRelAlias) IsFilterable() bool

+ func (p *PlanOpRelAlias) UpdateFilters(filterCondition types.PlanExpression) (types.PlanOperator, error)

+ func (p *PlanOpRelAlias) UpdateTimeQuantumFilters(filters ...types.PlanExpression) (types.PlanOperator, error)

type PlanOpTableValuedFunction

+ func (p *PlanOpTableValuedFunction) Name() string

v3.32.0

Feb 16, 2023

Changes in this version

+ type PlanOpAlterDatabase struct

+ func NewPlanOpAlterDatabase(p *ExecutionPlanner, db *dax.Database, operation alterOperation, ...) *PlanOpAlterDatabase

+ func (p *PlanOpAlterDatabase) AddWarning(warning string)

+ func (p *PlanOpAlterDatabase) Children() []types.PlanOperator

+ func (p *PlanOpAlterDatabase) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpAlterDatabase) Plan() map[string]interface{}

+ func (p *PlanOpAlterDatabase) Schema() types.Schema

+ func (p *PlanOpAlterDatabase) String() string

+ func (p *PlanOpAlterDatabase) Warnings() []string

+ func (p *PlanOpAlterDatabase) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpCreateDatabase struct

+ func NewPlanOpCreateDatabase(p *ExecutionPlanner, databaseName string, failIfExists bool, units int, ...) *PlanOpCreateDatabase

+ func (p *PlanOpCreateDatabase) AddWarning(warning string)

+ func (p *PlanOpCreateDatabase) Children() []types.PlanOperator

+ func (p *PlanOpCreateDatabase) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpCreateDatabase) Plan() map[string]interface{}

+ func (p *PlanOpCreateDatabase) Schema() types.Schema

+ func (p *PlanOpCreateDatabase) String() string

+ func (p *PlanOpCreateDatabase) Warnings() []string

+ func (p *PlanOpCreateDatabase) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpDropDatabase struct

+ func NewPlanOpDropDatabase(p *ExecutionPlanner, db *dax.Database) *PlanOpDropDatabase

+ func (p *PlanOpDropDatabase) AddWarning(warning string)

+ func (p *PlanOpDropDatabase) Children() []types.PlanOperator

+ func (p *PlanOpDropDatabase) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpDropDatabase) Plan() map[string]interface{}

+ func (p *PlanOpDropDatabase) Schema() types.Schema

+ func (p *PlanOpDropDatabase) String() string

+ func (p *PlanOpDropDatabase) Warnings() []string

+ func (p *PlanOpDropDatabase) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpFeatureBaseDatabases struct

+ func NewPlanOpFeatureBaseDatabases(planner *ExecutionPlanner, dbs []*dax.Database) *PlanOpFeatureBaseDatabases

+ func (p *PlanOpFeatureBaseDatabases) AddWarning(warning string)

+ func (p *PlanOpFeatureBaseDatabases) Children() []types.PlanOperator

+ func (p *PlanOpFeatureBaseDatabases) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpFeatureBaseDatabases) Plan() map[string]interface{}

+ func (p *PlanOpFeatureBaseDatabases) Schema() types.Schema

+ func (p *PlanOpFeatureBaseDatabases) String() string

+ func (p *PlanOpFeatureBaseDatabases) Warnings() []string

+ func (p *PlanOpFeatureBaseDatabases) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

v3.31.0

Feb 1, 2023

v3.30.0

Feb 1, 2023

Changes in this version

+ func NewParquetReader(ctx context.Context, mappings []*bulkInsertMapColumn, r *os.File, ...) (*parquetReader, error)

v3.29.0

Jan 25, 2023

Changes in this version

type ExecutionPlanner

+ func (p *ExecutionPlanner) RehydratePlanOp(ctx context.Context, reader io.Reader) (types.PlanOperator, error)

+ type PlanOpAlterView struct

+ func NewPlanOpAlterView(planner *ExecutionPlanner, view *viewSystemObject) *PlanOpAlterView

+ func (p *PlanOpAlterView) AddWarning(warning string)

+ func (p *PlanOpAlterView) Children() []types.PlanOperator

+ func (p *PlanOpAlterView) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpAlterView) Plan() map[string]interface{}

+ func (p *PlanOpAlterView) Schema() types.Schema

+ func (p *PlanOpAlterView) String() string

+ func (p *PlanOpAlterView) Warnings() []string

+ func (p *PlanOpAlterView) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpCreateView struct

+ func NewPlanOpCreateView(planner *ExecutionPlanner, ifNotExists bool, view *viewSystemObject) *PlanOpCreateView

+ func (p *PlanOpCreateView) AddWarning(warning string)

+ func (p *PlanOpCreateView) Children() []types.PlanOperator

+ func (p *PlanOpCreateView) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpCreateView) Plan() map[string]interface{}

+ func (p *PlanOpCreateView) Schema() types.Schema

+ func (p *PlanOpCreateView) String() string

+ func (p *PlanOpCreateView) Warnings() []string

+ func (p *PlanOpCreateView) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpDropView struct

+ func NewPlanOpDropView(p *ExecutionPlanner, ifExists bool, viewName string) *PlanOpDropView

+ func (p *PlanOpDropView) AddWarning(warning string)

+ func (p *PlanOpDropView) Children() []types.PlanOperator

+ func (p *PlanOpDropView) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpDropView) Plan() map[string]interface{}

+ func (p *PlanOpDropView) Schema() types.Schema

+ func (p *PlanOpDropView) String() string

+ func (p *PlanOpDropView) Warnings() []string

+ func (p *PlanOpDropView) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpFanout struct

+ ChildOp types.PlanOperator

+ func NewPlanOpFanout(planner *ExecutionPlanner, child types.PlanOperator) *PlanOpFanout

+ func (p *PlanOpFanout) AddWarning(warning string)

+ func (p *PlanOpFanout) Children() []types.PlanOperator

+ func (p *PlanOpFanout) Expressions() []types.PlanExpression

+ func (p *PlanOpFanout) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpFanout) Plan() map[string]interface{}

+ func (p *PlanOpFanout) Schema() types.Schema

+ func (p *PlanOpFanout) String() string

+ func (p *PlanOpFanout) Warnings() []string

+ func (p *PlanOpFanout) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpFanout) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

v3.27.0

Jan 12, 2023

Changes in this version

+ func InspectOperatorExpressions(op types.PlanOperator, f exprInspector)

type PlanOpDistinct

+ ChildOp types.PlanOperator

+ func (p *PlanOpDistinct) Children() []types.PlanOperator

+ func (p *PlanOpDistinct) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpDistinct) Schema() types.Schema

+ func (p *PlanOpDistinct) String() string

+ func (p *PlanOpDistinct) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpHaving struct

+ ChildOp types.PlanOperator

+ Predicate types.PlanExpression

+ func NewPlanOpHaving(planner *ExecutionPlanner, predicate types.PlanExpression, ...) *PlanOpHaving

+ func (p *PlanOpHaving) AddWarning(warning string)

+ func (p *PlanOpHaving) Children() []types.PlanOperator

+ func (p *PlanOpHaving) Expressions() []types.PlanExpression

+ func (p *PlanOpHaving) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpHaving) Plan() map[string]interface{}

+ func (p *PlanOpHaving) Schema() types.Schema

+ func (p *PlanOpHaving) String() string

+ func (p *PlanOpHaving) Warnings() []string

+ func (p *PlanOpHaving) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpHaving) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

+ type PlanOpPQLConstRowDelete struct

+ ChildOp types.PlanOperator

+ func NewPlanOpPQLConstRowDelete(p *ExecutionPlanner, tableName string, child types.PlanOperator) *PlanOpPQLConstRowDelete

+ func (p *PlanOpPQLConstRowDelete) AddWarning(warning string)

+ func (p *PlanOpPQLConstRowDelete) Children() []types.PlanOperator

+ func (p *PlanOpPQLConstRowDelete) Expressions() []types.PlanExpression

+ func (p *PlanOpPQLConstRowDelete) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLConstRowDelete) Plan() map[string]interface{}

+ func (p *PlanOpPQLConstRowDelete) Schema() types.Schema

+ func (p *PlanOpPQLConstRowDelete) String() string

+ func (p *PlanOpPQLConstRowDelete) Warnings() []string

+ func (p *PlanOpPQLConstRowDelete) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpPQLConstRowDelete) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

+ type PlanOpPQLDistinctScan struct

+ func NewPlanOpPQLDistinctScan(p *ExecutionPlanner, tableName string, column string) (*PlanOpPQLDistinctScan, error)

+ func (p *PlanOpPQLDistinctScan) AddWarning(warning string)

+ func (p *PlanOpPQLDistinctScan) Children() []types.PlanOperator

+ func (p *PlanOpPQLDistinctScan) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLDistinctScan) Name() string

+ func (p *PlanOpPQLDistinctScan) Plan() map[string]interface{}

+ func (p *PlanOpPQLDistinctScan) Schema() types.Schema

+ func (p *PlanOpPQLDistinctScan) String() string

+ func (p *PlanOpPQLDistinctScan) UpdateFilters(filterCondition types.PlanExpression) (types.PlanOperator, error)

+ func (p *PlanOpPQLDistinctScan) Warnings() []string

+ func (p *PlanOpPQLDistinctScan) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpPQLFilteredDelete struct

+ func NewPlanOpPQLFilteredDelete(p *ExecutionPlanner, tableName string, filter types.PlanExpression) *PlanOpPQLFilteredDelete

+ func (p *PlanOpPQLFilteredDelete) AddWarning(warning string)

+ func (p *PlanOpPQLFilteredDelete) Children() []types.PlanOperator

+ func (p *PlanOpPQLFilteredDelete) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLFilteredDelete) Plan() map[string]interface{}

+ func (p *PlanOpPQLFilteredDelete) Schema() types.Schema

+ func (p *PlanOpPQLFilteredDelete) String() string

+ func (p *PlanOpPQLFilteredDelete) Warnings() []string

+ func (p *PlanOpPQLFilteredDelete) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpPQLTruncateTable struct

+ func NewPlanOpPQLTruncateTable(p *ExecutionPlanner, tableName string) *PlanOpPQLTruncateTable

+ func (p *PlanOpPQLTruncateTable) AddWarning(warning string)

+ func (p *PlanOpPQLTruncateTable) Children() []types.PlanOperator

+ func (p *PlanOpPQLTruncateTable) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLTruncateTable) Plan() map[string]interface{}

+ func (p *PlanOpPQLTruncateTable) Schema() types.Schema

+ func (p *PlanOpPQLTruncateTable) String() string

+ func (p *PlanOpPQLTruncateTable) Warnings() []string

+ func (p *PlanOpPQLTruncateTable) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

v3.26.0

Dec 12, 2022

Changes in this version

+ func ExprWalk(v ExprVisitor, expr types.PlanExpression)

+ func ExprWithPlanOpWalk(v PlanOpExprVisitor, op types.PlanOperator, expr types.PlanExpression)

+ func ExpressionToColumn(e types.PlanExpression) *types.PlannerColumn

+ func InspectExpression(expr types.PlanExpression, f func(expr types.PlanExpression) bool)

+ func InspectExpressions(op types.PlanOperator, f exprInspector)

+ func InspectExpressionsWithPlanOp(op types.PlanOperator, f exprWithNodeInspector)

+ func InspectPlan(op types.PlanOperator, f planInspectionFunction)

+ func NewAggAvgBuffer(child types.PlanExpression) *aggregateAvg

+ func NewAggCountBuffer(child types.PlanExpression) *aggregateCount

+ func NewAggCountDistinctBuffer(child types.PlanExpression) *aggregateCountDistinct

+ func NewAggLastBuffer(child types.PlanExpression) *aggregateLast

+ func NewAggMaxBuffer(child types.PlanExpression) *aggregateMax

+ func NewAggMinBuffer(child types.PlanExpression) *aggregateMin

+ func NewAggSumBuffer(child types.PlanExpression) *aggregateSum

+ func NewFirstBuffer(child types.PlanExpression) *aggregateFirst

+ func NewMapObjectCache() mapObjectCache

+ func PlanWalk(v PlanVisitor, op types.PlanOperator)

+ func ProjectRow(ctx context.Context, projections []types.PlanExpression, row types.Row) (types.Row, error)

+ func TransformExpr(expr types.PlanExpression, transformFunction ExprFunc, ...) (types.PlanExpression, bool, error)

+ func TransformPlanOp(op types.PlanOperator, f PlanOpTransformFunc) (types.PlanOperator, bool, error)

+ func TransformPlanOpWithParent(op types.PlanOperator, s ParentSelectorFunc, f ParentContextFunc) (types.PlanOperator, bool, error)

+ func TransformSinglePlanOpExpressions(op types.PlanOperator, f ExprFunc, selector ExprSelectorFunc) (types.PlanOperator, bool, error)

+ func WalkExpressions(v ExprVisitor, op types.PlanOperator)

+ func WalkExpressionsWithPlanOp(v PlanOpExprVisitor, op types.PlanOperator)

+ type ExecutionPlanner struct

+ func NewExecutionPlanner(executor pilosa.Executor, schemaAPI pilosa.SchemaAPI, ...) *ExecutionPlanner

+ func (p *ExecutionPlanner) CompilePlan(ctx context.Context, stmt parser.Statement) (types.PlanOperator, error)

+ type ExprFunc func(expr types.PlanExpression) (types.PlanExpression, bool, error)

+ type ExprSelectorFunc func(parentExpr, childExpr types.PlanExpression) bool

+ type ExprVisitor interface

+ VisitExpr func(expr types.PlanExpression) ExprVisitor

+ type ExprWithPlanOpFunc func(op types.PlanOperator, expr types.PlanExpression) (types.PlanExpression, bool, error)

+ type KeyedRowCache interface

+ Get func(key uint64) (types.Row, error)

+ Put func(key uint64, row types.Row) error

+ Size func() int

+ type ObjectCache interface

+ GetObject func(uint64) (interface{}, error)

+ PutObject func(uint64, interface{}) error

+ Size func() int

+ type OptimizerFunc func(context.Context, *ExecutionPlanner, types.PlanOperator, *OptimizerScope) (types.PlanOperator, bool, error)

+ type OptimizerScope struct

+ type OrderByExpression struct

+ ExprType parser.ExprDataType

+ Index int

+ NullOrdering nullOrdering

+ Order orderByOrder

+ type OrderBySorter struct

+ Ctx context.Context

+ LastError error

+ Rows []types.Row

+ SortFields []*OrderByExpression

+ func (s *OrderBySorter) Len() int

+ func (s *OrderBySorter) Less(i, j int) bool

+ func (s *OrderBySorter) Swap(i, j int)

+ type ParentContext struct

+ ChildCount int

+ Operator types.PlanOperator

+ Parent types.PlanOperator

+ type ParentContextFunc func(c ParentContext) (types.PlanOperator, bool, error)

+ type ParentSelectorFunc func(c ParentContext) bool

+ type PlanOpAlterTable struct

+ func NewPlanOpAlterTable(p *ExecutionPlanner, tableName string, operation alterOperation, ...) *PlanOpAlterTable

+ func (p *PlanOpAlterTable) AddWarning(warning string)

+ func (p *PlanOpAlterTable) Children() []types.PlanOperator

+ func (p *PlanOpAlterTable) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpAlterTable) Plan() map[string]interface{}

+ func (p *PlanOpAlterTable) Schema() types.Schema

+ func (p *PlanOpAlterTable) String() string

+ func (p *PlanOpAlterTable) Warnings() []string

+ func (p *PlanOpAlterTable) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpBulkInsert struct

+ func NewPlanOpBulkInsert(p *ExecutionPlanner, tableName string, options *bulkInsertOptions) *PlanOpBulkInsert

+ func (p *PlanOpBulkInsert) AddWarning(warning string)

+ func (p *PlanOpBulkInsert) Children() []types.PlanOperator

+ func (p *PlanOpBulkInsert) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpBulkInsert) Plan() map[string]interface{}

+ func (p *PlanOpBulkInsert) Schema() types.Schema

+ func (p *PlanOpBulkInsert) String() string

+ func (p *PlanOpBulkInsert) Warnings() []string

+ func (p *PlanOpBulkInsert) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpCreateTable struct

+ func NewPlanOpCreateTable(p *ExecutionPlanner, tableName string, failIfExists bool, isKeyed bool, ...) *PlanOpCreateTable

+ func (p *PlanOpCreateTable) AddWarning(warning string)

+ func (p *PlanOpCreateTable) Children() []types.PlanOperator

+ func (p *PlanOpCreateTable) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpCreateTable) Plan() map[string]interface{}

+ func (p *PlanOpCreateTable) Schema() types.Schema

+ func (p *PlanOpCreateTable) String() string

+ func (p *PlanOpCreateTable) Warnings() []string

+ func (p *PlanOpCreateTable) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpDistinct struct

+ func NewPlanOpDistinct(p *ExecutionPlanner, source types.PlanOperator) *PlanOpDistinct

+ func (n *PlanOpDistinct) AddWarning(warning string)

+ func (n *PlanOpDistinct) Plan() map[string]interface{}

+ func (n *PlanOpDistinct) Warnings() []string

+ type PlanOpDropTable struct

+ func NewPlanOpDropTable(p *ExecutionPlanner, index *pilosa.IndexInfo) *PlanOpDropTable

+ func (p *PlanOpDropTable) AddWarning(warning string)

+ func (p *PlanOpDropTable) Children() []types.PlanOperator

+ func (p *PlanOpDropTable) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpDropTable) Plan() map[string]interface{}

+ func (p *PlanOpDropTable) Schema() types.Schema

+ func (p *PlanOpDropTable) String() string

+ func (p *PlanOpDropTable) Warnings() []string

+ func (p *PlanOpDropTable) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpExprVisitor interface

+ VisitPlanOpExpr func(op types.PlanOperator, expression types.PlanExpression) PlanOpExprVisitor

+ type PlanOpFeatureBaseColumns struct

+ func NewPlanOpFeatureBaseColumns(tbl *dax.Table) *PlanOpFeatureBaseColumns

+ func (p *PlanOpFeatureBaseColumns) AddWarning(warning string)

+ func (p *PlanOpFeatureBaseColumns) Children() []types.PlanOperator

+ func (p *PlanOpFeatureBaseColumns) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpFeatureBaseColumns) Plan() map[string]interface{}

+ func (p *PlanOpFeatureBaseColumns) Schema() types.Schema

+ func (p *PlanOpFeatureBaseColumns) String() string

+ func (p *PlanOpFeatureBaseColumns) Warnings() []string

+ func (p *PlanOpFeatureBaseColumns) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpFeatureBaseTables struct

+ func NewPlanOpFeatureBaseTables(indexInfo []*pilosa.IndexInfo) *PlanOpFeatureBaseTables

+ func (p *PlanOpFeatureBaseTables) AddWarning(warning string)

+ func (p *PlanOpFeatureBaseTables) Children() []types.PlanOperator

+ func (p *PlanOpFeatureBaseTables) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpFeatureBaseTables) Plan() map[string]interface{}

+ func (p *PlanOpFeatureBaseTables) Schema() types.Schema

+ func (p *PlanOpFeatureBaseTables) String() string

+ func (p *PlanOpFeatureBaseTables) Warnings() []string

+ func (p *PlanOpFeatureBaseTables) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpFilter struct

+ ChildOp types.PlanOperator

+ Predicate types.PlanExpression

+ func NewPlanOpFilter(planner *ExecutionPlanner, predicate types.PlanExpression, ...) *PlanOpFilter

+ func (p *PlanOpFilter) AddWarning(warning string)

+ func (p *PlanOpFilter) Children() []types.PlanOperator

+ func (p *PlanOpFilter) Expressions() []types.PlanExpression

+ func (p *PlanOpFilter) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpFilter) Plan() map[string]interface{}

+ func (p *PlanOpFilter) Schema() types.Schema

+ func (p *PlanOpFilter) String() string

+ func (p *PlanOpFilter) Warnings() []string

+ func (p *PlanOpFilter) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpFilter) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

+ type PlanOpGroupBy struct

+ Aggregates []types.PlanExpression

+ ChildOp types.PlanOperator

+ GroupByExprs []types.PlanExpression

+ func NewPlanOpGroupBy(aggregates []types.PlanExpression, groupByExprs []types.PlanExpression, ...) *PlanOpGroupBy

+ func (p *PlanOpGroupBy) AddWarning(warning string)

+ func (p *PlanOpGroupBy) Children() []types.PlanOperator

+ func (p *PlanOpGroupBy) Expressions() []types.PlanExpression

+ func (p *PlanOpGroupBy) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpGroupBy) Plan() map[string]interface{}

+ func (p *PlanOpGroupBy) Schema() types.Schema

+ func (p *PlanOpGroupBy) String() string

+ func (p *PlanOpGroupBy) Warnings() []string

+ func (p *PlanOpGroupBy) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpGroupBy) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

+ type PlanOpInsert struct

+ func NewPlanOpInsert(p *ExecutionPlanner, tableName string, ...) *PlanOpInsert

+ func (p *PlanOpInsert) AddWarning(warning string)

+ func (p *PlanOpInsert) Children() []types.PlanOperator

+ func (p *PlanOpInsert) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpInsert) Plan() map[string]interface{}

+ func (p *PlanOpInsert) Schema() types.Schema

+ func (p *PlanOpInsert) String() string

+ func (p *PlanOpInsert) Warnings() []string

+ func (p *PlanOpInsert) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpNestedLoops struct

+ func NewPlanOpNestedLoops(top, bottom types.PlanOperator, condition types.PlanExpression) *PlanOpNestedLoops

+ func (p *PlanOpNestedLoops) AddWarning(warning string)

+ func (p *PlanOpNestedLoops) Children() []types.PlanOperator

+ func (p *PlanOpNestedLoops) Expressions() []types.PlanExpression

+ func (p *PlanOpNestedLoops) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpNestedLoops) Plan() map[string]interface{}

+ func (p *PlanOpNestedLoops) Schema() types.Schema

+ func (p *PlanOpNestedLoops) String() string

+ func (p *PlanOpNestedLoops) Warnings() []string

+ func (p *PlanOpNestedLoops) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpNestedLoops) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

+ type PlanOpNullTable struct

+ func NewPlanOpNullTable() *PlanOpNullTable

+ func (p *PlanOpNullTable) AddWarning(warning string)

+ func (p *PlanOpNullTable) Children() []types.PlanOperator

+ func (p *PlanOpNullTable) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpNullTable) Plan() map[string]interface{}

+ func (p *PlanOpNullTable) Schema() types.Schema

+ func (p *PlanOpNullTable) String() string

+ func (p *PlanOpNullTable) Warnings() []string

+ func (p *PlanOpNullTable) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpOrderBy struct

+ ChildOp types.PlanOperator

+ func NewPlanOpOrderBy(orderByFields []*OrderByExpression, child types.PlanOperator) *PlanOpOrderBy

+ func (n *PlanOpOrderBy) AddWarning(warning string)

+ func (n *PlanOpOrderBy) Children() []types.PlanOperator

+ func (n *PlanOpOrderBy) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (n *PlanOpOrderBy) Plan() map[string]interface{}

+ func (n *PlanOpOrderBy) Schema() types.Schema

+ func (n *PlanOpOrderBy) String() string

+ func (n *PlanOpOrderBy) Warnings() []string

+ func (n *PlanOpOrderBy) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpPQLAggregate struct

+ func NewPlanOpPQLAggregate(p *ExecutionPlanner, tableName string, aggregate types.Aggregable, ...) *PlanOpPQLAggregate

+ func (p *PlanOpPQLAggregate) AddWarning(warning string)

+ func (p *PlanOpPQLAggregate) Children() []types.PlanOperator

+ func (p *PlanOpPQLAggregate) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLAggregate) Plan() map[string]interface{}

+ func (p *PlanOpPQLAggregate) Schema() types.Schema

+ func (p *PlanOpPQLAggregate) String() string

+ func (p *PlanOpPQLAggregate) Warnings() []string

+ func (p *PlanOpPQLAggregate) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpPQLGroupBy struct

+ func NewPlanOpPQLGroupBy(p *ExecutionPlanner, tableName string, groupByExprs []types.PlanExpression, ...) *PlanOpPQLGroupBy

+ func (p *PlanOpPQLGroupBy) AddWarning(warning string)

+ func (p *PlanOpPQLGroupBy) Children() []types.PlanOperator

+ func (p *PlanOpPQLGroupBy) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLGroupBy) Plan() map[string]interface{}

+ func (p *PlanOpPQLGroupBy) Schema() types.Schema

+ func (p *PlanOpPQLGroupBy) String() string

+ func (p *PlanOpPQLGroupBy) Warnings() []string

+ func (p *PlanOpPQLGroupBy) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpPQLMultiAggregate struct

+ func NewPlanOpPQLMultiAggregate(p *ExecutionPlanner, operators []*PlanOpPQLAggregate) *PlanOpPQLMultiAggregate

+ func (p *PlanOpPQLMultiAggregate) AddWarning(warning string)

+ func (p *PlanOpPQLMultiAggregate) Children() []types.PlanOperator

+ func (p *PlanOpPQLMultiAggregate) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLMultiAggregate) Plan() map[string]interface{}

+ func (p *PlanOpPQLMultiAggregate) Schema() types.Schema

+ func (p *PlanOpPQLMultiAggregate) String() string

+ func (p *PlanOpPQLMultiAggregate) Warnings() []string

+ func (p *PlanOpPQLMultiAggregate) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpPQLMultiGroupBy struct

+ func NewPlanOpPQLMultiGroupBy(p *ExecutionPlanner, operators []*PlanOpPQLGroupBy, ...) *PlanOpPQLMultiGroupBy

+ func (p *PlanOpPQLMultiGroupBy) AddWarning(warning string)

+ func (p *PlanOpPQLMultiGroupBy) Children() []types.PlanOperator

+ func (p *PlanOpPQLMultiGroupBy) Expressions() []types.PlanExpression

+ func (p *PlanOpPQLMultiGroupBy) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLMultiGroupBy) Plan() map[string]interface{}

+ func (p *PlanOpPQLMultiGroupBy) Schema() types.Schema

+ func (p *PlanOpPQLMultiGroupBy) String() string

+ func (p *PlanOpPQLMultiGroupBy) Warnings() []string

+ func (p *PlanOpPQLMultiGroupBy) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpPQLMultiGroupBy) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

+ type PlanOpPQLTableScan struct

+ func NewPlanOpPQLTableScan(p *ExecutionPlanner, tableName string, columns []string) *PlanOpPQLTableScan

+ func (p *PlanOpPQLTableScan) AddWarning(warning string)

+ func (p *PlanOpPQLTableScan) Children() []types.PlanOperator

+ func (p *PlanOpPQLTableScan) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpPQLTableScan) Name() string

+ func (p *PlanOpPQLTableScan) Plan() map[string]interface{}

+ func (p *PlanOpPQLTableScan) Schema() types.Schema

+ func (p *PlanOpPQLTableScan) String() string

+ func (p *PlanOpPQLTableScan) UpdateFilters(filterCondition types.PlanExpression) (types.PlanOperator, error)

+ func (p *PlanOpPQLTableScan) Warnings() []string

+ func (p *PlanOpPQLTableScan) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpProjection struct

+ ChildOp types.PlanOperator

+ Projections []types.PlanExpression

+ func NewPlanOpProjection(expressions []types.PlanExpression, child types.PlanOperator) *PlanOpProjection

+ func (p *PlanOpProjection) AddWarning(warning string)

+ func (p *PlanOpProjection) Children() []types.PlanOperator

+ func (p *PlanOpProjection) Expressions() []types.PlanExpression

+ func (p *PlanOpProjection) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpProjection) Plan() map[string]interface{}

+ func (p *PlanOpProjection) Schema() types.Schema

+ func (p *PlanOpProjection) String() string

+ func (p *PlanOpProjection) Warnings() []string

+ func (p *PlanOpProjection) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ func (p *PlanOpProjection) WithUpdatedExpressions(exprs ...types.PlanExpression) (types.PlanOperator, error)

+ type PlanOpQuery struct

+ ChildOp types.PlanOperator

+ func NewPlanOpQuery(p *ExecutionPlanner, child types.PlanOperator, sql string) *PlanOpQuery

+ func (p *PlanOpQuery) AddWarning(warning string)

+ func (p *PlanOpQuery) Child() types.PlanOperator

+ func (p *PlanOpQuery) Children() []types.PlanOperator

+ func (p *PlanOpQuery) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpQuery) Plan() map[string]interface{}

+ func (p *PlanOpQuery) Schema() types.Schema

+ func (p *PlanOpQuery) String() string

+ func (p *PlanOpQuery) Warnings() []string

+ func (p *PlanOpQuery) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpRelAlias struct

+ ChildOp types.PlanOperator

+ func NewPlanOpRelAlias(alias string, child types.PlanOperator) *PlanOpRelAlias

+ func (p *PlanOpRelAlias) AddWarning(warning string)

+ func (p *PlanOpRelAlias) Children() []types.PlanOperator

+ func (p *PlanOpRelAlias) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpRelAlias) Name() string

+ func (p *PlanOpRelAlias) Plan() map[string]interface{}

+ func (p *PlanOpRelAlias) Schema() types.Schema

+ func (p *PlanOpRelAlias) String() string

+ func (p *PlanOpRelAlias) Warnings() []string

+ func (p *PlanOpRelAlias) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpSubquery struct

+ ChildOp types.PlanOperator

+ func NewPlanOpSubquery(child types.PlanOperator) *PlanOpSubquery

+ func (p *PlanOpSubquery) AddWarning(warning string)

+ func (p *PlanOpSubquery) Children() []types.PlanOperator

+ func (p *PlanOpSubquery) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpSubquery) Name() string

+ func (p *PlanOpSubquery) Plan() map[string]interface{}

+ func (p *PlanOpSubquery) Schema() types.Schema

+ func (p *PlanOpSubquery) String() string

+ func (p *PlanOpSubquery) Warnings() []string

+ func (p *PlanOpSubquery) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpSystemTable struct

+ func NewPlanOpSystemTable(p *ExecutionPlanner, table *systemTable) *PlanOpSystemTable

+ func (p *PlanOpSystemTable) AddWarning(warning string)

+ func (p *PlanOpSystemTable) Children() []types.PlanOperator

+ func (p *PlanOpSystemTable) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpSystemTable) Plan() map[string]interface{}

+ func (p *PlanOpSystemTable) Schema() types.Schema

+ func (p *PlanOpSystemTable) String() string

+ func (p *PlanOpSystemTable) Warnings() []string

+ func (p *PlanOpSystemTable) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpTableValuedFunction struct

+ func NewPlanOpTableValuedFunction(p *ExecutionPlanner, callExpr types.PlanExpression) *PlanOpTableValuedFunction

+ func (p *PlanOpTableValuedFunction) AddWarning(warning string)

+ func (p *PlanOpTableValuedFunction) Children() []types.PlanOperator

+ func (p *PlanOpTableValuedFunction) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpTableValuedFunction) Plan() map[string]interface{}

+ func (p *PlanOpTableValuedFunction) Schema() types.Schema

+ func (p *PlanOpTableValuedFunction) String() string

+ func (p *PlanOpTableValuedFunction) Warnings() []string

+ func (p *PlanOpTableValuedFunction) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpTop struct

+ ChildOp types.PlanOperator

+ func NewPlanOpTop(expr types.PlanExpression, child types.PlanOperator) *PlanOpTop

+ func (p *PlanOpTop) AddWarning(warning string)

+ func (p *PlanOpTop) Children() []types.PlanOperator

+ func (p *PlanOpTop) Iterator(ctx context.Context, row types.Row) (types.RowIterator, error)

+ func (p *PlanOpTop) Plan() map[string]interface{}

+ func (p *PlanOpTop) Schema() types.Schema

+ func (p *PlanOpTop) String() string

+ func (p *PlanOpTop) Warnings() []string

+ func (p *PlanOpTop) WithChildren(children ...types.PlanOperator) (types.PlanOperator, error)

+ type PlanOpTransformFunc func(op types.PlanOperator) (types.PlanOperator, bool, error)

+ type PlanVisitor interface

+ VisitOperator func(op types.PlanOperator) PlanVisitor

+ type PlannerScope struct

+ type RelationAliasesMap map[string]types.IdentifiableByName

+ type RowCache interface

+ Add func(row types.Row) error

+ AllRows func() []types.Row

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL