Package com.foundationdb.util

Examples of com.foundationdb.util.BloomFilter

179
180
181
182
183
184
185
186
187
188
189
            TAP_OPEN.in();
            try {
                // Usually super.open called first, but needs to be done
                // opposite order here to allow Select_BloomFilter access
                // to the filled BloomFilter in the bindings.
                BloomFilter filter = loadBloomFilter();
                bindings.setBloomFilter(filterBindingPosition, filter);
                super.open();
            } finally {
                TAP_OPEN.out();
            }
View Full Code Here
218
219
220
221
222
223
224
225
226
227
228
229
230
231
        // For use by this class

        private BloomFilter loadBloomFilter()
        {
            BloomFilter filter = new BloomFilter(estimatedRowCount, ERROR_RATE);
            long rows = loadBloomFilter(filter);
            if (rows > estimatedRowCount) {
                // Do it again, but size the filter based on the actual row count
                filter = new BloomFilter(rows, ERROR_RATE);
                loadBloomFilter(filter);
            }
            return filter;
        }
View Full Code Here
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
            }
        }

        @Override
        protected Row nextInputRow() {
            BloomFilter filter = baseBindings.getBloomFilter(bindingPosition);
            while (true) {
                Row row = input.next();
                if (row == null) {
                    return row;
                }
                if (filter.maybePresent(hashProjectedRow(row))) {
                    if (ExecutionBase.LOG_EXECUTION) {
                        LOG.debug("Select_BloomFilter: candidate {}", row);
                    }
                    return row;
                }
View Full Code Here
TOP

Related Classes of com.foundationdb.util.BloomFilter

  • com.foundationdb.qp.operator.Select_BloomFilter$FilterBindingsCursor
  • com.foundationdb.qp.operator.Using_BloomFilter$Execution
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.