Pipe smallPipe = new Each(keys, new CollectKeyStats(keyBytesField));
smallPipe = new Each(smallPipe, new Fields(keyBytesField), new GetIndices(HashFunctionFactory.DEFAULT_HASH_FACTORY), new Fields("split", "index", "hash_num"));
smallPipe = new Each(smallPipe, new Fields("split", "index", "hash_num"), new Unique.FilterPartialDuplicates());
smallPipe = new GroupBy(smallPipe, new Fields("split"));
smallPipe = new Every(smallPipe, new Fields("index", "hash_num"), new CreateBloomFilterFromIndices(), Fields.ALL);
ConfigDef bloomDef = smallPipe.getStepConfigDef();
bloomDef.setProperty(BloomProps.BLOOM_FILTER_PARTS_DIR, bloomPartsDir);
bloomDef.setProperty(BloomProps.BLOOM_KEYS_COUNTS_DIR, approxCountPartsDir);
bloomDef.setProperty(BloomProps.TARGET_BLOOM_FILTER_ID, bloomFilterID);