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 © 2016 Actian Corporation. All Rights Reserved.