Method exec

src/org/apache/pig/builtin/COR.java:141–161

(Tuple input)

    static public class Initial extends EvalFunc<Tuple> {
        @Override
        public Tuple exec(Tuple input) throws IOException {
            if (input == null || input.size() == 0)
                return null;
            Tuple output = TupleFactory.getInstance().newTuple(input.size()*(input.size()-1)); 
            try {
                int k = -1;
                for(int i=0;i<input.size();i++){
                    for(int j=i+1;j<input.size();j++){
                        DataBag first = (DataBag)input.get(i);
                        DataBag second = (DataBag)input.get(j);
                        output.set(++k, computeAll(first, second));
                        output.set(++k, (Long)first.size());
                    }
                }
            } catch(Exception t) {
                System.err.println("Failed to process input record; error - " + t.getMessage());
                return null;
            }
            return output;    
        }
    } 

    static public class Intermed extends EvalFunc<Tuple> {