| Package | Description |
|---|---|
| com.googlecode.n_orm | |
| com.googlecode.n_orm.operations | |
| com.googlecode.n_orm.query | |
| com.googlecode.n_orm.storeapi |
| Modifier and Type | Method and Description |
|---|---|
Process<? extends PersistingElement> |
ProcessException.getProcess()
The process in which the problem(s) appeared.
|
| Modifier and Type | Method and Description |
|---|---|
String |
TimeoutCanceller.getErrorMessage(Process<?> processAction) |
String |
ProcessCanceller.getErrorMessage(Process<?> processAction) |
| Constructor and Description |
|---|
ProcessException(Process<? extends PersistingElement> p,
Process.ProcessReport<? extends PersistingElement> report,
List<ProcessException.Problem> problems,
List<Throwable> otherExceptions) |
| Modifier and Type | Method and Description |
|---|---|
static <AE extends PersistingElement,E extends AE> |
Process.processElements(Class<E> clazz,
Constraint c,
Process<AE> processAction,
int limit,
String[] families,
int threadNumber,
ProcessCanceller cancel,
ExecutorService executor) |
static <AE extends PersistingElement,E extends AE> |
Process.processElementsRemotely(Class<E> clazz,
Constraint c,
Process<AE> process,
Callback callback,
int limit,
String[] families,
int threadNumber,
long timeout) |
static <T extends PersistingElement> |
ImportExport.readSerializedPersistingElements(InputStream fis,
Process<T> process)
Processes sequentially each element of a serialized stream without importing them.
|
static long |
ImportExport.readSerializedPersistingElements(String file,
Process<? extends PersistingElement> process)
Processes sequentially each element of a serialized file without importing them.
|
| Modifier and Type | Method and Description |
|---|---|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action)
Performs an action for each element corresponding to the query.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
long timeoutMs)
Performs an action for each element corresponding to the query using parallel threads.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
long timeoutMs,
ExecutorService executor)
Performs an action for each element corresponding to the query using parallel threads ; method might return before process is ended.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
ProcessCanceller canceller)
Performs an action for each element corresponding to the query using parallel threads.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
ProcessCanceller canceller,
ExecutorService executor)
Performs an action for each element corresponding to the query using parallel threads ; method might return before process is ended.
|
void |
SearchableClassConstraintBuilder.remoteForEach(Process<T> action,
Callback callBack,
int threadNumber,
long timeout)
Performs asynchronously an action for each element corresponding to the query.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ProcessWrapper<AE extends PersistingElement,E extends AE> |
| Modifier and Type | Method and Description |
|---|---|
Process<AE> |
ProcessWrapper.getActualProcess() |
| Modifier and Type | Method and Description |
|---|---|
<AE extends PersistingElement,E extends AE> |
ActionnableStore.process(MetaInformation meta,
String table,
Constraint c,
Set<String> families,
Class<E> element,
Process<AE> action,
Callback callback) |
| Constructor and Description |
|---|
ProcessWrapper(Process<AE> process,
Class<E> clazz,
Set<String> toBeActivated) |
Copyright © 2016. All Rights Reserved.