Module datarush.commons
Package com.pervasive.datarush.cal
Interface DistributedCallableContextBatch
-
public interface DistributedCallableContextBatchDistributed 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 NodeAllocationPlanensureInitialNodeAllocation()Returns the initial node allocation of the job.DistributedCallableContextgetContext(int partitionID)Returns the context corresponding to the given partitionIDList<DistributedCallableContext>getContexts()Returns the contexts for thisphysicalNode.FileClientgetFileClient()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
nullif the context does not exist in this batch
-
-