Hi All
We are trying to create a table in Hive from spark-assembly-1.0.2.jar file.
CREATE TABLE IF NOT EXISTS src (key INT, value STRING)
JavaSparkContext sc = CC2SparkManager.sharedInstance().getSparkContext();
JavaHiveContext sqlContext = new JavaHiveContext(sc);
sqlContext.sql("CREATE
Hi All
I have one master and one worker on AWS (amazon web service) and am running
spark map reduce code provided on the link
https://spark.apache.org/examples.html
We are using Spark version 1.0.2
Word Count
val file = spark.textFile("hdfs://...")
val counts = file.flatMap(line => line.split("