parquet文件是一个压缩格式 package spark; import org.apache....

阅读(15)评论(0)2020-03-29

赞(0)

动态构建DataFrame中的元数据创建row顺序要和动态创建schema的顺序一致 package...

阅读(14)评论(0)2020-03-28

赞(0)

开窗函数只能在hive中使用 开窗函数格式： row_number() over (partitio...

阅读(15)评论(0)2020-03-28

赞(0)

package spark; import java.util.HashMap; import ja...

阅读(13)评论(12)2020-03-26

赞(0)

读取json格式的RDD加载成DateFrame DateFrame 有数据，有列的schema s...

阅读(15)评论(0)2020-03-24

赞(0)

广播变量只能在Driver定义，在Executor端使用，不能在Executor端使用，不能在Exc...

阅读(14)评论(5)2020-03-20

赞(0)