Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
Modifier and Type | Method and Description |
---|---|
DistributedCallableContext |
DistributedCallableContextBatch.getContext(int partitionID)
Returns the context corresponding to the given partitionID
|
DistributedCallableContext |
DistributedExecutorService.getMasterContext()
Returns the job master context.
|
Modifier and Type | Method and Description |
---|---|
List<DistributedCallableContext> |
DistributedCallableContextBatch.getContexts()
Returns the contexts for this
physicalNode . |
Modifier and Type | Method and Description |
---|---|
protected abstract T |
DistributedCommand.execute(DistributedCallableContext ctx)
Subclasses must override to provide an execution implementation
|
MonitoredCallable<T> |
DistributedCommand.init(DistributedCallableContext ctx)
Implementation of init that returns a callable whose
call
method invokes DistributedCommand.execute(DistributedCallableContext) . |
MonitoredCallable<T> |
DistributedCallable.init(DistributedCallableContext ctx)
Invoked once per
VirtualNodeID . |
Modifier and Type | Method and Description |
---|---|
DistributedCallableContext |
ExecutionContext.getDistributedCallableContext()
Public only as a matter if implementation; operator authors should not invoke this method.
|
DistributedCallableContext |
DeferredCompositionContext.getDistributedCallableContext()
Public only as a matter if implementation; operator authors should not invoke this method.
|
Copyright © 2021 Actian Corporation. All rights reserved.