Package | Description |
---|---|
com.amazon.carbonado |
Main user-level interfaces, classes, and annotations for Carbonado.
|
com.amazon.carbonado.adapter |
Contains annotations and implementations for supporting property adapters.
|
com.amazon.carbonado.cursor |
Support for advanced processing of cursor results, including basic set
theory operations.
|
com.amazon.carbonado.gen |
Storable code generation support intended for use by repository implementations.
|
com.amazon.carbonado.layout |
Support for recording the evolution of a storable's layout, used internally
by some repositories.
|
com.amazon.carbonado.lob |
Support for LOB property types, which are Large OBjects.
|
com.amazon.carbonado.qe |
Support for implementing a Query Engine.
|
com.amazon.carbonado.raw |
Provides support for repositories that encode/decode storables in a raw
binary format.
|
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.sequence |
Support for generating sequences of values, intended for creating surrogate
keys.
|
com.amazon.carbonado.spi |
Service Provider Interface for Carbonado.
|
com.amazon.carbonado.synthetic |
Support for dynamic creation of storables, intended for internal use by
repository implementations.
|
Modifier and Type | Class and Description |
---|---|
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 |
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.
|
Modifier and Type | Method and Description |
---|---|
protected FetchException |
PersistDeadlockException.makeFetchException(java.lang.String message,
java.lang.Throwable cause) |
protected FetchException |
PersistNoneException.makeFetchException(java.lang.String message,
java.lang.Throwable cause) |
protected FetchException |
PersistInterruptedException.makeFetchException(java.lang.String message,
java.lang.Throwable cause) |
protected FetchException |
PersistMultipleException.makeFetchException(java.lang.String message,
java.lang.Throwable cause) |
protected FetchException |
PersistTimeoutException.makeFetchException(java.lang.String message,
java.lang.Throwable cause) |
protected FetchException |
RepositoryException.makeFetchException(java.lang.String message,
java.lang.Throwable cause)
Subclasses can override this to provide a more specialized exception.
|
FetchException |
RepositoryException.toFetchException()
Converts RepositoryException into an appropriate FetchException.
|
FetchException |
RepositoryException.toFetchException(java.lang.String message)
Converts RepositoryException into an appropriate FetchException, prepending
the specified message.
|
Modifier and Type | Method and Description |
---|---|
<T extends S> |
Query.after(T start)
Returns a query which fetches results for this query after a given
starting point, which is useful for re-opening a cursor.
|
void |
Trigger.afterLoad(S storable)
Called right after a storable has been successfully loaded or
fetched.
|
Query<S> |
Query.and(Filter<S> filter)
Returns a new query which has another
filter logically "and"ed to this, potentially reducing the amount of
results. |
Query<S> |
Query.and(java.lang.String filter)
Returns a new query which has another
filter logically "and"ed to this, potentially reducing the amount of
results. |
void |
Cursor.close()
Call close to release any resources being held by this cursor.
|
void |
Query.Controller.continueCheck()
Periodically called by query to determine if it should continue.
|
int |
Cursor.copyInto(java.util.Collection<? super S> c)
Copies all remaining next elements into the given collection.
|
int |
Cursor.copyInto(java.util.Collection<? super S> c,
int limit)
Copies a limited amount of remaining next elements into the given
collection.
|
long |
Query.count()
Returns a count of all results matched by this query.
|
long |
Query.count(Query.Controller controller)
Returns a count of all results matched by this query.
|
boolean |
Query.exists()
Returns true if any results are matched by this query.
|
boolean |
Query.exists(Query.Controller controller)
Returns true if any results are matched by this query.
|
Cursor<S> |
Query.fetch()
Fetches results for this query.
|
Cursor<S> |
Query.fetch(Query.Controller controller)
Fetches results for this query.
|
<T extends S> |
Query.fetchAfter(T start)
Fetches results for this query after a given starting point, which is
useful for re-opening a cursor.
|
<T extends S> |
Query.fetchAfter(T start,
Query.Controller controller)
Fetches results for this query after a given starting point, which is
useful for re-opening a cursor.
|
Cursor<S> |
Query.fetchSlice(long from,
java.lang.Long to)
Fetches a slice of results for this query, as defined by a numerical
range.
|
Cursor<S> |
Query.fetchSlice(long from,
java.lang.Long to,
Query.Controller controller)
Fetches a slice of results for this query, as defined by a numerical
range.
|
boolean |
Cursor.hasNext()
Returns true if this cursor has more elements.
|
void |
Storable.load()
Loads or reloads this object from the storage layer by a primary or
alternate key.
|
S |
Query.loadOne()
Attempts to load exactly one matching object.
|
S |
Query.loadOne(Query.Controller controller)
Attempts to load exactly one matching object.
|
S |
Cursor.next()
Returns the next element from this cursor.
|
Query<S> |
Query.not()
Returns a new query which produces all the results not supplied in this
query.
|
Query<S> |
Query.or(Filter<S> filter)
Returns a new query which has another
filter logically "or"ed to this, potentially increasing the amount of
results. |
Query<S> |
Query.or(java.lang.String filter)
Returns a new query which has another
filter logically "or"ed to this, potentially increasing the amount of
results. |
Query<S> |
Query.orderBy(java.lang.String... properties)
Returns a copy of this query ordered by specific property values.
|
Query<S> |
Query.orderBy(java.lang.String property)
Returns a copy of this query ordered by a specific property value.
|
Query<S> |
Storage.query()
Query for all Storable instances in this Storage.
|
Query<S> |
Storage.query(Filter<S> filter)
Query for Storable instances against an explicitly constructed filter
object.
|
Query<S> |
Storage.query(java.lang.String filter)
Query for Storable instances against a filter expression.
|
int |
Cursor.skipNext(int amount)
Skips forward by the specified amount of elements, returning the actual
amount skipped.
|
java.util.List<S> |
Cursor.toList()
Copies all remaining next elements into a new modifiable list.
|
java.util.List<S> |
Cursor.toList(int limit)
Copies a limited amount of remaining next elements into a new modifiable
list.
|
boolean |
Storable.tryLoad()
Loads or reloads this object from the storage layer by a primary or
alternate key.
|
S |
Query.tryLoadOne()
Tries to load one record, but returns null if nothing was found.
|
S |
Query.tryLoadOne(Query.Controller controller)
Tries to load one record, but returns null if nothing was found.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
TextAdapter.Adapter.adaptToString(Blob blob) |
java.lang.String |
TextAdapter.Adapter.adaptToString(Clob clob) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
GroupedCursor.addToGroup(S groupMember)
This method is called when more entries are found for the current
group.
|
protected abstract void |
GroupedCursor.beginGroup(S groupLeader)
This method is called for the first entry in a group.
|
void |
MultiTransformedCursor.close() |
void |
LimitCursor.close() |
void |
ThrottledCursor.close() |
void |
FilteredCursor.close() |
void |
IntersectionCursor.close() |
void |
DifferenceCursor.close() |
void |
ControllerCursor.close() |
void |
FetchAheadCursor.close() |
void |
SortedCursor.close() |
void |
SkipCursor.close() |
void |
UnionCursor.close() |
void |
SortBuffer.close()
Clear and close buffer.
|
void |
GroupedCursor.close() |
void |
TransformedCursor.close() |
void |
SymmetricDifferenceCursor.close() |
int |
SymmetricDifferenceCursor.compareNext()
Returns 0 if no next element available, <0 if next element is
from left source cursor, and >0 if next element is from right
source cursor.
|
int |
AbstractCursor.copyInto(java.util.Collection<? super S> c) |
int |
AbstractCursor.copyInto(java.util.Collection<? super S> c,
int limit) |
protected abstract G |
GroupedCursor.finishGroup()
This method is called when a group is finished, and it can return an
aggregate.
|
boolean |
MultiTransformedCursor.hasNext() |
boolean |
LimitCursor.hasNext() |
boolean |
ThrottledCursor.hasNext() |
boolean |
FilteredCursor.hasNext() |
boolean |
IntersectionCursor.hasNext() |
boolean |
DifferenceCursor.hasNext() |
boolean |
ControllerCursor.hasNext() |
boolean |
FetchAheadCursor.hasNext() |
boolean |
SortedCursor.hasNext() |
boolean |
SkipCursor.hasNext() |
boolean |
UnionCursor.hasNext() |
boolean |
GroupedCursor.hasNext() |
boolean |
TransformedCursor.hasNext() |
boolean |
SymmetricDifferenceCursor.hasNext() |
protected abstract boolean |
FilteredCursor.isAllowed(S storable) |
T |
MultiTransformedCursor.next() |
S |
LimitCursor.next() |
S |
ThrottledCursor.next() |
S |
FilteredCursor.next() |
S |
IntersectionCursor.next() |
S |
DifferenceCursor.next() |
S |
ControllerCursor.next() |
S |
FetchAheadCursor.next() |
S |
SortedCursor.next() |
S |
SkipCursor.next() |
S |
UnionCursor.next() |
G |
GroupedCursor.next() |
T |
TransformedCursor.next() |
S |
SymmetricDifferenceCursor.next() |
int |
MultiTransformedCursor.skipNext(int amount) |
int |
LimitCursor.skipNext(int amount) |
int |
ThrottledCursor.skipNext(int amount) |
int |
FilteredCursor.skipNext(int amount) |
int |
AbstractCursor.skipNext(int amount) |
int |
SortedCursor.skipNext(int amount) |
int |
SkipCursor.skipNext(int amount) |
int |
GroupedCursor.skipNext(int amount) |
int |
TransformedCursor.skipNext(int amount) |
void |
SortBuffer.sort()
Finish sorting buffer.
|
java.util.List<S> |
AbstractCursor.toList() |
java.util.List<S> |
AbstractCursor.toList(int limit) |
protected abstract Cursor<T> |
MultiTransformedCursor.transform(S storable)
This method must be implemented to transform storables.
|
protected abstract T |
TransformedCursor.transform(S storable)
This method must be implemented to transform storables.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DelegateSupport.doTryLoad(S storable) |
Modifier and Type | Method and Description |
---|---|
boolean |
Layout.equalLayouts(Layout layout)
Returns true if the given layout matches this one.
|
java.util.List<LayoutProperty> |
Layout.getAllProperties()
Returns all the properties of this layout, in their proper order.
|
java.util.List<LayoutProperty> |
Layout.getDataProperties()
Returns all the non-primary key properties of this layout, in their
proper order.
|
Layout |
Layout.getGeneration(int generation)
Returns the layout for a particular generation of this layout's type.
|
Layout |
LayoutFactory.layoutFor(boolean readOnly,
java.lang.Class<? extends Storable> type,
LayoutOptions options)
Returns the layout matching the current definition of the given type.
|
Layout |
LayoutCapability.layoutFor(java.lang.Class<? extends Storable> type)
Returns the layout matching the current definition of the given type.
|
Layout |
LayoutFactory.layoutFor(java.lang.Class<? extends Storable> type)
Returns the layout matching the current definition of the given type.
|
Layout |
LayoutCapability.layoutFor(java.lang.Class<? extends Storable> type,
int generation)
Returns the layout for a particular generation of the given type.
|
Layout |
LayoutFactory.layoutFor(java.lang.Class<? extends Storable> type,
int generation)
Returns the layout for a particular generation of the given type.
|
Layout |
LayoutFactory.layoutFor(java.lang.Class<? extends Storable> type,
LayoutOptions options)
Returns the layout matching the current definition of the given type.
|
Layout |
Layout.nextGeneration()
Returns the next known generation of the storable's layout, or null
if none.
|
Layout |
Layout.previousGeneration()
Returns the previous known generation of the storable's layout, or null
if none.
|
java.lang.Class<? extends Storable> |
Layout.reconstruct()
Reconstructs the storable type defined by this layout by returning an
auto-generated class.
|
java.lang.Class<? extends Storable> |
Layout.reconstruct(java.lang.ClassLoader loader)
Reconstructs the storable type defined by this layout by returning an
auto-generated class.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
Clob.asString()
Convenience method to capture all the Clob data as a single String.
|
java.lang.String |
AbstractBlob.asString() |
java.lang.String |
AbstractClob.asString() |
java.lang.String |
Blob.asString()
Convenience method to capture all the Blob data as a single String,
assuming UTF-8 encoding.
|
java.lang.String |
AbstractBlob.asString(java.nio.charset.Charset charset) |
java.lang.String |
Blob.asString(java.nio.charset.Charset charset)
Convenience method to capture all the Blob data as a single String,
decoded against the given charset.
|
java.lang.String |
AbstractBlob.asString(java.lang.String charsetName) |
java.lang.String |
Blob.asString(java.lang.String charsetName)
Convenience method to capture all the Blob data as a single String,
decoded against the given charset.
|
long |
Clob.getLength()
Returns the length of this Clob, in characters.
|
long |
StringClob.getLength() |
long |
BlobClob.getLength() |
long |
Blob.getLength()
Returns the length of this Blob, in bytes.
|
long |
FileBlob.getLength() |
java.io.InputStream |
Blob.openInputStream()
Returns an InputStream for reading Blob data positioned at the
start.
|
java.io.InputStream |
FileBlob.openInputStream() |
java.io.InputStream |
Blob.openInputStream(long pos)
Returns an InputStream for reading Blob data.
|
java.io.InputStream |
FileBlob.openInputStream(long pos) |
java.io.InputStream |
Blob.openInputStream(long pos,
int bufferSize)
Returns an InputStream for reading Blob data.
|
java.io.InputStream |
FileBlob.openInputStream(long pos,
int bufferSize) |
java.io.Reader |
Clob.openReader()
Returns a Reader for reading Clob data, positioned at the start.
|
java.io.Reader |
BlobClob.openReader() |
java.io.Reader |
Clob.openReader(long pos)
Returns a Reader for reading Clob data.
|
java.io.Reader |
StringClob.openReader(long pos) |
java.io.Reader |
BlobClob.openReader(long pos) |
java.io.Reader |
Clob.openReader(long pos,
int bufferSize)
Returns a Reader for reading Clob data.
|
java.io.Reader |
StringClob.openReader(long pos,
int bufferSize) |
java.io.Reader |
BlobClob.openReader(long pos,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
<T extends S> |
StandardQuery.after(T start) |
Query<S> |
StandardQuery.and(Filter<S> filter) |
Query<S> |
AbstractQuery.and(java.lang.String filter) |
long |
StandardQuery.count() |
long |
QueryExecutor.count(FilterValues<S> values)
Counts the query results using the given filter values.
|
long |
SortedQueryExecutor.count(FilterValues<S> values) |
long |
FullScanQueryExecutor.count(FilterValues<S> values) |
long |
AbstractQueryExecutor.count(FilterValues<S> values)
Counts results by opening a cursor and skipping entries.
|
long |
DelegatedQueryExecutor.count(FilterValues<S> values) |
long |
QueryExecutor.count(FilterValues<S> values,
Query.Controller controller)
Counts the query results using the given filter values.
|
long |
SortedQueryExecutor.count(FilterValues<S> values,
Query.Controller controller) |
long |
FullScanQueryExecutor.count(FilterValues<S> values,
Query.Controller controller) |
long |
AbstractQueryExecutor.count(FilterValues<S> values,
Query.Controller controller)
Counts results by opening a cursor and skipping entries.
|
long |
DelegatedQueryExecutor.count(FilterValues<S> values,
Query.Controller controller) |
long |
StandardQuery.count(Query.Controller controller) |
long |
FullScanQueryExecutor.Support.countAll()
Counts all Storables.
|
long |
FullScanQueryExecutor.Support.countAll(Query.Controller controller)
Counts all Storables.
|
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 abstract StandardQuery<S> |
StandardQueryFactory.createQuery(Filter<S> filter,
FilterValues<S> values,
OrderingList<S> ordering,
QueryHints hints)
Implement this method to return query implementations.
|
QueryExecutor<S> |
DelegatedQueryExecutorFactory.executor(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints) |
boolean |
StandardQuery.exists() |
boolean |
StandardQuery.exists(Query.Controller controller) |
Cursor<S> |
StandardQuery.fetch() |
Cursor<S> |
QueryExecutor.fetch(FilterValues<S> values)
Returns a new cursor using the given filter values.
|
Cursor<S> |
SortedQueryExecutor.fetch(FilterValues<S> values) |
Cursor<S> |
FullScanQueryExecutor.fetch(FilterValues<S> values) |
Cursor<S> |
DelegatedQueryExecutor.fetch(FilterValues<S> values) |
Cursor<S> |
KeyQueryExecutor.fetch(FilterValues<S> values) |
Cursor<S> |
IndexedQueryExecutor.fetch(FilterValues<S> values) |
Cursor<S> |
FilteredQueryExecutor.fetch(FilterValues<S> values) |
Cursor<S> |
UnionQueryExecutor.fetch(FilterValues<S> values) |
Cursor<S> |
QueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller)
Returns a new cursor using the given filter values.
|
Cursor<S> |
SortedQueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller) |
Cursor<S> |
FullScanQueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller) |
Cursor<S> |
DelegatedQueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller) |
Cursor<S> |
KeyQueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller) |
Cursor<S> |
IndexedQueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller) |
Cursor<S> |
FilteredQueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller) |
Cursor<S> |
UnionQueryExecutor.fetch(FilterValues<S> values,
Query.Controller controller) |
Cursor<T> |
JoinedQueryExecutor.fetch(FilterValues<T> values) |
Cursor<T> |
JoinedQueryExecutor.fetch(FilterValues<T> values,
Query.Controller controller) |
Cursor<S> |
StandardQuery.fetch(Query.Controller controller) |
<T extends S> |
AbstractQuery.fetchAfter(T start) |
<T extends S> |
AbstractQuery.fetchAfter(T start,
Query.Controller controller) |
Cursor<S> |
FullScanQueryExecutor.Support.fetchAll()
Perform a full scan of all Storables.
|
Cursor<S> |
FullScanQueryExecutor.Support.fetchAll(Query.Controller controller)
Perform a full scan of all Storables.
|
Cursor<S> |
IndexedQueryExecutor.Support.fetchFromIndexEntryQuery(StorableIndex<S> index,
Query<?> indexEntryQuery)
Fetch Storables referenced by the given index entry query.
|
Cursor<S> |
IndexedQueryExecutor.Support.fetchFromIndexEntryQuery(StorableIndex<S> index,
Query<?> indexEntryQuery,
Query.Controller controller)
Fetch Storables referenced by the given index entry query.
|
Cursor<S> |
KeyQueryExecutor.Support.fetchOne(StorableIndex<S> index,
java.lang.Object[] identityValues)
Select at most one Storable referenced by an index.
|
Cursor<S> |
KeyQueryExecutor.Support.fetchOne(StorableIndex<S> index,
java.lang.Object[] identityValues,
Query.Controller controller)
Select at most one Storable referenced by an index.
|
Cursor<S> |
QueryExecutor.fetchSlice(FilterValues<S> values,
long from,
java.lang.Long to)
Returns a new cursor using the given filter values and slice.
|
Cursor<S> |
AbstractQueryExecutor.fetchSlice(FilterValues<S> values,
long from,
java.lang.Long to)
Produces a slice via skip and limit cursors.
|
Cursor<S> |
DelegatedQueryExecutor.fetchSlice(FilterValues<S> values,
long from,
java.lang.Long to) |
Cursor<S> |
QueryExecutor.fetchSlice(FilterValues<S> values,
long from,
java.lang.Long to,
Query.Controller controller)
Returns a new cursor using the given filter values and slice.
|
Cursor<S> |
AbstractQueryExecutor.fetchSlice(FilterValues<S> values,
long from,
java.lang.Long to,
Query.Controller controller)
Produces a slice via skip and limit cursors.
|
Cursor<S> |
DelegatedQueryExecutor.fetchSlice(FilterValues<S> values,
long from,
java.lang.Long to,
Query.Controller controller) |
Cursor<S> |
StandardQuery.fetchSlice(long from,
java.lang.Long to) |
Cursor<S> |
StandardQuery.fetchSlice(long from,
java.lang.Long to,
Query.Controller controller) |
Cursor<S> |
IndexedQueryExecutor.Support.fetchSubset(StorableIndex<S> index,
java.lang.Object[] identityValues,
BoundaryType rangeStartBoundary,
java.lang.Object rangeStartValue,
BoundaryType rangeEndBoundary,
java.lang.Object rangeEndValue,
boolean reverseRange,
boolean reverseOrder)
Perform an index scan of a subset of Storables referenced by an
index.
|
Cursor<S> |
IndexedQueryExecutor.Support.fetchSubset(StorableIndex<S> index,
java.lang.Object[] identityValues,
BoundaryType rangeStartBoundary,
java.lang.Object rangeStartValue,
BoundaryType rangeEndBoundary,
java.lang.Object rangeEndValue,
boolean reverseRange,
boolean reverseOrder,
Query.Controller controller)
Perform an index scan of a subset of Storables referenced by an
index.
|
Query<?> |
IndexedQueryExecutor.Support.indexEntryQuery(StorableIndex<S> index)
Returns an open query if the given index supports query access.
|
S |
AbstractQuery.loadOne() |
S |
AbstractQuery.loadOne(Query.Controller controller) |
Query<S> |
StandardQuery.not() |
Query<S> |
EmptyQuery.not()
Returns a query that fetches everything, possibly in a specified order.
|
Query<S> |
StandardQuery.or(Filter<S> filter) |
Query<S> |
EmptyQuery.or(Filter<S> filter) |
Query<S> |
AbstractQuery.or(java.lang.String filter) |
Query<S> |
StandardQuery.orderBy(java.lang.String... properties) |
Query<S> |
EmptyQuery.orderBy(java.lang.String... properties) |
Query<S> |
StandardQuery.orderBy(java.lang.String property) |
Query<S> |
EmptyQuery.orderBy(java.lang.String property) |
Query<S> |
StandardQueryFactory.query()
Returns a new or cached query that fetches everything.
|
Query<S> |
StandardQueryFactory.query(Filter<S> filter)
Returns a new or cached query for the given filter.
|
Query<S> |
StandardQueryFactory.query(Filter<S> filter,
FilterValues<S> values,
OrderingList<S> ordering)
Returns a new or cached query for the given query specification.
|
Query<S> |
QueryFactory.query(Filter<S> filter,
FilterValues<S> values,
OrderingList<S> ordering,
QueryHints hints)
Returns a query that handles the given query specification.
|
Query<S> |
StandardQueryFactory.query(Filter<S> filter,
FilterValues<S> values,
OrderingList<S> ordering,
QueryHints hints)
Returns a new or cached query for the given query specification.
|
Query<S> |
StandardQueryFactory.query(Filter<S> filter,
OrderingList<S> ordering)
Returns a new or cached query for the given query specification.
|
Query<S> |
StandardQueryFactory.query(Filter<S> filter,
OrderingList<S> ordering,
QueryHints hints)
Returns a new or cached query for the given query specification.
|
Query<S> |
StandardQueryFactory.query(java.lang.String filter)
Returns a new or cached query for the given filter.
|
S |
AbstractQuery.tryLoadOne() |
S |
AbstractQuery.tryLoadOne(Query.Controller controller) |
Constructor and Description |
---|
DelegatedQueryExecutor(Storage<S> rootStorage,
Filter<S> filter,
OrderingList<S> ordering) |
DelegatedQueryExecutor(Storage<S> rootStorage,
QueryExecutor<S> executor) |
IndexedQueryExecutor(IndexedQueryExecutor.Support<S> support,
StorableIndex<S> index,
CompositeScore<S> score) |
Modifier and Type | Method and Description |
---|---|
void |
RawCursor.close() |
protected void |
RawCursor.enableKeyAndValue()
Enable key and value acquisition again, after they have been
disabled.
|
Blob |
RawSupport.getBlob(S storable,
java.lang.String name,
long locator)
Returns the Blob for the given locator, returning null if not found.
|
Clob |
RawSupport.getClob(S storable,
java.lang.String name,
long locator)
Returns the Clob for the given locator, returning null if not found.
|
protected abstract byte[] |
RawCursor.getCurrentKey()
Returns the contents of the current key being referenced, or null
otherwise.
|
protected abstract byte[] |
RawCursor.getCurrentValue()
Returns the contents of the current value being referenced, or null
otherwise.
|
GenericStorableCodec.Decoder<S> |
GenericStorableCodec.getDecoder(int generation)
Deprecated.
use direct decode method
|
protected void |
RawCursor.handleNoSuchElement()
Called right before throwing NoSuchElementException.
|
boolean |
RawCursor.hasNext() |
S |
StorableCodec.instantiate(byte[] key)
Instantiate a Storable with no value defined yet.
|
S |
GenericStorableCodec.instantiate(byte[] key)
Instantiate a Storable with no value defined yet.
|
S |
StorableCodec.instantiate(byte[] key,
byte[] value)
Instantiate a Storable with a specific key and value.
|
S |
CustomStorableCodec.instantiate(byte[] key,
byte[] value) |
S |
GenericStorableCodec.instantiate(byte[] key,
byte[] value)
Instantiate a Storable with a specific key and value.
|
S |
StorableCodec.instantiate(RawSupport<S> support,
byte[] key,
byte[] value)
Instantiate a Storable with a specific key and value.
|
S |
CustomStorableCodec.instantiate(RawSupport<S> support,
byte[] key,
byte[] value) |
S |
GenericStorableCodec.instantiate(RawSupport<S> support,
byte[] key,
byte[] value)
Instantiate a Storable with a specific key and value.
|
Storable |
GenericInstanceFactory.instantiate(RawSupport support,
byte[] key) |
Storable |
GenericInstanceFactory.instantiate(RawSupport support,
byte[] key,
byte[] value) |
Storable |
CustomStorableCodec.InstanceFactory.instantiate(RawSupport support,
byte[] key,
byte[] value,
CustomStorableCodec codec) |
protected abstract S |
RawCursor.instantiateCurrent()
Returns a new Storable instance for the currently referenced entry.
|
S |
RawCursor.next() |
protected abstract void |
RawCursor.release()
Release any internal resources, called when closed.
|
int |
RawCursor.skipNext(int amount) |
protected abstract boolean |
RawCursor.toFirst()
Move the cursor to the first available entry.
|
protected abstract boolean |
RawCursor.toFirst(byte[] key)
Move the cursor to the first available entry at or after the given
key.
|
protected abstract boolean |
RawCursor.toLast()
Move the cursor to the last available entry.
|
protected abstract boolean |
RawCursor.toLast(byte[] key)
Move the cursor to the last available entry at or before the given
key.
|
protected abstract boolean |
RawCursor.toNext()
Move the cursor to the next available entry, returning false if none.
|
protected int |
RawCursor.toNext(int amount)
Move the cursor to the next available entry, incrementing by the amount
given.
|
protected boolean |
RawCursor.toNextKey()
Move the cursor to the next unique key, returning false if none.
|
protected abstract boolean |
RawCursor.toPrevious()
Move the cursor to the previous available entry, returning false if
none.
|
protected int |
RawCursor.toPrevious(int amount)
Move the cursor to the previous available entry, decrementing by the
amount given.
|
protected boolean |
RawCursor.toPreviousKey()
Move the cursor to the previous unique key, returning false if none.
|
byte[] |
RawSupport.tryLoad(S storable,
byte[] key)
Try to load the entry referenced by the given key, but return null
if not found.
|
Modifier and Type | Method and Description |
---|---|
void |
IndexEntryAccessor.copyFromMaster(Storable indexEntry,
S master)
Sets all the properties of the given index entry, using the applicable
properties of the given master.
|
void |
IndexEntryAccessor.copyToMasterPrimaryKey(Storable indexEntry,
S master)
Sets all the primary key properties of the given master, using the
applicable properties of the given index entry.
|
boolean |
IndexEntryAccessor.isConsistent(Storable indexEntry,
S master)
Returns true if the properties of the given index entry match those
contained in the master, exluding any version property.
|
Modifier and Type | Method and Description |
---|---|
FetchException |
JDBCConnectionCapability.toFetchException(java.lang.Throwable e)
Transforms the given throwable into an appropriate fetch exception.
|
Modifier and Type | Method and Description |
---|---|
Blob |
JDBCSupport.convertBlob(java.sql.Blob blob,
JDBCBlobLoader loader) |
Clob |
JDBCSupport.convertClob(java.sql.Clob clob,
JDBCClobLoader loader) |
java.sql.Connection |
JDBCConnectionCapability.getConnection()
Any connection returned by this method must be closed by calling
yieldConnection.
|
java.sql.Blob |
JDBCBlobLoader.load(JDBCConnectionCapability cap) |
java.sql.Clob |
JDBCClobLoader.load(JDBCConnectionCapability cap) |
void |
JDBCConnectionCapability.yieldConnection(java.sql.Connection con)
Gives up a connection returned from getConnection.
|
Modifier and Type | Method and Description |
---|---|
void |
SequenceValueGenerator.reset(int initialValue)
Reset the sequence.
|
boolean |
SequenceValueProducer.returnReservedValues()
Allow any unused reserved values to be returned for re-use.
|
boolean |
SequenceValueGenerator.returnReservedValues()
Allow any unused reserved values to be returned for re-use.
|
Modifier and Type | Method and Description |
---|---|
FetchException |
ExceptionTransformer.toFetchException(java.lang.Throwable e)
Transforms the given throwable into an appropriate fetch exception.
|
protected FetchException |
ExceptionTransformer.transformIntoFetchException(java.lang.Throwable e)
Override to support custom transformations, returning null if none is
applicable.
|
Modifier and Type | Method and Description |
---|---|
void |
TriggerManager.afterLoad(S storable) |
Modifier and Type | Method and Description |
---|---|
void |
SyntheticStorableReferenceAccess.copyFromMaster(Storable reference,
S master)
Sets all the properties of the given reference, using the applicable
properties of the given master.
|
void |
SyntheticStorableReferenceBuilder.copyFromMaster(Storable indexEntry,
S master)
Deprecated.
call getReferenceAccess
|
void |
SyntheticStorableReferenceAccess.copyToMasterPrimaryKey(Storable reference,
S master)
Sets all the primary key properties of the given master, using the
applicable properties of the given reference.
|
void |
SyntheticStorableReferenceBuilder.copyToMasterPrimaryKey(Storable indexEntry,
S master)
Deprecated.
call getReferenceAccess
|
boolean |
SyntheticStorableReferenceAccess.isConsistent(Storable reference,
S master)
Returns true if the properties of the given reference match those
contained in the master, excluding any version property.
|
boolean |
SyntheticStorableReferenceBuilder.isConsistent(Storable indexEntry,
S master)
Deprecated.
call getReferenceAccess
|
Copyright © 2006-2013 Amazon Technologies, Inc.. All Rights Reserved.