| Package | Description |
|---|---|
| com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
| com.pervasive.datarush.cal.dr | |
| com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
| Modifier and Type | Method and Description |
|---|---|
DistributedCallableContextBatch |
PseudoDistributedExecutorService.getContexts()
Returns the contexts corresponding to all distributed contexts.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract T |
DistributedCommandBatch.execute(DistributedCallableContextBatch ctx)
Subclasses must override to provide an execution implementation
|
MonitoredCallable<T> |
DistributedCommandBatch.init(DistributedCallableContextBatch ctx)
Implementation of init that returns a callable whose
call
method invokes DistributedCommandBatch.execute(DistributedCallableContextBatch). |
MonitoredCallable<R> |
DistributedCallableBatch.init(DistributedCallableContextBatch ctx)
Invoked once per
physicalNodeID. |
| Modifier and Type | Method and Description |
|---|---|
DistributedCallableContextBatch |
PseudoDistributedClusterExecutor.getContexts() |
| Modifier and Type | Method and Description |
|---|---|
DistributedCallableContextBatch |
DistributedWorkerServiceImpl.getBatchContext(List<NodeAllocationState.AssignmentState> assignments) |
Copyright © 2015 Actian Corporation. All Rights Reserved.