dataframe 转换为临时表，执行sparksql
val df = spark.read.json(Path) df.show()
//将dataframe 注册成为一张临时表
df.createOrReplaceTempView("persons")
spark.sql("select * from persons where age > 20 ").show()
相关文章
- 03-07cc2640学习笔记
- 03-07Qt QStringList 的学习笔记
- 03-07C++面向对象程序设计学习笔记（5）
- 03-07C++面向对象程序设计学习笔记（7）
- 03-07C++面向对象程序设计学习笔记（3）
- 03-07$exLucas$学习笔记
- 03-07LDA主题模型学习笔记5：C源代码理解
- 03-07【转】shell学习笔记（三）——引用变量、内部变量、条件测试、字符串比较、整数比较等
- 03-07[('type','=','get_user_ht_type()')]">openerp学习笔记 domain 增加扩展支持，例如支持
[('type','=','get_user_ht_type()')] - 03-07Objective -C学习笔记 之copy(复制)