Method open

src/java/simpledb/execution/Join.java:82–110

()

    }

    public void open() throws DbException, NoSuchElementException,
            TransactionAbortedException {
        // some code goes here
        child1.open();
        child2.open();

        while(child1.hasNext()){
            Tuple next1 = child1.next();
            while(child2.hasNext()){
                Tuple next2 = child2.next();
                if(joinPredicate.filter(next1,next2)){
                    Tuple mergeTuple = new Tuple(tupleDesc);
                    Iterator<Field> fields1 = next1.fields();
                    Iterator<Field> fields2 = next2.fields();
                    int count = 0;
                    while(fields1.hasNext()){
                        mergeTuple.setField(count++,fields1.next());
                    }
                    while(fields2.hasNext()){
                        mergeTuple.setField(count++,fields2.next());
                    }
                    childTuple.add(mergeTuple);
                }
            }
            child2.rewind();
        }
        it = childTuple.iterator();
        super.open();
    }

    public void close() {
        // some code goes here