1. 程式人生 > >pyspark 讀取csv檔案建立DataFrame的兩種方法

pyspark 讀取csv檔案建立DataFrame的兩種方法

pyspark 讀取csv檔案建立DataFrame的兩種方法

方法一:用pandas輔助

from pyspark import SparkContext 
from pyspark.sql import SQLContext 
import pandas as pd 
sc = SparkContext()
sqlContext=SQLContext(sc) 
df=pd.read_csv(r'game-clicks.csv') 
sdf=sqlc.createDataFrame(df) 

方法二:純spark

from pyspark import SparkContext 
from pyspark.sql import SQLContext
sc = SparkContext()
sqlContext = SQLContext(sc)
sqlContext.read.format('com.databricks.spark.csv').options(header='true', inferschema='true').