in kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala [147:185]
protected def initializeResponseMap(): collection.mutable.Map[String, ActorRef] =
new ConcurrentHashMap[String, ActorRef]().asScala
private def initializeKernel(
config: Config,
actorLoader: ActorLoader,
interpreterManager: InterpreterManager,
commManager: CommManager,
pluginManager: PluginManager
) = {
//kernel has a dependency on ScalaInterpreter to get the ClassServerURI for the SparkConf
//we need to pre-start the ScalaInterpreter
// val scalaInterpreter = interpreterManager.interpreters("Scala")
// scalaInterpreter.start()
val kernel = new Kernel(
config,
actorLoader,
interpreterManager,
commManager,
pluginManager
){
override protected[toree] def createSparkConf(conf: SparkConf) = {
val theConf = super.createSparkConf(conf)
// TODO: Move SparkIMain to private and insert in a different way
logger.warn("Locked to Scala interpreter with SparkIMain until decoupled!")
// TODO: Construct class server outside of SparkIMain
logger.warn("Unable to control initialization of REPL class server!")
theConf
}
}
pluginManager.dependencyManager.add(kernel)
kernel
}