executors

package

Go to main page

Versions in this module

v0

v0.0.10

Mar 21, 2023

v0.0.9

Mar 21, 2023

v0.0.8

Mar 20, 2023

v0.0.7

Mar 20, 2023

v0.0.6

Mar 19, 2023

v0.0.5

Mar 19, 2023

v0.0.4

Mar 18, 2023

v0.0.3

Jan 28, 2023

v0.0.2

Jan 26, 2023

Changes in this version

+ func ExecuteIndexPointScanTestCase(t *testing.T, testCase IndexPointScanTestCase, ...)

+ func ExecuteIndexRangeScanTestCase(t *testing.T, testCase IndexRangeScanTestCase, ...)

type AggregationExecutor

+ func (e *AggregationExecutor) GetTableMetaData() *catalog.TableMetadata

type DeleteExecutor

+ func (e *DeleteExecutor) GetTableMetaData() *catalog.TableMetadata

type Executor

+ func NewPointScanWithIndexExecutor(context *ExecutorContext, plan *plans.PointScanWithIndexPlanNode) Executor

+ func NewRangeScanWithIndexExecutor(context *ExecutorContext, plan *plans.RangeScanWithIndexPlanNode) Executor

+ GetTableMetaData func() *catalog.TableMetadata

type FilterExecutor

+ func (e *FilterExecutor) GetTableMetaData() *catalog.TableMetadata

type HashJoinExecutor

+ func (e *HashJoinExecutor) GetTableMetaData() *catalog.TableMetadata

+ type IndexPointScanTestCase struct

+ Asserts []Assertion

+ Columns []Column

+ Description string

+ ExecutionEngine *ExecutionEngine

+ ExecutorContext *ExecutorContext

+ Predicate Predicate

+ TableMetadata *catalog.TableMetadata

+ TotalHits uint32

+ type IndexRangeScanTestCase struct

+ ColIdx int32

+ Columns []Column

+ Description string

+ ExecutionEngine *ExecutionEngine

+ ExecutorContext *ExecutorContext

+ Predicate Predicate

+ ScanRange []*types.Value

+ TableMetadata *catalog.TableMetadata

+ TotalHits uint32

type InsertExecutor

+ func (e *InsertExecutor) GetTableMetaData() *catalog.TableMetadata

type LimitExecutor

+ func (e *LimitExecutor) GetTableMetaData() *catalog.TableMetadata

type OrderbyExecutor

+ func (e *OrderbyExecutor) GetTableMetaData() *catalog.TableMetadata

+ type PointScanWithIndexExecutor struct

+ func (e *PointScanWithIndexExecutor) GetOutputSchema() *schema.Schema

+ func (e *PointScanWithIndexExecutor) GetTableMetaData() *catalog.TableMetadata

+ func (e *PointScanWithIndexExecutor) Init()

+ func (e *PointScanWithIndexExecutor) Next() (*tuple.Tuple, Done, error)

+ type RangeScanWithIndexExecutor struct

+ func (e *RangeScanWithIndexExecutor) GetOutputSchema() *schema.Schema

+ func (e *RangeScanWithIndexExecutor) GetTableMetaData() *catalog.TableMetadata

+ func (e *RangeScanWithIndexExecutor) Init()

+ func (e *RangeScanWithIndexExecutor) Next() (*tuple.Tuple, Done, error)

type SeqScanExecutor

+ func (e *SeqScanExecutor) GetTableMetaData() *catalog.TableMetadata

type UpdateExecutor

+ func (e *UpdateExecutor) GetTableMetaData() *catalog.TableMetadata

v0.0.1

Jun 28, 2022

Changes in this version

+ const DistSerial

+ const DistUniform

+ const TEST1_SIZE

+ const TEST2_SIZE

+ const TEST_VARLEN_SIZE

+ func ExecuteDeleteTestCase(t *testing.T, testCase DeleteTestCase)

+ func ExecuteHashIndexScanTestCase(t *testing.T, testCase HashIndexScanTestCase)

+ func ExecuteSeqScanTestCase(t *testing.T, testCase SeqScanTestCase)

+ func FillTable(info *catalog.TableMetadata, table_meta *TableInsertMeta, ...)

+ func GenNumericValues(col_meta *ColumnInsertMeta, count uint32) []types.Value

+ func GenNumericValuesFloat(col_meta *ColumnInsertMeta, count uint32) []types.Value

+ func GenerateTestTabls(c *catalog.Catalog, exec_ctx *ExecutorContext, txn *access.Transaction) (*catalog.TableMetadata, *catalog.TableMetadata)

+ func GetValue(data interface{}) (value types.Value)

+ func GetValueType(data interface{}) (value types.TypeID)

+ func HashValuesOnAggregateKey(key *plans.AggregateKey) uint32

+ func MakeAggregateValueExpression(is_group_by_term bool, col_index uint32) expression.Expression

