notebook.community

Edit and run



In [1]:

    
from pyspark.sql import SparkSession



In [6]:

    
spark = SparkSession \
    .builder \
    .appName("Python Spark SQL basic example") \
    .getOrCreate()



In [7]:

    
df = spark.read.format("org.apache.spark.sql.cassandra").options(table="words", keyspace="test").load()



In [8]:

    
df.show()









    



+-----+-----+
| word|count|
+-----+-----+
|hello|   50|
+-----+-----+