Skip to content

Commit

Permalink
Remove the REPL forked code.
Browse files Browse the repository at this point in the history
  • Loading branch information
dragos committed Jun 19, 2015
1 parent c13da20 commit abcc7cb
Show file tree
Hide file tree
Showing 9 changed files with 35 additions and 3,147 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,6 @@ object Main extends Logging {
Option(sparkContext).map(_.stop)
}


def getAddedJars: Array[String] = {
val envJars = sys.env.get("ADD_JARS")
if (envJars.isDefined) {
Expand Down Expand Up @@ -84,10 +83,9 @@ object Main extends Logging {
val loader = Utils.getContextOrSparkClassLoader
try {
sqlContext = loader.loadClass(name).getConstructor(classOf[SparkContext])
.newInstance(sparkContext).asInstanceOf[SQLContext]
.newInstance(sparkContext).asInstanceOf[SQLContext]
logInfo("Created sql context (with Hive support)..")
}
catch {
} catch {
case _: java.lang.ClassNotFoundException | _: java.lang.NoClassDefFoundError =>
sqlContext = new SQLContext(sparkContext)
logInfo("Created sql context..")
Expand Down

This file was deleted.

Loading

0 comments on commit abcc7cb

Please sign in to comment.