Package com.activeviam.database.internal

Class DatabaseAdapter

java.lang.Object

com.activeviam.database.internal.DatabaseAdapter

All Implemented Interfaces:

IDatabase

public final class DatabaseAdapter
extends Object
implements IDatabase

Do not use this class as a shortcut to convert the internal database into a public IDatabase when you do not have access to the public database. This will prevent casting an IDatabase object to its explicit class.

Author:

ActiveViam

Constructor Summary

Constructors

Constructor	Description
DatabaseAdapter(IInternalDatabase underlying)

Method Summary

Modifier and Type	Method	Description
IDatabaseSchema	getCurrentSchema()	Returns the schema of the database.
IDataStreamer	getDataStreamer()	Returns the component responsible for managing streaming from this Database.
IDatabaseVersion	getHead(String branchName)	Gets the latest version in the given branch.
Map<String,IDatabaseVersion>	getHeads()	Returns the latest version of each branch.
IQueryManager	getQueryManager()	Returns a component capable of compiling queries to run in the future or registering subscriptions to data.
IDatabaseVersion	getVersion(long epochId)	Retrieves the version at the given epoch if there is one available.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.activeviam.database.api.IDatabase

getMasterHead

Constructor Details

DatabaseAdapter

public DatabaseAdapter(IInternalDatabase underlying)

Method Details

getCurrentSchema

public IDatabaseSchema getCurrentSchema()

Description copied from interface: IDatabase

Returns the schema of the database.

Specified by:

getCurrentSchema in interface IDatabase

getQueryManager

public IQueryManager getQueryManager()

Description copied from interface: IDatabase

Returns a component capable of compiling queries to run in the future or registering subscriptions to data.

Specified by:

getQueryManager in interface IDatabase

getDataStreamer

public IDataStreamer getDataStreamer()

Description copied from interface: IDatabase

Returns the component responsible for managing streaming from this Database.

Specified by:

getDataStreamer in interface IDatabase

getHeads

public Map<String,IDatabaseVersion> getHeads()

Description copied from interface: IDatabase

Returns the latest version of each branch.

The keys are the names of the branches.

Specified by:

getHeads in interface IDatabase

getHead

public IDatabaseVersion getHead(String branchName)

Description copied from interface: IDatabase

Gets the latest version in the given branch.

Specified by:

getHead in interface IDatabase

Parameters:

branchName - the name of a branch, null to retrieve the most recent versions across heads

getVersion

public IDatabaseVersion getVersion(long epochId)
                            throws UnknownEpochException

Description copied from interface: IDatabase

Retrieves the version at the given epoch if there is one available.

Specified by:

getVersion in interface IDatabase

Parameters:

epochId - the id of the epoch at which to retrieve the version

Throws:

UnknownEpochException - if this version is no more available