Skip to content

Commit

Permalink
revert no need change
Browse files Browse the repository at this point in the history
  • Loading branch information
scwf committed Nov 22, 2014
1 parent b00e20c commit ed3d6c9
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,11 @@ object HiveFromSpark {
case class Record(key: Int, value: String)

def main(args: Array[String]) {

val sparkConf = new SparkConf().setAppName("HiveFromSpark")
val sc = new SparkContext(sparkConf)
val path = s"${System.getenv("SPARK_HOME")}/examples/src/main/resources/kv1.txt"

// A local hive context creates an instance of the Hive Metastore in process, storing
// A local hive context creates an instance of the Hive Metastore in process, storing
// the warehouse data in the current directory. This location can be overridden by
// specifying a second parameter to the constructor.
val hiveContext = new HiveContext(sc)
Expand Down

0 comments on commit ed3d6c9

Please sign in to comment.