Check to see if the DbIterators have the same number of tuples and each tuple pair in parallel iteration satisfies compareTuples . If not, throw an

This is a helper method that computes the cost and cardinality of joining joinToRemove to joinSet (joinSet should contain joinToRemove

A utility method to create a new HeapFile with a single empty page, assuming the path does not already exist. If the path exists, the file will be ove

Static method to generate a byte array corresponding to an empty HeapPage. Used to add new, empty pages to the file. Passing the results of this metho

Remove the specified tuple from the buffer pool. Will acquire a write lock on the page the tuple is removed from. May block if the lock cannot be acqu

Remove the specific page id from the buffer pool. Needed by the recovery manager to ensure that the buffer pool doesn't keep a rolled back page in its

Helper method to enumerate all of the subsets of a given size of a specified vector. @param v The vector whose subsets are desired

Estimate the selectivity (as a double between 0 and 1) of the specified predicate over the specified string @param op The operation being app

Discards a page from the buffer pool. Flushes the page to disk to ensure dirty pages are updated on disk.

Write all pages of the specified transaction to disk.

Convert the aggregate operator name s into an Aggregator.op operation. @throws ParsingException if s is not a valid operator name

Computes the number of bytes in the header of a page in a HeapFile with each tuple occupying tupleSize bytes @return the number of bytes in the header

Generates a byte array representing the contents of this page. Used to serialize this page to disk. <p> The invariant here is that it should be possib

Unit test for RecordId.getPageId()

@return a String array of length len populated with the (possibly null) strings in val, and an appended increasing integer at the end (val1, val2, etc

@return the table associated with this PageId

Returns the TupleDesc of this Aggregate. If there is no group by field, this will have one field - the aggregate column. If there is a group by field,

@see simpledb.TupleDesc#combine(TupleDesc, TupleDesc) for possible implementation logic.

Generic unit test structure to grab an additional lock in a new thread. @param tid the transaction Id @param pid the first page to lock over @param p

Return true if a primary key field is joined by one of the joins in joinlist

Add a tuple to the specified table behalf of transaction tid. Will acquire a write lock on the page the tuple is added to(Lock acquisition is not need

Return best iterator for computing a given logical join, given the specified statistics, and the provided left and right subplans. Note that ther

Reads the schema from a file and creates the appropriate tables in the database. @param catalogFile

Write an abort record to the log for the specified tid, force the log to disk, and perform a rollback @param tid The aborting transact

Checkpoint the log and write a checkpoint record.

Write a commit record to disk for the specified tid, and force the log to disk. @param tid The committing transaction.

Truncate any unneeded portion of the log to reduce its space consumption

Write a BEGIN record for the specified transaction @param tid The transaction that is beginning

@return the maximum value indexed by the histogram

Merge a new tuple into the aggregate for a distinct group value; creates a new group aggregate result if the group value has not yet been encountered.

@return the minimum value indexed by the histogram

@return the page number in the table getTableId() associated with this PageId

Helper function to display a Swing window with a tree representation of the specified list of joins. See {@link #orderJoins}, which may want

@return a byte array containing the contents of the file 'path'

Suck up tuples from the source file. @throws Exception

Rollback the specified transaction, setting the state of any of pages it updated to their pre-updated state. To preserve transaction

Return a representation of this page id object as a collection of integers (used for logging) This class MUST have a constructor that

Write the bytes representing this field to the specified DataOutputStream. @see DataOutputStream @param dos The DataOutputStream to write to.

Return a new LogicalJoinNode with the inner and outer (t1.f1 and t2.f2) tables swapped.

Tests the scan operator for a table with the specified dimensions.

Push the specified page to disk. @param p The page to write. page.getId().pageno() specifies the offset into the file where the page should be writt

Constructor. <p> Implementation hint: depending on the type of afield, you will want to construct an IntAggregator or StringAggregator to help you wit

Creates a BufferPool that caches up to numPages pages. @param nPages maximum number of pages in this buffer pool.

Constructor. Creates a new, empty catalog.

Constructor specifying the transaction that this delete belongs to as well as the child to read from. @param t The transaction this delete runs in @pa

Constructor accepts a predicate to apply and a child operator to read tuples to filter from. @param p The predicate to filter tuples with @param chil

Constructs a heap file backed by the specified file. @param f the file that stores the on-disk backing store for this heap file.

Create a HeapPage from a set of bytes of data read from disk. The format of a HeapPage is a set of header bytes indicating the slots of the page that

Constructor. Create a page id structure for a specific page of a specific table. @param tableId The table that is being referenced @param pgNo The pa

Constructor. @param tid The transaction running the insert. @param child The child operator from which to read tuples to be inserted. @param tableid T

Aggregate constructor @param gbfield the 0-based index of the group-by field in the tuple, or NO_GROUPING if there is no grouping @param gbfieldtype t

Constructor. @param i The value of this field.

Create a new IntHistogram. This IntHistogram should maintain a histogram of integer values that it receives. It should split the histogram into "buck

Constructor. Accepts to children to join and the predicate to join them on @param p The predicate to use to join the children @param child1 Iterator