Package be.bagofwords.db.bloomfilter

Class BloomFilterDataInterface<T>

java.lang.Object

be.bagofwords.db.impl.BaseDataInterface<T>

be.bagofwords.db.LayeredDataInterface<T>

be.bagofwords.db.bloomfilter.BloomFilterDataInterface<T>

All Implemented Interfaces:

DataInterface<T>, be.bagofwords.iterator.DataIterable<be.bagofwords.util.KeyValue<T>>, Iterable<be.bagofwords.util.KeyValue<T>>

public class BloomFilterDataInterface<T>
extends LayeredDataInterface<T>

Field Summary

Fields inherited from class be.bagofwords.db.LayeredDataInterface

baseInterface

Fields inherited from class be.bagofwords.db.impl.BaseDataInterface

combinator, isTemporaryDataInterface, name, objectClass, objectSerializer

Constructor Summary

Constructors

Constructor	Description
BloomFilterDataInterface(BaseDataInterface<T> baseInterface, BaseDataInterface<LongBloomFilterWithCheckSum> bloomFilterDataInterface, be.bagofwords.jobs.AsyncJobService asyncJobService)

Method Summary

Modifier and Type	Method	Description
protected void	doCloseImpl()
void	dropAllData()
void	flush()
boolean	mightContain(long key)
void	optimizeForReading()
T	read(long key)
void	write(long key, T value)
void	write(be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> keyValueIterator)

Methods inherited from class be.bagofwords.db.LayeredDataInterface

apprSize, cachedValueIterator, doClose, getCoreDataInterface, iterator, iterator, iterator, iterator, keyIterator, registerUpdateListener, streamValues, streamValues, valueIterator, valueIterator, valueIterator

Methods inherited from class be.bagofwords.db.impl.BaseDataInterface

apprDataChecksum, close, exactSize, finalize, getCombinator, getName, getObjectClass, getObjectSerializer, ifNotClosed, isTemporaryDataInterface, wasClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface be.bagofwords.db.DataInterface

increaseCount, increaseCount, increaseCount, increaseCount, iterator, mightContain, read, read, readCount, readCount, readCount, remove, remove, stream, stream, stream, stream, streamKeys, streamValues, streamValues, streamValues, valueIterator, valueIterator, write, write, write

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

BloomFilterDataInterface

public BloomFilterDataInterface(BaseDataInterface<T> baseInterface,
                                BaseDataInterface<LongBloomFilterWithCheckSum> bloomFilterDataInterface,
                                be.bagofwords.jobs.AsyncJobService asyncJobService)

Method Detail

optimizeForReading

public void optimizeForReading()

Specified by:

optimizeForReading in interface DataInterface<T>

Overrides:

optimizeForReading in class LayeredDataInterface<T>

read

public T read(long key)

Specified by:

read in interface DataInterface<T>

Overrides:

read in class LayeredDataInterface<T>

write

public void write(long key,
                  T value)

Specified by:

write in interface DataInterface<T>

Overrides:

write in class LayeredDataInterface<T>

write

public void write(be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> keyValueIterator)

Specified by:

write in interface DataInterface<T>

Overrides:

write in class LayeredDataInterface<T>

dropAllData

public void dropAllData()

Specified by:

dropAllData in interface DataInterface<T>

Overrides:

dropAllData in class LayeredDataInterface<T>

mightContain

public boolean mightContain(long key)

Specified by:

mightContain in interface DataInterface<T>

Overrides:

mightContain in class LayeredDataInterface<T>

flush

public void flush()

Specified by:

flush in interface DataInterface<T>

Overrides:

flush in class LayeredDataInterface<T>

doCloseImpl

protected void doCloseImpl()

Specified by:

doCloseImpl in class LayeredDataInterface<T>