Package be.bagofwords.db.cached

Class CachedDataInterface<T>

java.lang.Object

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

be.bagofwords.db.LayeredDataInterface<T>

be.bagofwords.db.cached.CachedDataInterface<T>

All Implemented Interfaces:

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

public class CachedDataInterface<T>
extends LayeredDataInterface<T>
implements be.bagofwords.memory.MemoryGobbler

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
CachedDataInterface(be.bagofwords.memory.MemoryManager memoryManager, be.bagofwords.cache.CachesManager cachesManager, DataInterface<T> baseInterface, be.bagofwords.jobs.AsyncJobService asyncJobService)

Method Summary

Modifier and Type	Method	Description
be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>	cachedValueIterator()
void	doCloseImpl()
void	dropAllData()
void	flush()
long	freeMemory()
long	getMemoryUsage()
be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>	iterator(KeyFilter keyFilter)
be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>	iterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)
boolean	mightContain(long key)
T	read(long key)
be.bagofwords.iterator.CloseableIterator<T>	valueIterator(KeyFilter keyFilter)
be.bagofwords.iterator.CloseableIterator<T>	valueIterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)
void	write(long key, T value)
void	write(be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> entries)

Methods inherited from class be.bagofwords.db.LayeredDataInterface

apprSize, doClose, getCoreDataInterface, iterator, iterator, keyIterator, optimizeForReading, registerUpdateListener, streamValues, streamValues, 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

CachedDataInterface

public CachedDataInterface(be.bagofwords.memory.MemoryManager memoryManager,
                           be.bagofwords.cache.CachesManager cachesManager,
                           DataInterface<T> baseInterface,
                           be.bagofwords.jobs.AsyncJobService asyncJobService)

Method Detail

read

public T read(long key)

Specified by:

read in interface DataInterface<T>

Overrides:

read in class LayeredDataInterface<T>

iterator

public be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> iterator(KeyFilter keyFilter)

Specified by:

iterator in interface DataInterface<T>

Overrides:

iterator in class LayeredDataInterface<T>

valueIterator

public be.bagofwords.iterator.CloseableIterator<T> valueIterator(KeyFilter keyFilter)

Specified by:

valueIterator in interface DataInterface<T>

Overrides:

valueIterator in class LayeredDataInterface<T>

iterator

public be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> iterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)

Specified by:

iterator in interface DataInterface<T>

Overrides:

iterator in class LayeredDataInterface<T>

valueIterator

public be.bagofwords.iterator.CloseableIterator<T> valueIterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)

Specified by:

valueIterator in interface DataInterface<T>

Overrides:

valueIterator in class LayeredDataInterface<T>

mightContain

public boolean mightContain(long key)

Specified by:

mightContain in interface DataInterface<T>

Overrides:

mightContain 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>

cachedValueIterator

public be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> cachedValueIterator()

Specified by:

cachedValueIterator in interface DataInterface<T>

Overrides:

cachedValueIterator in class LayeredDataInterface<T>

write

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

Specified by:

write in interface DataInterface<T>

Overrides:

write in class LayeredDataInterface<T>

doCloseImpl

public void doCloseImpl()

Specified by:

doCloseImpl in class LayeredDataInterface<T>

flush

public void flush()

Specified by:

flush in interface DataInterface<T>

Overrides:

flush in class LayeredDataInterface<T>

dropAllData

public void dropAllData()

Specified by:

dropAllData in interface DataInterface<T>

Overrides:

dropAllData in class LayeredDataInterface<T>

freeMemory

public long freeMemory()

Specified by:

freeMemory in interface be.bagofwords.memory.MemoryGobbler

getMemoryUsage

public long getMemoryUsage()

Specified by:

getMemoryUsage in interface be.bagofwords.memory.MemoryGobbler