notebook.community
Edit and run
In [3]: from pyspark import SparkContext, SparkConf, SQLContext, HiveContext, StorageLevel from pyspark.sql.functions import * sc = SparkContext() sqlContext = SQLContext(sc)
from pyspark import SparkContext, SparkConf, SQLContext, HiveContext, StorageLevel from pyspark.sql.functions import * sc = SparkContext() sqlContext = SQLContext(sc)
In [ ]: