Package be.bagofwords.db.filedb

Class FileDataInterface<T>

java.lang.Object

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

be.bagofwords.db.CoreDataInterface<T>

be.bagofwords.db.filedb.FileDataInterface<T>

Type Parameters:

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 FileDataInterface<T>
extends CoreDataInterface<T>
implements be.bagofwords.memory.MemoryGobbler

Improvements: 1) Make sure keys can have any distribution (e.g. sequential starting from 0), without affecting performance - either infrequently restructure buckets - or rewrite hashes 2) Support ObjectSerializer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FileDataInterface.MetaFile

Field Summary

Fields inherited from class be.bagofwords.db.CoreDataInterface

updateListenerCollection

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

combinator, isTemporaryDataInterface, name, objectClass, objectSerializer

Constructor Summary

Constructors

Constructor	Description
FileDataInterface(be.bagofwords.memory.MemoryManager memoryManager, Combinator<T> combinator, Class<T> objectClass, String directory, String name, boolean isTemporaryDataInterface, be.bagofwords.jobs.AsyncJobService asyncJobService, ObjectSerializer<T> objectSerializer)

Method Summary

Modifier and Type	Method	Description
long	apprSize()
protected void	doClose()
void	dropAllData()
void	flushImpl()
long	freeMemory()
long	getMemoryUsage()
be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>	iterator()
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)
be.bagofwords.iterator.CloseableIterator<Long>	keyIterator()
void	optimizeForReading()
T	read(long key)
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.CoreDataInterface

flush, getCoreDataInterface, registerUpdateListener

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

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

FileDataInterface

public FileDataInterface(be.bagofwords.memory.MemoryManager memoryManager,
                         Combinator<T> combinator,
                         Class<T> objectClass,
                         String directory,
                         String name,
                         boolean isTemporaryDataInterface,
                         be.bagofwords.jobs.AsyncJobService asyncJobService,
                         ObjectSerializer<T> objectSerializer)

Method Detail

read

public T read(long key)

Specified by:

read in interface DataInterface<T>

write

public void write(long key,
                  T value)

Specified by:

write in interface DataInterface<T>

write

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

Specified by:

write in interface DataInterface<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>

iterator

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

Specified by:

iterator in interface DataInterface<T>

Specified by:

iterator in interface be.bagofwords.iterator.DataIterable<T>

Specified by:

iterator in interface Iterable<T>

iterator

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

Specified by:

iterator in interface DataInterface<T>

keyIterator

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

Specified by:

keyIterator in interface DataInterface<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

apprSize

public long apprSize()

Specified by:

apprSize in interface DataInterface<T>

Specified by:

apprSize in interface be.bagofwords.iterator.DataIterable<T>

flushImpl

public void flushImpl()

Specified by:

flushImpl in class CoreDataInterface<T>

optimizeForReading

public void optimizeForReading()

Specified by:

optimizeForReading in interface DataInterface<T>

doClose

protected void doClose()

Specified by:

doClose in class BaseDataInterface<T>

dropAllData

public void dropAllData()

Specified by:

dropAllData in interface DataInterface<T>