hash

type LinearProbeHashTable ¶

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

*

• Implementation of linear probing hash table that is backed by a buffer pool
• manager. Non-unique keys are supported. Supports insert and delete. The
• table dynamically grows once full.

TODO: (SDB) LinearProbeHashTable does not dynamically grows...

func NewLinearProbeHashTable(bpm *buffer.BufferPoolManager, numBuckets int, headerPageId types.PageID) *LinearProbeHashTable

func (ht *LinearProbeHashTable) GetHeaderPageId() types.PageID

func (ht *LinearProbeHashTable) GetValue(key []byte) []uint32

func (ht *LinearProbeHashTable) Insert(key []byte, value uint32) (err error)

func (ht *LinearProbeHashTable) Remove(key []byte, value uint32)

type TmpTuple ¶

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

when doing hash join we create a temp page to store all the tuple from left table which corresponds to the input key from right tuple so that we can refer to this page when calling Next from the hash join executor

func NewTmpTuple(page_id types.PageID, offset uint32) *TmpTuple

func (tt *TmpTuple) Equals(rhs *TmpTuple) bool

func (tt *TmpTuple) GetOffset() uint32

func (tt *TmpTuple) GetPageId() types.PageID

type TmpTuplePage ¶

type TmpTuplePage struct {
	page.Page
}

*

• TmpTuplePage format: *
• Sizes are in bytes.
• | PageId (4) | LSN (4) | FreeSpace (4) | (free space) | TupleSize2 | TupleData2 | TupleSize1 | TupleData1 | *
• We choose this format because DeserializeExpression expects to read Size followed by Data.

func CastPageAsTmpTuplePage(page *page.Page) *TmpTuplePage

func (p *TmpTuplePage) Get(tuple_ *tuple.Tuple, offset uint32)

func (p *TmpTuplePage) GetFreeSpacePointer() uint32

func (p *TmpTuplePage) GetNextPosToInsert() []byte

func (p *TmpTuplePage) GetOffset() uint32

func (p *TmpTuplePage) GetTablePageId() types.PageID

func (p *TmpTuplePage) Init(page_id types.PageID, page_size uint32)

func (p *TmpTuplePage) Insert(tuple_ *tuple.Tuple, out *TmpTuple) bool

func (p *TmpTuplePage) SetFreeSpacePointer(size uint32)

func (p *TmpTuplePage) SetPageId(page_id types.PageID)