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.cursor |
Support for advanced processing of cursor results, including basic set
theory operations.
|
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.txn |
Provides support for managing transactions.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
Cursor<R> |
RemoteProcedure.Call.fetchReply()
Executes the call and receive a reply.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCursor<S>
AbstractCursor implements a small set of common Cursor methods.
|
class |
ControllerCursor<S>
Wraps another cursor and periodically calls a
controller . |
class |
DifferenceCursor<S>
Wraps two Cursors and performs an asymmetric set difference
operation.
|
class |
EmptyCursor<S>
Special cursor implementation that is empty.
|
class |
FetchAheadCursor<S>
Cursor implementation which fetches records in advance, in order to release locks.
|
class |
FilteredCursor<S>
Wraps another cursor and applies custom filtering to reduce the set of
results.
|
class |
GroupedCursor<S,G>
Abstract cursor for aggregation and finding distinct data.
|
class |
IntersectionCursor<S>
Wraps two Cursors and performs a set intersection operation.
|
class |
IteratorCursor<S>
Adapts an Iterator into a Cursor.
|
class |
LimitCursor<S>
Wraps another cursor to limit the amount of elements.
|
class |
MultiTransformedCursor<S,T>
Abstract cursor which wraps another cursor and transforms each storable
result into a set of target storables.
|
class |
SingletonCursor<S>
Special cursor implementation that returns only one element.
|
class |
SkipCursor<S>
Wraps another cursor to skip an initial amount of elements.
|
class |
SortedCursor<S>
Wraps another Cursor and ensures the results are sorted.
|
class |
SymmetricDifferenceCursor<S>
Wraps two Cursors and performs a symmetric set difference
operation.
|
class |
ThrottledCursor<S>
Wraps another cursor and fetches results at a reduced speed.
|
class |
TransformedCursor<S,T>
Abstract cursor which wraps another cursor and transforms each storable
result into a target storable.
|
class |
UnionCursor<S>
Wraps two Cursors and performs a set union operation.
|
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.
|
static <S extends Storable> |
FilteredCursor.applyFilter(Cursor<S> cursor,
java.lang.Class<S> type,
java.lang.String filter,
java.lang.Object... filterValues)
Returns a Cursor that is filtered by the given filter expression and values.
|
static <S extends Storable> |
FilteredCursor.applyFilter(Filter<S> filter,
FilterValues<S> filterValues,
Cursor<S> cursor)
Returns a Cursor that is filtered by the given Filter and FilterValues.
|
static <S> Cursor<S> |
EmptyCursor.the()
Returns the empty cursor instance.
|
protected abstract Cursor<T> |
MultiTransformedCursor.transform(S storable)
This method must be implemented to transform storables.
|
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.
|
static <S extends Storable> |
FilteredCursor.applyFilter(Cursor<S> cursor,
java.lang.Class<S> type,
java.lang.String filter,
java.lang.Object... filterValues)
Returns a Cursor that is filtered by the given filter expression and values.
|
static <S extends Storable> |
FilteredCursor.applyFilter(Filter<S> filter,
FilterValues<S> filterValues,
Cursor<S> cursor)
Returns a Cursor that is filtered by the given Filter and FilterValues.
|
Constructor and Description |
---|
DifferenceCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
DifferenceCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
FetchAheadCursor(Cursor<S> source,
int fetchAhead) |
FilteredCursor(Cursor<S> cursor) |
GroupedCursor(Cursor<S> cursor,
java.lang.Class<S> type,
java.lang.String... groupProperties)
Create a GroupedCursor using properties to define the group
comparator.
|
GroupedCursor(Cursor<S> cursor,
java.util.Comparator<S> groupComparator)
Create a GroupedCursor with an existing group comparator.
|
IntersectionCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
IntersectionCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
LimitCursor(Cursor<S> source,
long limit) |
MultiTransformedCursor(Cursor<S> cursor) |
SkipCursor(Cursor<S> source,
long skip) |
SortedCursor(Cursor<S> cursor,
SortBuffer<S> buffer,
java.lang.Class<S> type,
java.lang.String... orderProperties) |
SortedCursor(Cursor<S> cursor,
SortBuffer<S> buffer,
java.util.Comparator<S> handled,
java.util.Comparator<S> finisher) |
SymmetricDifferenceCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
SymmetricDifferenceCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
ThrottledCursor(Cursor<S> cursor,
double throttle) |
TransformedCursor(Cursor<S> cursor) |
UnionCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
UnionCursor(Cursor<S> left,
Cursor<S> right,
java.util.Comparator<S> order) |
Modifier and Type | Method and Description |
---|---|
Cursor<S> |
StandardQuery.fetch() |
Cursor<S> |
EmptyQuery.fetch()
Always returns an
EmptyCursor . |
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> |
IterableQueryExecutor.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> |
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) |
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) |
<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> |
EmptyQuery.fetchSlice(long from,
java.lang.Long to)
Always returns an
EmptyCursor . |
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)
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.
|
Modifier and Type | Class and Description |
---|---|
class |
RawCursor<S>
Abstract Cursor implementation for a repository that manipulates raw bytes.
|
Modifier and Type | Method and Description |
---|---|
<S extends Storable> |
TransactionScope.register(java.lang.Class<S> type,
Cursor<S> cursor)
Registers the given cursor against the active transaction, allowing it
to be closed on transaction exit or transaction manager close.
|
<S extends Storable> |
TransactionScope.unregister(java.lang.Class<S> type,
Cursor<S> cursor)
Unregisters a previously registered cursor.
|
Copyright © 2006-2013 Amazon Technologies, Inc.. All Rights Reserved.