Method init

src/org/apache/pig/builtin/Bloom.java:136–163

(Tuple input)

    }

    private void init(Tuple input) throws IOException {
        if (bloomFile == null) {
            if (input.get(0) instanceof DataByteArray) {
                filter = BuildBloomBase.bloomIn((DataByteArray) input.get(0));
            } else {
                throw new IllegalArgumentException("The first argument to the Bloom UDF should be"
                        + " the bloom filter if a bloom file is not specified in the constructor");
            }
        } else {
            filter = new BloomFilter();
            String dir = "./" + getFilenameFromPath(bloomFile);
            String[] partFiles = new File(dir)
                    .list(new FilenameFilter() {
                        @Override
                        public boolean accept(File current, String name) {
                            return name.startsWith("part");
                        }
                    });

            String dcFile = dir + "/" + partFiles[0];
            DataInputStream dis = new DataInputStream(new FileInputStream(dcFile));
            try {
                filter.readFields(dis);
            } finally {
                dis.close();
            }
        }
    }

    /**
     * For testing only, do not use directly.