Package | Description |
---|---|
com.amazon.carbonado |
Main user-level interfaces, classes, and annotations for Carbonado.
|
com.amazon.carbonado.capability |
Common capabilities for repositories.
|
com.amazon.carbonado.layout |
Support for recording the evolution of a storable's layout, used internally
by some repositories.
|
com.amazon.carbonado.qe |
Support for implementing a Query Engine.
|
com.amazon.carbonado.repo.indexed |
Repository implementation that adds index support for repositories that have
little or no index support.
|
com.amazon.carbonado.repo.jdbc |
Repository implementation that connects to an external SQL database via
JDBC.
|
com.amazon.carbonado.repo.logging |
Repository implementation which logs activity against it.
|
com.amazon.carbonado.repo.map |
Volatile repository implementation backed by a concurrent map.
|
com.amazon.carbonado.repo.replicated |
Repository implementation that supports replication between two
repositories.
|
com.amazon.carbonado.repo.sleepycat |
Repository implementation backed by a Sleepycat (BDB, Berkeley)
database.
|
com.amazon.carbonado.sequence |
Support for generating sequences of values, intended for creating surrogate
keys.
|
com.amazon.carbonado.spi |
Service Provider Interface for Carbonado.
|
com.amazon.carbonado.txn |
Provides support for managing transactions.
|
Modifier and Type | Class and Description |
---|---|
class |
ConfigurationException
Indicates that a
Repository could not be
instantiated given the configuration information provided to a RepositoryBuilder . |
class |
ConstraintException
A ConstraintException is thrown if the
Repository storage layer
detects any kind of constraint violation. |
class |
CorruptEncodingException
A CorruptEncodingException is caused when decoding an encoded record fails.
|
class |
FetchDeadlockException
Thrown if a fetch operation fails because it was selected to resolve a
deadlock.
|
class |
FetchException
A FetchException is caused by a failure when selecting records from a
Repository . |
class |
FetchInterruptedException
Thrown from a fetch operation that was canceled.
|
class |
FetchMultipleException
A FetchMultipleException is thrown when a fetch operation returned more
than one record when at most one was expected.
|
class |
FetchNoneException
A FetchNoneException is thrown when a fetch operation returned no records
when at least one was expected.
|
class |
FetchTimeoutException
Thrown if a fetch operation fails because lock acquisition timed out.
|
class |
MismatchException
Indicates that a
Storable doesn't exactly match up with an external
schema. |
class |
NonDurableCommitException
Thrown during a transaction commit if durability guarantees cannot be met.
|
class |
OptimisticLockException
An OptimisticLockException is thrown if the
Repository is using
optimistic locking for concurrency control, and lock aquisition failed. |
class |
PersistDeadlockException
Thrown if a persist operation fails because it was selected to resolve a
deadlock.
|
class |
PersistDeniedException
Thrown when a persist operation was denied either because the repository is
in read-only mode, or the connection does not have permission.
|
class |
PersistException
A PersistException is caused by a failure when inserting, updating, or
deleting records from a
Repository . |
class |
PersistInterruptedException
Thrown from a persist operation that was canceled.
|
class |
PersistMultipleException
A PersistMultipleException is thrown when a persist operation would have
applied to more than one record when at most one was expected.
|
class |
PersistNoneException
A PersistNoneException is thrown when a persist operation applied to no
records when at least one was expected.
|
class |
PersistTimeoutException
Thrown if a persist operation fails because lock acquisition timed out.
|
class |
SupportException
Indicates that an action cannot be supported by the
Repository it is being requested from. |
static class |
Trigger.Abort |
class |
UniqueConstraintException
A UniqueConstraintException is thrown if the
Repository storage
layer has a unique constraint check defined for a property, and a violation
has been detected. |
class |
UnsupportedTypeException
Thrown by a
Repository which cannot support a Storable which
is declared as Independent or Authoritative . |
Modifier and Type | Method and Description |
---|---|
Repository |
RepositoryBuilder.build()
Builds a repository instance.
|
Repository |
RepositoryBuilder.build(java.util.concurrent.atomic.AtomicReference<Repository> rootReference)
Builds a repository instance.
|
<S extends Storable> |
Repository.storageFor(java.lang.Class<S> type)
Returns a Storage instance for the given user defined Storable class or
interface.
|
<S extends Storable> |
TriggerFactory.triggerFor(java.lang.Class<S> type)
Return an appropriate trigger for the given type, or null if none.
|
Modifier and Type | Method and Description |
---|---|
<R,D> RemoteProcedure.Call<R,D> |
RemoteProcedureCapability.beginCall(RemoteProcedure<R,D> proc)
Begins a call to execute the given procedure on a remote host.
|
RemoteProcedure.Reply<R> |
RemoteProcedure.Request.beginReply()
Begin a reply after receiving all data.
|
void |
RemoteProcedure.Call.execute()
Executes the call without expecting a reply.
|
void |
RemoteProcedure.Call.executeAsync()
Executes the call without expecting a reply.
|
Cursor<R> |
RemoteProcedure.Call.fetchReply()
Executes the call and receive a reply.
|
void |
RemoteProcedure.Request.finish()
Reply and immediately finish, without sending any data to caller.
|
void |
RemoteProcedure.Reply.finish()
Finish the reply.
|
void |
RemoteProcedure.Call.flush()
Flushes all the data sent so far.
|
void |
RemoteProcedure.Reply.flush()
Flushes all the data sent so far.
|
<S extends Storable> |
IndexInfoCapability.getIndexInfo(java.lang.Class<S> storableType)
Returns information about the known indexes for the given storable
type.
|
java.lang.String[] |
StorableInfoCapability.getUserStorableTypeNames()
Returns an array of storable type class names for user-level storables
known to the repository.
|
boolean |
RemoteProcedure.handleRequest(Repository repo,
RemoteProcedure.Request<R,D> request)
Request handler for remote procedure implementation.
|
D |
RemoteProcedure.Request.receive()
Receive data from caller.
|
int |
RemoteProcedure.Request.receiveInto(java.util.Collection<? super D> c)
Receive all remaining data from caller.
|
RemoteProcedure.Call<R,D> |
RemoteProcedure.Call.reset()
Reset the internal object stream of the call, allowing cached
objects to get freed.
|
RemoteProcedure.Reply<R> |
RemoteProcedure.Reply.reset()
Reset the internal object stream of the reply, allowing cached
objects to get freed.
|
<S extends Storable> |
ResyncCapability.resync(java.lang.Class<S> type,
double desiredSpeed,
java.lang.String filter,
java.lang.Object... filterValues)
Re-synchronizes replicated storables against the master repository.
|
<S extends Storable> |
ResyncCapability.resync(java.lang.Class<S> type,
ResyncCapability.Listener<? super S> listener,
double desiredSpeed,
java.lang.String filter,
java.lang.Object... filterValues)
Re-synchronizes replicated storables against the master repository.
|
RemoteProcedure.Call<R,D> |
RemoteProcedure.Call.send(D data)
Send data to the remote procedure.
|
RemoteProcedure.Reply<R> |
RemoteProcedure.Reply.send(R data)
Send reply data to the caller.
|
RemoteProcedure.Call<R,D> |
RemoteProcedure.Call.sendAll(Cursor<? extends D> cursor)
Send all data from the given cursor to the remote procedure.
|
RemoteProcedure.Reply<R> |
RemoteProcedure.Reply.sendAll(Cursor<? extends R> cursor)
Reply with all data from the given cursor to the caller.
|
RemoteProcedure.Call<R,D> |
RemoteProcedure.Call.sendAll(java.lang.Iterable<? extends D> iterable)
Send all data from the given iterable to the remote procedure.
|
RemoteProcedure.Reply<R> |
RemoteProcedure.Reply.sendAll(java.lang.Iterable<? extends R> iterable)
Reply with all data from the given iterable to the caller.
|
Modifier and Type | Method and Description |
---|---|
Layout |
LayoutFactory.readLayoutFrom(java.io.InputStream in)
Read a layout as written by
Layout.writeTo(java.io.OutputStream) . |
boolean |
LayoutSync.run() |
void |
Layout.writeTo(java.io.OutputStream out)
Write a layout to be read by
LayoutFactory.readLayoutFrom(java.io.InputStream) . |
Constructor and Description |
---|
LayoutFactory(Repository repo) |
Modifier and Type | Method and Description |
---|---|
UnionQueryAnalyzer.Result |
UnionQueryAnalyzer.analyze(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints) |
IndexedQueryAnalyzer.Result |
IndexedQueryAnalyzer.analyze(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints) |
static <T extends Storable> |
JoinedQueryExecutor.build(RepositoryAccess repoAccess,
ChainedProperty<T> targetToSourceProperty,
Filter<T> targetFilter,
OrderingList<T> targetOrdering,
QueryHints hints)
Builds and returns a complex joined excutor against a chained property,
supporting multi-way joins.
|
QueryExecutor<S> |
UnionQueryAnalyzer.Result.createExecutor()
Creates a QueryExecutor based on this result.
|
QueryExecutor<S> |
IndexedQueryAnalyzer.Result.createExecutor()
Creates a QueryExecutor based on this result.
|
protected QueryExecutor<S> |
StandardQuery.executor()
Returns the executor in use by this query.
|
QueryExecutor<S> |
UnionQueryAnalyzer.executor(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints)
Returns an executor that handles the given query specification.
|
QueryExecutor<S> |
QueryExecutorCache.executor(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints)
Returns an executor from the cache.
|
QueryExecutor<S> |
QueryExecutorFactory.executor(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints)
Returns an executor that handles the given query specification.
|
QueryExecutor<S> |
QueryEngine.executor(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints) |
protected void |
StandardQuery.resetExecutor()
Resets any cached reference to a query executor.
|
void |
StandardQueryFactory.resetExecutors()
For each cached query, calls
StandardQuery.resetExecutor() . |
protected void |
StandardQuery.setExecutor()
Ensures that a cached query executor reference is available.
|
void |
StandardQueryFactory.setExecutors()
For each cached query, calls
StandardQuery.setExecutor() . |
<S extends Storable> |
RepositoryAccess.storageAccessFor(java.lang.Class<S> type)
Returns a StorageAccess instance for the given user defined Storable
class or interface.
|
Modifier and Type | Method and Description |
---|---|
Repository |
IndexedRepositoryBuilder.build(java.util.concurrent.atomic.AtomicReference<Repository> rootRef) |
<S extends Storable> |
IndexEntryAccessCapability.getIndexEntryAccessors(java.lang.Class<S> storableType)
Returns index entry accessors for the known indexes of the given
storable type.
|
void |
IndexEntryAccessor.repair(double desiredSpeed)
Repairs the index by inserting missing entries and fixing
inconsistencies.
|
Modifier and Type | Method and Description |
---|---|
Repository |
JDBCRepositoryBuilder.build(java.util.concurrent.atomic.AtomicReference<Repository> rootRef) |
Modifier and Type | Method and Description |
---|---|
Repository |
LoggingRepositoryBuilder.build(java.util.concurrent.atomic.AtomicReference<Repository> rootRef) |
Modifier and Type | Method and Description |
---|---|
Repository |
MapRepositoryBuilder.build(java.util.concurrent.atomic.AtomicReference<Repository> rootRef) |
Modifier and Type | Method and Description |
---|---|
Repository |
ReplicatedRepositoryBuilder.build(java.util.concurrent.atomic.AtomicReference<Repository> rootRef) |
Modifier and Type | Method and Description |
---|---|
Repository |
BDBRepositoryBuilder.build(java.util.concurrent.atomic.AtomicReference<Repository> rootRef) |
<S extends Storable> |
CompactionCapability.compact(java.lang.Class<S> storableType)
Compact an entire BDB backed storage.
|
void |
HotBackupCapability.Backup.endBackup()
Resume normal operation.
|
java.io.File[] |
HotBackupCapability.Backup.getDataFiles()
Returns all the data files to be copied.
|
java.io.File[] |
HotBackupCapability.Backup.getFiles()
Deprecated.
use getDataFiles and getLogFiles
|
long |
HotBackupCapability.Backup.getLastLogNumber()
Can be called after a backup has been performed to find the last log file
that has been backed up.
|
java.io.File[] |
HotBackupCapability.Backup.getLogFiles()
Returns all the transaction log files to be copied, in the exact
order in which they must be copied.
|
void |
BDBRepositoryBuilder.DatabaseHook.prepareForOpening(java.lang.Object db)
Called right before database is opened.
|
HotBackupCapability.Backup |
HotBackupCapability.startBackup()
Starts the backup by disabling log file deletion.
|
HotBackupCapability.Backup |
HotBackupCapability.startBackup(boolean deleteOldLogFiles)
Starts the backup by disabling log file deletion.
|
HotBackupCapability.Backup |
HotBackupCapability.startIncrementalBackup(long lastLogNumber)
Starts an incremental backup.
|
HotBackupCapability.Backup |
HotBackupCapability.startIncrementalBackup(long lastLogNumber,
boolean deleteOldLogFiles)
Starts an incremental backup.
|
boolean |
BDBRepositoryBuilder.verify(java.io.PrintStream out)
Opens the BDB environment, checks if it is corrupt, and then closes it.
|
Modifier and Type | Method and Description |
---|---|
protected SequenceValueProducer |
SequenceValueProducerPool.create(java.lang.String name) |
protected abstract SequenceValueProducer |
SequenceValueProducerPool.createSequenceValueProducer(java.lang.String name) |
SequenceValueProducer |
SequenceValueProducerPool.get(java.lang.String name)
Returns a SequenceValueProducer instance for the given name, which is
lazily created and pooled.
|
SequenceValueProducer |
SequenceCapability.getSequenceValueProducer(java.lang.String name)
Retrieve and/or generate a SequenceValueProducer for the given name.
|
Constructor and Description |
---|
SequenceValueGenerator(Repository repo,
java.lang.String name)
Construct a new SequenceValueGenerator which might create persistent
sequence data if it does not exist.
|
SequenceValueGenerator(Repository repo,
java.lang.String name,
long initialValue,
int increment)
Construct a new SequenceValueGenerator which might create persistent
sequence data if it does not exist.
|
SequenceValueGenerator(Repository repo,
java.lang.String name,
long initialValue,
int increment,
int reserveAmount)
Construct a new SequenceValueGenerator which might create persistent
sequence data if it does not exist.
|
Modifier and Type | Method and Description |
---|---|
RepositoryException |
ExceptionTransformer.toRepositoryException(java.lang.Throwable e)
Transforms the given throwable into an appropriate repository
exception.
|
protected RepositoryException |
ExceptionTransformer.transformIntoRepositoryException(java.lang.Throwable e)
Override to support custom transformations, returning null if none is
applicable.
|
Modifier and Type | Method and Description |
---|---|
void |
TriggerManager.addTriggers(java.lang.Class<S> type,
java.lang.Iterable<TriggerFactory> triggerFactories) |
Repository |
AbstractRepositoryBuilder.build() |
protected Storage |
StoragePool.create(java.lang.Class type) |
protected abstract SequenceValueProducer |
AbstractRepository.createSequenceValueProducer(java.lang.String name)
Called upon to create a new SequenceValueProducer instance.
|
protected abstract <S extends Storable> |
AbstractRepository.createStorage(java.lang.Class<S> type)
Called upon to create a new Storage instance.
|
protected abstract <S extends Storable> |
StoragePool.createStorage(java.lang.Class<S> type) |
SequenceValueProducer |
AbstractRepository.getSequenceValueProducer(java.lang.String name) |
<S extends Storable> |
StoragePool.getStorage(java.lang.Class<S> type)
Returns a Storage instance for the given Storable type, which is lazily
created and pooled.
|
<S extends Storable> |
TriggerManagerCapability.getTriggerManagerFor(java.lang.Class<S> type)
Returns the
TriggerManager for the given Storable type. |
<S extends Storable> |
AbstractRepository.storageFor(java.lang.Class<S> type) |
Constructor and Description |
---|
LobEngine(Repository lobRepo,
Repository locatorRepo) |
LobEngine(Repository lobRepo,
SequenceValueProducer locatorSequenceProducer) |
TriggerManager(java.lang.Class<S> type,
java.lang.Iterable<TriggerFactory> triggerFactories) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionManager.close(boolean suspend)
Closes all transaction scopes.
|
Copyright © 2006-2013 Amazon Technologies, Inc.. All Rights Reserved.