scala常用操作
scala常用操作
版本信息
python3.7
pyspark2.4.0
from pyspark import SQLContext,SparkContext,SparkConf
conf = SparkConf()
sc = SparkContext(conf=conf)
sqlContext = SQLContext(sc)
#加载csv文件
data = sqlContext.read.format("csv").option("header","true").load("union_order_user")
#按字段降序排序
sorted=data.sort("created_at",ascending = False)
#展示前100条记录 默认展示20条
sorted.show(100) 相关推荐
TheBigBlue 2020-07-28
shenwenjie 2020-07-07
muhongdi 2020-07-07
waitwolf 2020-07-08
yunfenglee 2020-07-08
yunfenglee 2020-07-08
kekeromer 2020-07-08
匆匆那些年 2020-07-07
liqinglin0 2020-07-05
TheBigBlue 2020-07-05
kekeromer 2020-06-13
zhixingheyitian 2020-06-08
TheBigBlue 2020-06-06
liqinglin0 2020-06-01
liqinglin0 2020-06-01
yunfenglee 2020-05-30
MICKEYSTUDY 2020-05-28
muhongdi 2020-05-19