pyspark 讀取csv文件創(chuàng)建DataFrame的兩種方法

更新時間：2018年06月07日 08:36:22 作者：Stephen__Chou

今天小編就為大家分享一篇pyspark 讀取csv文件創(chuàng)建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').load('game-clicks.csv')

以上這篇pyspark 讀取csv文件創(chuàng)建DataFrame的兩種方法就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

python使用lxml xpath模塊解析XML遇到的坑及解決
這篇文章主要介紹了python使用lxml xpath模塊解析XML遇到的坑及解決,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2024-05-05
在PyCharm中高效使用遠程文件編輯功能的實現(xiàn)
PyCharm作為業(yè)界領先的集成開發(fā)環(huán)境（IDE）,提供了強大的本地和遠程開發(fā)功能,本文詳細介紹了如何在PyCharm中使用遠程文件編輯功能,希望能夠幫助你提高遠程開發(fā)的效率和體驗
2024-08-08
Python查找字符串中重復字符的多種方法
在處理字符串時,我們經常需要分析字符的頻率,找出那些出現(xiàn)次數(shù)超過一次的重復字符,這在數(shù)據(jù)處理、文本分析、密碼學等多個領域都有廣泛的應用,本文介紹了Python查找字符串中重復字符的多種方法,需要的朋友可以參考下
2024-09-09
python實現(xiàn)Floyd算法
這篇文章主要為大家詳細介紹了python實現(xiàn)Floyd算法，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2018-01-01
python中SQLAlchemy使用前端頁面實現(xiàn)插入數(shù)據(jù)
這篇文章主要介紹了SQLAlchemy使用前端頁面實現(xiàn)插入數(shù)據(jù)，文章內容介紹詳細巨頭有一定的參考價值，需要的小伙伴可以參考一下
2022-03-03
python中函數(shù)總結之裝飾器閉包詳解
下面小編就為大家?guī)硪黄猵ython中函數(shù)總結之裝飾器閉包詳解。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2016-06-06
numpy:找到指定元素的索引示例
今天小編就為大家分享一篇numpy:找到指定元素的索引示例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2019-11-11
Pandas中Replace函數(shù)使用那些事兒
Pandas是基于NumPy?的一種工具,該工具是為了解決數(shù)據(jù)分析任務而創(chuàng)建的,下面這篇文章主要給大家介紹了關于Pandas中Replace函數(shù)使用那些事兒,文中通過實例代碼以及圖文介紹的非常詳細,需要的朋友可以參考下
2022-11-11
python 三邊測量定位的實現(xiàn)代碼
這篇文章主要介紹了python 三邊測量定位的實現(xiàn)代碼，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2021-04-04
Python基于Tkinter的HelloWorld入門實例
這篇文章主要介紹了Python基于Tkinter的HelloWorld入門實例,以一個簡單實例分析了Python中Tkinter模塊的使用技巧,需要的朋友可以參考下
2015-06-06