Module org.elasticsearch.server

Package org.elasticsearch.index.codec.bloomfilter

Class IdBloomFilterSupplier

java.lang.Object

org.elasticsearch.index.codec.bloomfilter.IdBloomFilterSupplier

All Implemented Interfaces:

Closeable, AutoCloseable

public class IdBloomFilterSupplier
extends Object
implements Closeable

Owns the DocValuesProducer dedicated to bloom-filter lookups and vends per-caller BloomFilter instances from it.

Thread-safety contract: DocValuesProducer.getBinary(org.apache.lucene.index.FieldInfo) returns a new, independent BinaryDocValues reader on every call, each backed by its own I/O buffer. Callers must therefore invoke createBloomFilterInstance() once per logical lookup context (e.g. once per TermsEnum obtained via Terms.iterator()) and must not share the returned BloomFilter across threads. Sharing a single BloomFilter across threads would race on the mutable buffer state of its underlying RandomAccessInput.

Constructor Summary

Constructors

Constructor	Description
IdBloomFilterSupplier(org.apache.lucene.index.SegmentReadState state)

Method Summary

Modifier and Type	Method	Description
void	close()
BloomFilter	createBloomFilterInstance()	Returns a BloomFilter for the _id field backed by a freshly obtained reader from the underlying DocValuesProducer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

IdBloomFilterSupplier

public IdBloomFilterSupplier(org.apache.lucene.index.SegmentReadState state)
                      throws IOException

Throws:

IOException

Method Details

createBloomFilterInstance

public BloomFilter createBloomFilterInstance()
                                      throws IOException

Returns a BloomFilter for the _id field backed by a freshly obtained reader from the underlying DocValuesProducer. Must be called once per lookup context; the returned instance must not be shared across threads.

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException