In [2]:
import findspark
In [3]:
findspark.init('/Users/hanlei/Downloads/spark-2.2.0-bin-hadoop2.7')
In [4]:
from pyspark.sql import SparkSession
In [5]:
spark = SparkSession.builder.appName('ops').getOrCreate()
In [ ]:
df = spark.read.csv('')