Uses of Interface
com.pervasive.datarush.cal.DistributedCallableContext
-
Packages that use DistributedCallableContext 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. -
-
Uses of DistributedCallableContext in com.pervasive.datarush.cal
Methods in com.pervasive.datarush.cal that return DistributedCallableContext Modifier and Type Method Description DistributedCallableContext
DistributedCallableContextBatch. getContext(int partitionID)
Returns the context corresponding to the given partitionIDDistributedCallableContext
DistributedExecutorService. getMasterContext()
Returns the job master context.Methods in com.pervasive.datarush.cal that return types with arguments of type DistributedCallableContext Modifier and Type Method Description List<DistributedCallableContext>
DistributedCallableContextBatch. getContexts()
Returns the contexts for thisphysicalNode
.Methods in com.pervasive.datarush.cal with parameters of type DistributedCallableContext Modifier and Type Method Description protected abstract T
DistributedCommand. execute(DistributedCallableContext ctx)
Subclasses must override to provide an execution implementationMonitoredCallable<T>
DistributedCallable. init(DistributedCallableContext ctx)
Invoked once perVirtualNodeID
.MonitoredCallable<T>
DistributedCommand. init(DistributedCallableContext ctx)
Implementation of init that returns a callable whosecall
method invokesDistributedCommand.execute(DistributedCallableContext)
. -
Uses of DistributedCallableContext in com.pervasive.datarush.operators
Methods in com.pervasive.datarush.operators that return DistributedCallableContext Modifier and Type Method Description DistributedCallableContext
DeferredCompositionContext. getDistributedCallableContext()
Public only as a matter if implementation; operator authors should not invoke this method.DistributedCallableContext
ExecutionContext. getDistributedCallableContext()
Public only as a matter if implementation; operator authors should not invoke this method.
-