Method addJoin

src/java/simpledb/optimizer/LogicalPlan.java:123–137

Add a join between two fields of two different tables. @param joinField1 The name of the first join field; this can be a fully qualified name (e.g., tableName.field or alias.field) or may be an unqualified unique field name. If the name is ambiguous or unknown, a ParsingException will be throw

( String joinField1, String joinField2, Predicate.Op pred)

    */

    public void addJoin( String joinField1, String joinField2, Predicate.Op pred) throws ParsingException {
        joinField1 = disambiguateName(joinField1);
        joinField2 = disambiguateName(joinField2);
        String table1Alias = joinField1.split("[.]")[0];
        String table2Alias = joinField2.split("[.]")[0];
        String pureField1 = joinField1.split("[.]")[1];
        String pureField2 = joinField2.split("[.]")[1];

        if (table1Alias.equals(table2Alias))
            throw new ParsingException("Cannot join on two fields from same table");
        LogicalJoinNode lj = new LogicalJoinNode(table1Alias,table2Alias,pureField1, pureField2, pred);
        System.out.println("Added join between " + joinField1 + " and " + joinField2);
        joins.add(lj);

    }

    /** Add a join between a field and a subquery.
     *  @param joinField1 The name of the first join field; this can