Class LaunchConfig

java.lang.Object
com.rpl.rama.test.LaunchConfig

public class LaunchConfig extends Object
Object to specify parallelism settings for modules launched on an InProcessCluster
  • Constructor Details

    • LaunchConfig

      public LaunchConfig(int numTasks, int numThreads)
      Create LaunchConfig. Number of workers defaults to one but can be changed with numWorkers(int)
      Parameters:
      numTasks - Number of tasks for the module. Must be power of two.
      numThreads - Number of threads for the module. Must be less than or equal to number of tasks.
  • Method Details

    • numWorkers

      public LaunchConfig numWorkers(int numWorkers)
      Override number of workers for module
      Parameters:
      numWorkers - Number of workers. Must be less than or equal to number of threads.
    • getNumTasks

      public int getNumTasks()
    • getNumThreads

      public int getNumThreads()
    • getNumWorkers

      public int getNumWorkers()