Method setUpHashTable

test/org/apache/pig/test/TestFRJoin.java:117–143

()

        }

        private void setUpHashTable() throws IOException {
            FileSpec replFile = new FileSpec(repl, new FuncSpec(PigStorage.class.getName() + "()"));
            POLoad ld = new POLoad(new OperatorKey("Repl File Loader", 1L), replFile);
            PigContext pc = new PigContext(ExecType.MAPREDUCE, PigMapReduce.sJobConfInternal.get());
            pc.connect();

            ld.setPc(pc);
            for (Result res = ld.getNextTuple(); res.returnStatus != POStatus.STATUS_EOP; res = ld
                    .getNextTuple()) {
                Tuple tup = (Tuple)res.result;
                LoadFunc lf = ((LoadFunc)PigContext.instantiateFuncFromSpec(ld.getLFile().getFuncSpec()));
                String key = lf.getLoadCaster().bytesToCharArray(
                        ((DataByteArray)tup.get(keyField)).get());
                Tuple csttup = TupleFactory.getInstance().newTuple(2);
                csttup.set(0, key);
                csttup.set(1, lf.getLoadCaster().bytesToInteger(((DataByteArray)tup.get(1)).get()));
                DataBag vals = null;
                if (replTbl.containsKey(key)) {
                    vals = replTbl.get(key);
                }
                else {
                    vals = BagFactory.getInstance().newDefaultBag();
                    replTbl.put(key, vals);
                }
                vals.add(csttup);
            }
        }

    }