com.amazon.carbonado.qe

Class DelegatedQueryExecutor<S extends Storable>

java.lang.Object

com.amazon.carbonado.qe.DelegatedQueryExecutor<S>

All Implemented Interfaces:

QueryExecutor<S>

public class DelegatedQueryExecutor<S extends Storable>
extends java.lang.Object
implements QueryExecutor<S>

QueryExecutor which delegates by executing a Query on a Storage.

Author:

Brian S O'Neill

Constructor Summary

Constructors

Constructor and Description
DelegatedQueryExecutor(Storage<S> rootStorage, Filter<S> filter, OrderingList<S> ordering)
DelegatedQueryExecutor(Storage<S> rootStorage, QueryExecutor<S> executor)

Method Summary

Methods

Modifier and Type	Method and Description
long	count(FilterValues<S> values) Counts the query results using the given filter values.
long	count(FilterValues<S> values, Query.Controller controller) Counts the query results using the given filter values.
Cursor<S>	fetch(FilterValues<S> values) Returns a new cursor using the given filter values.
Cursor<S>	fetch(FilterValues<S> values, Query.Controller controller) Returns a new cursor using the given filter values.
Cursor<S>	fetchSlice(FilterValues<S> values, long from, java.lang.Long to) Returns a new cursor using the given filter values and slice.
Cursor<S>	fetchSlice(FilterValues<S> values, long from, java.lang.Long to, Query.Controller controller) Returns a new cursor using the given filter values and slice.
Filter<S>	getFilter() Returns the filter used by this QueryExecutor.
OrderingList<S>	getOrdering() Returns the result ordering of this QueryExecutor.
java.lang.Class<S>	getStorableType() Returns the storable type that this executor operates on.
boolean	printNative(java.lang.Appendable app, int indentLevel, FilterValues<S> values) Prints the native query to any appendable, if applicable.
boolean	printPlan(java.lang.Appendable app, int indentLevel, FilterValues<S> values) Prints the query plan to any appendable, if applicable.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatedQueryExecutor

public DelegatedQueryExecutor(Storage<S> rootStorage,
                      QueryExecutor<S> executor)
                       throws FetchException

Parameters:

rootStorage - root storage to query

executor - executor to emulate

Throws:

java.lang.IllegalArgumentException - if any parameter is null

FetchException

DelegatedQueryExecutor

public DelegatedQueryExecutor(Storage<S> rootStorage,
                      Filter<S> filter,
                      OrderingList<S> ordering)
                       throws FetchException

Parameters:

rootStorage - root storage to query

filter - optional query filter

ordering - optional ordering

Throws:

java.lang.IllegalArgumentException - if rootStorage is null

FetchException

Method Detail

getStorableType

public java.lang.Class<S> getStorableType()

Description copied from interface: QueryExecutor

Returns the storable type that this executor operates on.

Specified by:

getStorableType in interface QueryExecutor<S extends Storable>

fetch

public Cursor<S> fetch(FilterValues<S> values)
                                 throws FetchException

Description copied from interface: QueryExecutor

Returns a new cursor using the given filter values.

Specified by:

fetch in interface QueryExecutor<S extends Storable>

Throws:

FetchException

fetch

public Cursor<S> fetch(FilterValues<S> values,
              Query.Controller controller)
                                 throws FetchException

Description copied from interface: QueryExecutor

Returns a new cursor using the given filter values.

Specified by:

fetch in interface QueryExecutor<S extends Storable>

controller - optional controller which can abort query operation

Throws:

FetchException

fetchSlice

public Cursor<S> fetchSlice(FilterValues<S> values,
                   long from,
                   java.lang.Long to)
                                      throws FetchException

Description copied from interface: QueryExecutor

Returns a new cursor using the given filter values and slice.

Specified by:

fetchSlice in interface QueryExecutor<S extends Storable>

Throws:

FetchException

fetchSlice

public Cursor<S> fetchSlice(FilterValues<S> values,
                   long from,
                   java.lang.Long to,
                   Query.Controller controller)
                                      throws FetchException

Description copied from interface: QueryExecutor

Returns a new cursor using the given filter values and slice.

Specified by:

fetchSlice in interface QueryExecutor<S extends Storable>

controller - optional controller which can abort query operation

Throws:

FetchException

count

public long count(FilterValues<S> values)
           throws FetchException

Description copied from interface: QueryExecutor

Counts the query results using the given filter values.

Specified by:

count in interface QueryExecutor<S extends Storable>

Throws:

FetchException

count

public long count(FilterValues<S> values,
         Query.Controller controller)
           throws FetchException

Description copied from interface: QueryExecutor

Counts the query results using the given filter values.

Specified by:

count in interface QueryExecutor<S extends Storable>

controller - optional controller which can abort query operation

Throws:

FetchException

getFilter

public Filter<S> getFilter()

Description copied from interface: QueryExecutor

Returns the filter used by this QueryExecutor.

Specified by:

getFilter in interface QueryExecutor<S extends Storable>

Returns:

query filter, never null

getOrdering

public OrderingList<S> getOrdering()

Description copied from interface: QueryExecutor

Returns the result ordering of this QueryExecutor.

Specified by:

getOrdering in interface QueryExecutor<S extends Storable>

Returns:

query ordering in an unmodifiable list

printNative

public boolean printNative(java.lang.Appendable app,
                  int indentLevel,
                  FilterValues<S> values)
                    throws java.io.IOException

Description copied from interface: QueryExecutor

Prints the native query to any appendable, if applicable.

Specified by:

printNative in interface QueryExecutor<S extends Storable>

values - optional

Returns:

false if not implemented

Throws:

java.io.IOException

printPlan

public boolean printPlan(java.lang.Appendable app,
                int indentLevel,
                FilterValues<S> values)
                  throws java.io.IOException

Description copied from interface: QueryExecutor

Prints the query plan to any appendable, if applicable.

Specified by:

printPlan in interface QueryExecutor<S extends Storable>

values - optional

Returns:

false if not implemented

Throws:

java.io.IOException