Lines Matching refs:setupScheduler
68 def setupScheduler(confs: (String, String)*): TaskSchedulerImpl = { method
95 val taskScheduler = setupScheduler()
120 val taskScheduler = setupScheduler("spark.task.cpus" -> taskCpus.toString)
150 val taskScheduler = setupScheduler("spark.task.cpus" -> taskCpus.toString)
172 val taskScheduler = setupScheduler()
191 val taskScheduler = setupScheduler()
223 val taskScheduler = setupScheduler()
262 val taskScheduler = setupScheduler()
296 val taskScheduler = setupScheduler(
347 val taskScheduler = setupScheduler(
381 val taskScheduler = setupScheduler()