com.pervasive.datarush.cal

Interface DistributedCallableContextBatch

public interface DistributedCallableContextBatch

Distributed context passed to DistributedCallableBatch.init(DistributedCallableContextBatch). A batch context consists of a list of all contexts a given physicalNode.

Method Summary

Modifier and Type	Method and Description
NodeAllocationPlan	ensureInitialNodeAllocation() Returns the initial node allocation of the job.
DistributedCallableContext	getContext(int partitionID) Returns the context corresponding to the given partitionID
List<DistributedCallableContext>	getContexts() Returns the contexts for this physicalNode.
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 this physicalNode.

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