Skip to content

Instantly share code, notes, and snippets.

@emersonbarros

emersonbarros/Zeppelin script

Created July 23, 2018 12:03
Show Gist options
  • Save emersonbarros/3f4c56765006839f0dbe39949bf5e5d1 to your computer and use it in GitHub Desktop.
Save emersonbarros/3f4c56765006839f0dbe39949bf5e5d1 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Zeppelin script
%dep
z.load("/usr/zeppelin/interpreter/interpreter/spark/spark-cassandra-connector-assembly-2.0.2.jar")
%spark
import com.datastax.spark.connector._
import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.SparkContext._
val rdd = sc.cassandraTable("test","users")
println("Row count:" + rdd.count)
println("Age:" + rdd.first.getInt("age"))
val coultAgeHigher25 = rdd.filter(r => r.getInt("age") > 25).count
println("Count age:" + coultAgeHigher25)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment