public int compare()

in wayang-plugins/wayang-iejoin/code/main/java/org/apache/wayang/iejoin/operators/java_helpers/DataComparator.java [43:83]

• 38 lines of code
• 13 McCabe index (conditional complexity)

    public int compare(Tuple2<Data<Type0, Type1>, Input> o1p, Tuple2<Data<Type0, Type1>, Input> o2p) {
        // first level of sorting
        Data<Type0, Type1> o1 = o1p._1();
        Data<Type0, Type1> o2 = o2p._1();
        int dff = 0;
        if (asc1) {
            dff = o1.compareTo(o2);
        } else {
            dff = o2.compareTo(o1);
        }
        // second level of sorting
        if (dff == 0) {
            int dff2 = 0;
            if (asc2) {
                dff2 = o1.compareRank(o2);
            } else {
                dff2 = o2.compareRank(o1);
            }
            // third level of sorting
            if (dff2 == 0) {
                if ((o1.isPivot() && o2.isPivot())
                        || (!o1.isPivot() && !o2.isPivot())) {
                    return ((int) o1.getRowID() - (int) o2.getRowID());
                } else if (o1.isPivot()) {
                    if (asc1) {
                        return -1;
                    } else {
                        return 1;
                    }
                } else if (o2.isPivot()) {
                    if (!asc1) {
                        return 1;
                    } else {
                        return -1;
                    }
                }
            }
            return dff2;
        }
        return dff;
    }