Module datarush.commons
Package 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 Details

    • 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