+ func MakeColumnValueExpression(schema_ *schema.Schema, tuple_idx_on_join uint32, col_name string) expression.Expression

+ func MakeComparisonExpression(lhs expression.Expression, rhs expression.Expression, ...) expression.Expression

+ func MakeConstantValueExpression(val *types.Value) expression.Expression

+ func MakeOutputSchema(exprs []MakeSchemaMeta) *schema.Schema

+ func MakeOutputSchemaAgg(exprs []MakeSchemaMetaAgg) *schema.Schema

+ func MakeValues(col_meta *ColumnInsertMeta, count uint32) []types.Value

+ type AggregateHTIterator struct

+ func NewAggregateHTIteratorIterator(keys []*plans.AggregateKey, values []*plans.AggregateValue) *AggregateHTIterator

+ func (it *AggregateHTIterator) IsEnd() bool

+ func (it *AggregateHTIterator) IsNextEnd() bool

+ func (it *AggregateHTIterator) Key() *plans.AggregateKey

+ func (it *AggregateHTIterator) Next() bool

+ func (it *AggregateHTIterator) Val() *plans.AggregateValue

+ type AggregationExecutor struct

+ func NewAggregationExecutor(exec_ctx *ExecutorContext, plan *plans.AggregationPlanNode, child Executor) *AggregationExecutor

+ func (e *AggregationExecutor) GetOutputSchema() *schema.Schema

+ func (e *AggregationExecutor) Init()

+ func (e *AggregationExecutor) MakeKey(tuple_ *tuple.Tuple) *plans.AggregateKey

+ func (e *AggregationExecutor) MakeVal(tuple_ *tuple.Tuple) *plans.AggregateValue

+ func (e *AggregationExecutor) Next() (*tuple.Tuple, Done, error)

+ type Assertion struct

+ Column string

+ Exp interface{}

+ type Column struct

+ Kind types.TypeID

+ Name string

+ type ColumnIdx struct

+ HasIndex bool

+ Kind types.TypeID

+ Name string

+ type ColumnInsertMeta struct

+ Dist_ int32

+ Max_ int32

+ Min_ int32

+ Name_ string

+ Nullable_ bool

+ Serial_counter_ int32

+ Type_ types.TypeID

+ type DeleteExecutor struct

+ func (e *DeleteExecutor) GetOutputSchema() *schema.Schema

+ func (e *DeleteExecutor) Init()

+ func (e *DeleteExecutor) Next() (*tuple.Tuple, Done, error)

+ type DeleteTestCase struct

+ Asserts []Assertion

+ Columns []Column

+ Description string

+ ExecutionEngine *ExecutionEngine

+ ExecutorContext *ExecutorContext

+ Predicate Predicate

+ TableMetadata *catalog.TableMetadata

+ TotalHits uint32

+ TransactionManager *access.TransactionManager

+ type Done bool

+ type ExecutionEngine struct

+ func (e *ExecutionEngine) CreateExecutor(plan plans.Plan, context *ExecutorContext) Executor

+ func (e *ExecutionEngine) Execute(plan plans.Plan, context *ExecutorContext) []*tuple.Tuple

+ type Executor interface

+ GetOutputSchema func() *schema.Schema

+ Init func()

+ Next func() (*tuple.Tuple, Done, error)

+ func NewDeleteExecutor(context *ExecutorContext, plan *plans.DeletePlanNode) Executor

+ func NewFilterExecutor(context *ExecutorContext, plan *plans.FilterPlanNode, child Executor) Executor

+ func NewHashScanIndexExecutor(context *ExecutorContext, plan *plans.HashScanIndexPlanNode) Executor

+ func NewInsertExecutor(context *ExecutorContext, plan *plans.InsertPlanNode) Executor

+ func NewLimitExecutor(context *ExecutorContext, plan *plans.LimitPlanNode, child Executor) Executor

+ func NewSeqScanExecutor(context *ExecutorContext, plan *plans.SeqScanPlanNode) Executor

+ func NewUpdateExecutor(context *ExecutorContext, plan *plans.UpdatePlanNode) Executor

+ type ExecutorContext struct

+ func NewExecutorContext(catalog *catalog.Catalog, bpm *buffer.BufferPoolManager, ...) *ExecutorContext

+ func (e *ExecutorContext) GetBufferPoolManager() *buffer.BufferPoolManager

+ func (e *ExecutorContext) GetCatalog() *catalog.Catalog

+ func (e *ExecutorContext) GetTransaction() *access.Transaction

+ func (e *ExecutorContext) SetTransaction(txn *access.Transaction)

+ type FilterExecutor struct

+ func (e *FilterExecutor) GetOutputSchema() *schema.Schema

+ func (e *FilterExecutor) Init()

+ func (e *FilterExecutor) Next() (*tuple.Tuple, Done, error)

+ type HashIndexScanTestCase struct

+ Asserts []Assertion

