Package be.bagofwords.db.impl

Class BaseDataInterfaceFactory

java.lang.Object

be.bagofwords.db.impl.BaseDataInterfaceFactory

All Implemented Interfaces:

DataInterfaceFactory, be.bagofwords.minidepi.LifeCycleBean

Direct Known Subclasses:

FileDataInterfaceFactory, InMemoryDataInterfaceFactory, RemoteDatabaseInterfaceFactory

public abstract class BaseDataInterfaceFactory
extends Object
implements be.bagofwords.minidepi.LifeCycleBean, DataInterfaceFactory

Nested Class Summary

Nested classes/interfaces inherited from interface be.bagofwords.db.DataInterfaceFactory

DataInterfaceFactory.DataInterfaceReference

Field Summary

Fields

Modifier and Type	Field	Description
protected be.bagofwords.jobs.AsyncJobService	asyncJobService
protected be.bagofwords.memory.MemoryManager	memoryManager

Constructor Summary

Constructors

Constructor	Description
BaseDataInterfaceFactory(be.bagofwords.minidepi.ApplicationContext context)

Method Summary

Modifier and Type	Method	Description
void	cleanupClosedInterfaces()
void	closeAllInterfaces()
protected abstract <T> BaseDataInterface<T>	createBaseDataInterface(String name, Class<T> objectClass, Combinator<T> combinator, ObjectSerializer<T> objectSerializer, boolean isTemporaryDataInterface)
DataInterface<Long>	createCountDataInterface(String name)
<T> BaseDataInterface<T>	createDataInterface(String name, Class<T> objectClass, Combinator<T> combinator, ObjectSerializer<T> objectSerializer)
<T> BaseDataInterface<T>	createFromConfig(DataInterfaceConfig<T> config)
DataInterface<Long>	createInMemoryCountDataInterface(String name)
DataInterface<Long>	createTmpCountDataInterface(String name)
<T> DataInterfaceConfig<T>	dataInterface(String name, Class<T> objectClass, Class... genericParams)
List<DataInterfaceFactory.DataInterfaceReference>	getAllInterfaces()
protected abstract Class<? extends DataInterface>	getBaseDataInterfaceClass()
<T> MultiDataInterfaceIndex<T>	multiIndex(DataInterface<T> dataInterface, String nameOfIndex, MultiDataIndexer<T> indexer)
void	startBean()
void	stopBean()
void	terminate()
String	toString()
<T> UniqueDataInterfaceIndex<T>	uniqueIndex(DataInterface<T> dataInterface, String nameOfIndex, UniqueDataIndexer<T> indexer)

Methods inherited from class java.lang.Object

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

Methods inherited from interface be.bagofwords.db.DataInterfaceFactory

createDataInterface, createDataInterface, createIdDataInterface, createIdDataInterface, idDataInterface

Field Detail

memoryManager

protected final be.bagofwords.memory.MemoryManager memoryManager

asyncJobService

protected final be.bagofwords.jobs.AsyncJobService asyncJobService

Constructor Detail

BaseDataInterfaceFactory

public BaseDataInterfaceFactory(be.bagofwords.minidepi.ApplicationContext context)

Method Detail

dataInterface

public <T> DataInterfaceConfig<T> dataInterface(String name,
                                                Class<T> objectClass,
                                                Class... genericParams)

Specified by:

dataInterface in interface DataInterfaceFactory

multiIndex

public <T> MultiDataInterfaceIndex<T> multiIndex(DataInterface<T> dataInterface,
                                                 String nameOfIndex,
                                                 MultiDataIndexer<T> indexer)

Specified by:

multiIndex in interface DataInterfaceFactory

uniqueIndex

public <T> UniqueDataInterfaceIndex<T> uniqueIndex(DataInterface<T> dataInterface,
                                                   String nameOfIndex,
                                                   UniqueDataIndexer<T> indexer)

Specified by:

uniqueIndex in interface DataInterfaceFactory

createFromConfig

public <T> BaseDataInterface<T> createFromConfig(DataInterfaceConfig<T> config)

createBaseDataInterface

protected abstract <T> BaseDataInterface<T> createBaseDataInterface(String name,
                                                                    Class<T> objectClass,
                                                                    Combinator<T> combinator,
                                                                    ObjectSerializer<T> objectSerializer,
                                                                    boolean isTemporaryDataInterface)

getBaseDataInterfaceClass

protected abstract Class<? extends DataInterface> getBaseDataInterfaceClass()

createCountDataInterface

public DataInterface<Long> createCountDataInterface(String name)

Specified by:

createCountDataInterface in interface DataInterfaceFactory

createTmpCountDataInterface

public DataInterface<Long> createTmpCountDataInterface(String name)

Specified by:

createTmpCountDataInterface in interface DataInterfaceFactory

createInMemoryCountDataInterface

public DataInterface<Long> createInMemoryCountDataInterface(String name)

Specified by:

createInMemoryCountDataInterface in interface DataInterfaceFactory

createDataInterface

public <T> BaseDataInterface<T> createDataInterface(String name,
                                                    Class<T> objectClass,
                                                    Combinator<T> combinator,
                                                    ObjectSerializer<T> objectSerializer)

Specified by:

createDataInterface in interface DataInterfaceFactory

getAllInterfaces

public List<DataInterfaceFactory.DataInterfaceReference> getAllInterfaces()

Specified by:

getAllInterfaces in interface DataInterfaceFactory

startBean

public void startBean()

Specified by:

startBean in interface be.bagofwords.minidepi.LifeCycleBean

stopBean

public void stopBean()

Specified by:

stopBean in interface be.bagofwords.minidepi.LifeCycleBean

terminate

public void terminate()

Specified by:

terminate in interface DataInterfaceFactory

closeAllInterfaces

public void closeAllInterfaces()

Specified by:

closeAllInterfaces in interface DataInterfaceFactory

toString

public String toString()

Overrides:

toString in class Object

cleanupClosedInterfaces

public void cleanupClosedInterfaces()