public static class DistributedSQLStoreQuery.ParallelExecutor extends SQLStoreQuery.SQLExecutor
Constructor and Description |
---|
DistributedSQLStoreQuery.ParallelExecutor(DistributedSQLStoreQuery dsq,
ClassMetaData meta,
boolean p) |
Modifier and Type | Method and Description |
---|---|
void |
addExecutor(StoreQuery.Executor ex) |
(package private) boolean |
containsReplicated(QueryContext query)
Scans metadata to find out if a replicated class is the candidate.
|
Number |
executeDelete(StoreQuery q,
Object[] params)
Deleted the objects that result from the execution of the
query, retuning the number of objects that were deleted.
|
ResultObjectProvider |
executeQuery(StoreQuery q,
Object[] params,
StoreQuery.Range range)
Each child query must be executed with slice context and not the
given query context.
|
Number |
executeUpdate(StoreQuery q,
Object[] params)
Updates the objects that result from the execution of the
query, retuning the number of objects that were updated.
|
(package private) List<SliceStoreManager> |
findTargets() |
executeQuery, executeUpdate, getDataStoreActions, getOperation, isPacking, prepareCall, prepareCall, prepareStatement, prepareStatement, toParameterArray
getAccessPathMetaDatas, getAlias, getAscending, getOrderedParameterTypes, getOrderingValue, getParameterTypes, getProjectionAliases, getProjectionTypes, getQueryExpressions, getRange, getResultClass, getResultShape, getUpdates, hasGrouping, isAggregate, isDistinct, validate
public DistributedSQLStoreQuery.ParallelExecutor(DistributedSQLStoreQuery dsq, ClassMetaData meta, boolean p)
public void addExecutor(StoreQuery.Executor ex)
public ResultObjectProvider executeQuery(StoreQuery q, Object[] params, StoreQuery.Range range)
executeQuery
in interface StoreQuery.Executor
executeQuery
in class SQLStoreQuery.SQLExecutor
StoreQuery.Executor.isPacking(org.apache.openjpa.kernel.StoreQuery)
boolean containsReplicated(QueryContext query)
public Number executeDelete(StoreQuery q, Object[] params)
StoreQuery.Executor
executeDelete
in interface StoreQuery.Executor
executeDelete
in class AbstractStoreQuery.AbstractExecutor
public Number executeUpdate(StoreQuery q, Object[] params)
StoreQuery.Executor
executeUpdate
in interface StoreQuery.Executor
executeUpdate
in class SQLStoreQuery.SQLExecutor
List<SliceStoreManager> findTargets()
Copyright © 2006–2013 Apache Software Foundation. All rights reserved.