public class BloomFilterFactory extends Object
BloomFilterFn
which is responsible for generating keys of the filter.Constructor and Description |
---|
BloomFilterFactory() |
Modifier and Type | Method and Description |
---|---|
static PObject<Map<String,org.apache.hadoop.util.bloom.BloomFilter>> |
createFilter(org.apache.hadoop.fs.Path inputPath,
BloomFilterFn<String> filterFn)
The method will take an input path and generates BloomFilters for all text
files in that path.
|
static <T> PObject<org.apache.hadoop.util.bloom.BloomFilter> |
createFilter(PCollection<T> collection,
BloomFilterFn<T> filterFn) |
public static PObject<Map<String,org.apache.hadoop.util.bloom.BloomFilter>> createFilter(org.apache.hadoop.fs.Path inputPath, BloomFilterFn<String> filterFn) throws IOException
PObject
containing a
Map
having file names as keys and filters as valuesIOException
public static <T> PObject<org.apache.hadoop.util.bloom.BloomFilter> createFilter(PCollection<T> collection, BloomFilterFn<T> filterFn)
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.