Module datarush.commons
Package com.pervasive.datarush.cal
Interface DistributedCallableContextBatch
-
public interface DistributedCallableContextBatch
Distributed context passed toDistributedCallableBatch.init(DistributedCallableContextBatch)
. A batch context consists of a list of all contexts a givenphysicalNode
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description NodeAllocationPlan
ensureInitialNodeAllocation()
Returns the initial node allocation of the job.DistributedCallableContext
getContext(int partitionID)
Returns the context corresponding to the given partitionIDList<DistributedCallableContext>
getContexts()
Returns the contexts for thisphysicalNode
.FileClient
getFileClient()
Returns the file client to be used within this context
-
-
-
Method Detail
-
ensureInitialNodeAllocation
NodeAllocationPlan ensureInitialNodeAllocation()
Returns the initial node allocation of the job. This method forces allocation of nodes if not already allocated.- Returns:
- the initial node allocation of the job
-
getFileClient
FileClient getFileClient()
Returns the file client to be used within this context- Returns:
- the file client
-
getContexts
List<DistributedCallableContext> getContexts()
Returns the contexts for thisphysicalNode
.- Returns:
- the contexts
-
getContext
DistributedCallableContext getContext(int partitionID)
Returns the context corresponding to the given partitionID- Parameters:
partitionID
- the partition id- Returns:
- the context or
null
if the context does not exist in this batch
-
-