dataset<Row> df1,df2,df3

 //该方法可以执行成功
df3= df1.join(df2,"post_id").selectExpr("hostname,request_date,post_id,title,author,name as category".split(",")); //innner join acc = df1.withColumnRenamed("post_id", "post_id_acc");
//该方法join同名列的时候,要重命名,否则会报错:重名列(通过drop删除无效,不知道是什么原因)
post_categories = acc.join(post_one_cat,acc.col("post_id_acc").equalTo(post_one_cat.col("post_id")),"left_outer").join(categories, post_one_cat.col("cate_id").equalTo(categories.col("id")),"left_outer").selectExpr("hostname,request_date,post_id_acc as post_id,title,author,name as category".split(","));
9 //post_categories = acc.join(post_one_cat,acc.col("post_id_acc").equalTo(post_one_cat.col("post_id")),"left_outer").join(categories, post_one_cat.col("cate_id").equalTo(categories.col("id")),"left_outer").withColumnRenamed("name", "category")
.withColumnRenamed("post_id_cat", "post_id");
 //该方法可以执行成功 

 df3= df1.join(df2,JavaConverters.asScalaIteratorConverter(Arrays.asList("post_id").iterator()).asScala().toSeq(),"left_outer").join(cat, JavaConverters.asScalaIteratorConverter(Arrays.asList("cate_id").iterator()).asScala().toSeq(),"left_outer").selectExpr("hostname,request_date,post_id,title,author,name as category".split(","));

最新文章

  1. Asp.net有关GridView的使用
  2. 从RAM新建QIcon对象 / Create a QIcon from binary data
  3. iOS 3DES加密解密(一行代码搞定)
  4. Jenkins实现生产环境部署文件的回滚操作(Windows)
  5. OneSQL的docker之旅
  6. Python学习笔记第七天(列表解析)
  7. string和stringstream用法总结
  8. STL 简介,标准模板库
  9. hdu 4421 2-SAT问题
  10. tcl/tk实例详解——返回一个文件夹下所有文件的绝对路径
  11. Android基础之响应Menu键弹出菜单Demo
  12. CSS 效果汇总
  13. WebViewJavascriptBridge详细使用
  14. SELinux一键开启与禁用脚本
  15. Odoo免费开源ERP销售收款的财务对账解决方案
  16. Eclipse 中 SVN 插件的安装与使用
  17. EXSI中Linux安装tools
  18. DeepID人脸识别算法之三代
  19. NodeJS-002-Expres启动
  20. Windows服务器管理与优化

热门文章

  1. wordpress上传含中文文件名出现乱码
  2. Java Bean与Map之间相互转化的实现
  3. hibernateDAO层基本的增删改查
  4. Oracle12C创建用户遇到ora-6509
  5. 【oracle使用笔记1】SQL报的常见错误
  6. eclipse中误删tomcat后,文件都报错,恢复server时无法选择tomcat7.0解决办法
  7. mint-ui message box 问题;
  8. 【memcached启动报错】
  9. angularjs中控制器之间的通信----$on、$emit和$broadcast解析
  10. mybatis报错:未找到参数导致绑定异常