Method exec

test/org/apache/pig/test/TestFRJoin.java:105–115

(Tuple input)

        }

        @Override
        public DataBag exec(Tuple input) throws IOException {
            if (!isTblSetUp) {
                setUpHashTable();
                isTblSetUp = true;
            }
            String key = (String)input.get(keyField);
            if (!replTbl.containsKey(key))
                return BagFactory.getInstance().newDefaultBag();
            return replTbl.get(key);
        }

        private void setUpHashTable() throws IOException {
            FileSpec replFile = new FileSpec(repl, new FuncSpec(PigStorage.class.getName() + "()"));