Package | Description |
---|---|
com.amazon.carbonado |
Main user-level interfaces, classes, and annotations for Carbonado.
|
com.amazon.carbonado.cursor |
Support for advanced processing of cursor results, including basic set
theory operations.
|
com.amazon.carbonado.qe |
Support for implementing a Query Engine.
|
Modifier and Type | Class and Description |
---|---|
static class |
Query.Timeout
Timeout controller, for aborting long running queries.
|
Modifier and Type | Method and Description |
---|---|
long |
Query.count(Query.Controller controller)
Returns a count of all results matched by this query.
|
void |
Query.deleteAll(Query.Controller controller)
Deletes zero or more matching objects.
|
void |
Query.deleteOne(Query.Controller controller)
Deletes one matching object.
|
boolean |
Query.exists(Query.Controller controller)
Returns true if any results are matched by this query.
|
Cursor<S> |
Query.fetch(Query.Controller controller)
Fetches results for this query.
|
<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,
Query.Controller controller)
Fetches a slice of results for this query, as defined by a numerical
range.
|
S |
Query.loadOne(Query.Controller controller)
Attempts to load exactly one matching object.
|
boolean |
Query.tryDeleteOne(Query.Controller controller)
Deletes zero or one matching objects.
|
S |
Query.tryLoadOne(Query.Controller controller)
Tries to load one record, but returns null if nothing was found.
|
Modifier and Type | Method and Description |
---|---|
static <S> Cursor<S> |
ControllerCursor.apply(Cursor<S> source,
Query.Controller controller)
Returns a ControllerCursor depending on whether a controller instance is
passed in or not.
|
Constructor and Description |
---|
MergeSortBuffer(Query.Controller controller) |
MergeSortBuffer(Storage<S> storage,
Query.Controller controller) |
MergeSortBuffer(Storage<S> storage,
java.lang.String tempDir,
int maxArrayCapacity,
Query.Controller controller) |
Modifier and Type | Method and Description |
---|---|
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 |
EmptyQuery.count(Query.Controller controller)
Always returns zero.
|
long |
FullScanQueryExecutor.Support.countAll(Query.Controller controller)
Counts all Storables.
|
SortBuffer<S> |
SortedQueryExecutor.Support.createSortBuffer(Query.Controller controller)
Implementation must return an empty buffer for sorting.
|
SortBuffer<S> |
SortedQueryExecutor.ArraySortSupport.createSortBuffer(Query.Controller controller)
Returns a new ArraySortBuffer.
|
SortBuffer<S> |
SortedQueryExecutor.MergeSortSupport.createSortBuffer(Query.Controller controller)
Returns a new MergeSortBuffer.
|
void |
StandardQuery.deleteAll(Query.Controller controller) |
void |
EmptyQuery.deleteAll(Query.Controller controller)
Does nothing.
|
void |
AbstractQuery.deleteOne(Query.Controller controller) |
void |
EmptyQuery.deleteOne(Query.Controller controller)
Always throws
PersistNoneException . |
boolean |
StandardQuery.exists(Query.Controller controller) |
boolean |
EmptyQuery.exists(Query.Controller controller)
Always returns false.
|
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> |
IterableQueryExecutor.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,
Query.Controller controller) |
Cursor<S> |
StandardQuery.fetch(Query.Controller controller) |
Cursor<S> |
EmptyQuery.fetch(Query.Controller controller)
Always returns an
EmptyCursor . |
<T extends S> |
AbstractQuery.fetchAfter(T start,
Query.Controller controller) |
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,
Query.Controller controller)
Fetch Storables referenced by the given index entry query.
|
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,
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,
Query.Controller controller) |
Cursor<S> |
EmptyQuery.fetchSlice(long from,
java.lang.Long to,
Query.Controller controller)
Always returns an
EmptyCursor . |
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.
|
S |
AbstractQuery.loadOne(Query.Controller controller) |
boolean |
StandardQuery.tryDeleteOne(Query.Controller controller) |
boolean |
EmptyQuery.tryDeleteOne(Query.Controller controller)
Always returns false.
|
S |
AbstractQuery.tryLoadOne(Query.Controller controller) |
Copyright © 2006-2013 Amazon Technologies, Inc.. All Rights Reserved.