import org.apache.spark.SparkConf
import org.apache.spark.SparkContext
import org.apache.spark.streaming.StreamingContext
import com.datastax.driver.spark._
import org.apache.spark.streaming.Seconds

object test extends App {
  val sparkConf = new SparkConf(true)
  .set("cassandra.connection.host", "127.0.0.1")
  .setMaster("local[2]")
  .setAppName("spark-driver-demo")
  
  val sc = new SparkContext("local[2]", "test", sparkConf)
  val ssc =  new StreamingContext(sparkConf, Seconds(1))
  val allstarfull = sc.cassandraTable("cassandra_spark_mlbdata", "allstarfull")
  
  println("count: " + allstarfull.count)
  
  //allstarful.foreach(println(_))
println("first: " + allstarfull.first)
}

import org.apache.spark.SparkConf
import org.apache.spark.SparkContext
import org.apache.spark.streaming.StreamingContext
import com.datastax.driver.spark._
import org.apache.spark.streaming.Seconds

object test extends App {
  val sparkConf = new SparkConf(true)
  .set("cassandra.connection.host", "127.0.0.1")
  .setMaster("local[2]")
  .setAppName("spark-driver-demo")
  
  val sc = new SparkContext("local[2]", "test", sparkConf)
  val ssc =  new StreamingContext(sparkConf, Seconds(1))
  val allstarfull = sc.cassandraTable("demo", "allstarfull")
  
  println("count: " + allstarfull.count)
  
  //allstarful.foreach(println(_))
println("first: " + allstarfull.first)
}

--- 
+++ 
@@ -12,7 +12,7 @@
   
   val sc = new SparkContext("local[2]", "test", sparkConf)
   val ssc =  new StreamingContext(sparkConf, Seconds(1))
-  val allstarfull = sc.cassandraTable("demo", "allstarfull")
+  val allstarfull = sc.cassandraTable("cassandra_spark_mlbdata", "allstarfull")
   
   println("count: " + allstarfull.count)
   
Update keyspace to match creation scripts.