+ Columns []Column

+ Description string

+ ExecutionEngine *ExecutionEngine

+ ExecutorContext *ExecutorContext

+ Predicate Predicate

+ TableMetadata *catalog.TableMetadata

+ TotalHits uint32

+ type HashJoinExecutor struct

+ func NewHashJoinExecutor(exec_ctx *ExecutorContext, plan *plans.HashJoinPlanNode, left Executor, ...) *HashJoinExecutor

+ func (e *HashJoinExecutor) FetchTupleFromTmpTuplePage(tuple_ *tuple.Tuple, tmp_tuple *hash.TmpTuple)

+ func (e *HashJoinExecutor) GetJHT() *SimpleHashJoinHashTable

+ func (e *HashJoinExecutor) GetOutputSchema() *schema.Schema

+ func (e *HashJoinExecutor) Init()

+ func (e *HashJoinExecutor) IsValidCombination(left_tuple *tuple.Tuple, right_tuple *tuple.Tuple) bool

+ func (e *HashJoinExecutor) MakeOutputTuple(left_tuple *tuple.Tuple, right_tuple *tuple.Tuple) *tuple.Tuple

+ func (e *HashJoinExecutor) Next() (*tuple.Tuple, Done, error)

+ type HashScanIndexExecutor struct

+ func (e *HashScanIndexExecutor) GetOutputSchema() *schema.Schema

+ func (e *HashScanIndexExecutor) Init()

+ func (e *HashScanIndexExecutor) Next() (*tuple.Tuple, Done, error)

+ type InsertExecutor struct

+ func (e *InsertExecutor) GetOutputSchema() *schema.Schema

+ func (e *InsertExecutor) Init()

+ func (e *InsertExecutor) Next() (*tuple.Tuple, Done, error)

+ type LimitExecutor struct

+ func (e *LimitExecutor) GetOutputSchema() *schema.Schema

+ func (e *LimitExecutor) Init()

+ func (e *LimitExecutor) Next() (*tuple.Tuple, Done, error)

+ type MakeSchemaMeta struct

+ Col_name_ string

+ Expr_ expression.ColumnValue

+ type MakeSchemaMetaAgg struct

+ Col_name_ string

+ Expr_ expression.AggregateValueExpression

+ type OrderbyExecutor struct

+ func NewOrderbyExecutor(exec_ctx *ExecutorContext, plan *plans.OrderbyPlanNode, child Executor) *OrderbyExecutor

+ func (e *OrderbyExecutor) GetChildOutputSchema() *schema.Schema

+ func (e *OrderbyExecutor) GetOutputSchema() *schema.Schema

+ func (e *OrderbyExecutor) Init()

+ func (e *OrderbyExecutor) Next() (*tuple.Tuple, Done, error)

+ type Predicate struct

+ LeftColumn string

+ Operator expression.ComparisonType

+ RightColumn interface{}

+ type SeqScanExecutor struct

+ func (e *SeqScanExecutor) GetOutputSchema() *schema.Schema

+ func (e *SeqScanExecutor) Init()

+ func (e *SeqScanExecutor) Next() (*tuple.Tuple, Done, error)

+ type SeqScanTestCase struct

+ Asserts []Assertion

+ Columns []Column

+ Description string

+ ExecutionEngine *ExecutionEngine

+ ExecutorContext *ExecutorContext

+ Predicate Predicate

+ TableMetadata *catalog.TableMetadata

+ TotalHits uint32

+ type SimpleAggregationHashTable struct

+ func NewSimpleAggregationHashTable(agg_exprs []expression.Expression, agg_types []plans.AggregationType) *SimpleAggregationHashTable

+ func (aht *SimpleAggregationHashTable) Begin() *AggregateHTIterator

+ func (aht *SimpleAggregationHashTable) CombineAggregateValues(result *plans.AggregateValue, input *plans.AggregateValue)

+ func (aht *SimpleAggregationHashTable) InsertCombine(agg_key *plans.AggregateKey, agg_val *plans.AggregateValue)

+ func (ht *SimpleAggregationHashTable) GenerateInitialAggregateValue() *plans.AggregateValue

+ type SimpleHashJoinHashTable struct

+ func NewSimpleHashJoinHashTable() *SimpleHashJoinHashTable

+ func (jht *SimpleHashJoinHashTable) GetValue(h uint32) []hash.TmpTuple

+ func (jht *SimpleHashJoinHashTable) Insert(h uint32, t *hash.TmpTuple) bool

+ type TableInsertMeta struct

+ Col_meta_ []*ColumnInsertMeta

+ Name_ string

+ Num_rows_ uint32

+ type UpdateExecutor struct

+ func (e *UpdateExecutor) GetOutputSchema() *schema.Schema

+ func (e *UpdateExecutor) Init()

+ func (e *UpdateExecutor) Next() (*tuple.Tuple, Done, error)

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