diff --git a/repl/src/main/scala/spark/repl/SparkILoop.scala b/repl/src/main/scala/spark/repl/SparkILoop.scala index 490efa69bc78c6b2e266a073304a91a6a19cba89..a4bca02d21039052557582d87557c28263e35f0c 100644 --- a/repl/src/main/scala/spark/repl/SparkILoop.scala +++ b/repl/src/main/scala/spark/repl/SparkILoop.scala @@ -802,13 +802,13 @@ class SparkILoop(in0: Option[BufferedReader], val out: PrintWriter, val master: def chooseReader(settings: Settings): InteractiveReader = { if (settings.Xnojline.value || Properties.isEmacsShell) SimpleReader() - else try JLineReader( + else try SparkJLineReader( if (settings.noCompletion.value) NoCompletion - else new JLineCompletion(intp) + else new SparkJLineCompletion(intp) ) catch { case ex @ (_: Exception | _: NoClassDefFoundError) => - echo("Failed to created JLineReader: " + ex + "\nFalling back to SimpleReader.") + echo("Failed to created SparkJLineReader: " + ex + "\nFalling back to SimpleReader.") SimpleReader() } } @@ -985,7 +985,7 @@ object SparkILoop { repl.settings = new Settings(echo) repl.settings.embeddedDefaults[T] repl.createInterpreter() - repl.in = JLineReader(repl) + repl.in = SparkJLineReader(repl) // rebind exit so people don't accidentally call sys.exit by way of predef repl.quietRun("""def exit = println("Type :quit to resume program execution.")""") diff --git a/repl/src/main/scala/spark/repl/SparkJLineCompletion.scala b/repl/src/main/scala/spark/repl/SparkJLineCompletion.scala index 5d12898732866b8d693e06e61df6b9376fa12be1..0069d8b2f49c74d565f85a3a7bad12362f5ff3ec 100644 --- a/repl/src/main/scala/spark/repl/SparkJLineCompletion.scala +++ b/repl/src/main/scala/spark/repl/SparkJLineCompletion.scala @@ -15,7 +15,7 @@ import collection.mutable.ListBuffer // REPL completor - queries supplied interpreter for valid // completions based on current contents of buffer. -class JLineCompletion(val intp: SparkIMain) extends Completion with CompletionOutput { +class SparkJLineCompletion(val intp: SparkIMain) extends Completion with CompletionOutput { val global: intp.global.type = intp.global import global._ import definitions.{ PredefModule, RootClass, AnyClass, AnyRefClass, ScalaPackage, JavaLangPackage } diff --git a/repl/src/main/scala/spark/repl/SparkJLineReader.scala b/repl/src/main/scala/spark/repl/SparkJLineReader.scala index f7b0261ad02873f856e594d87ecb052a967a7510..ef6b6e092e04df8143d0a0d72ac489a32707bed5 100644 --- a/repl/src/main/scala/spark/repl/SparkJLineReader.scala +++ b/repl/src/main/scala/spark/repl/SparkJLineReader.scala @@ -73,7 +73,7 @@ class SparkJLineReader(val completion: Completion) extends InteractiveReader { def readOneKey(prompt: String) = consoleReader readOneKey prompt } -object JLineReader { - def apply(intp: SparkIMain): JLineReader = apply(new JLineCompletion(intp)) - def apply(comp: Completion): JLineReader = new JLineReader(comp) +object SparkJLineReader { + def apply(intp: SparkIMain): SparkJLineReader = apply(new SparkJLineCompletion(intp)) + def apply(comp: Completion): SparkJLineReader = new SparkJLineReader(comp) }