Interface HasParallelism

All Superinterfaces:
Identifiable, Params, Serializable, scala.Serializable
All Known Implementing Classes:
CrossValidator, OneVsRest, TrainValidationSplit

public interface HasParallelism extends Params
Trait to define a level of parallelism for algorithms that are able to use multithreaded execution, and provide a thread-pool based execution context.
  • Method Details

    • getExecutionContext

      scala.concurrent.ExecutionContext getExecutionContext()
      Create a new execution context with a thread-pool that has a maximum number of threads set to the value of parallelism(). If this param is set to 1, a same-thread executor will be used to run in serial.
    • getParallelism

      int getParallelism()
    • parallelism

      IntParam parallelism()
      The number of threads to use when running parallel algorithms. Default is 1 for serial execution