sparksql使用问题请大神指点
2018-02-10 17:17
197 查看
SELECT orginfo.court_uuid,orginfo.uuid buildId,orginfo.memo buildmemo,orginfo. NAME AS buildname,T.userid,T.birth,T.sex,now() AS analysis_date,now() AS create_time,now() AS update_time FROM (SELECT base_house.org_uuid,base_user.birth,base_user.sex,base_user.uuid as userid,base_user.court_uuid as courtid1,base_house_user_rel.house_uuid,substring(base_org.sort_by,0,9) as orgsort_by FROM mdc.base_user base_user INNER JOIN mdc.base_house_user_rel base_house_user_rel ON base_user.uuid = base_house_user_rel.user_uuid INNER JOIN mdc.base_house base_house ON base_house_user_rel.house_uuid = base_house.uuid LEFT JOIN mdc.base_org base_org ON base_house.org_uuid = base_org.uuid WHERE base_user.user_type = 1) AS T LEFT JOIN mdc.base_org orginfo ON orginfo.sort_by = T.orgsort_by AND orginfo.court_uuid = T.courtid1 WHERE orginfo.org_type = 3 AND length (orginfo.sort_by) = 9 AND orginfo.uuid IS NOT NULL;
sql能在spark-sql中运行,但是我在java中使用sparkSession.sql就报错java.io.FileNotFoundException: File does not exist: /opt\mdc\base_org。
其中mdc是表空间,base_org是上面关联查询中的其中一个表。
是否不能把多重关联的sql放入到sparksession.sql中?必须使用Dataset<Row>中的join函数进行关联操作?
第一次使用sparksql~~~~请大神指点
sql能在spark-sql中运行,但是我在java中使用sparkSession.sql就报错java.io.FileNotFoundException: File does not exist: /opt\mdc\base_org。
其中mdc是表空间,base_org是上面关联查询中的其中一个表。
是否不能把多重关联的sql放入到sparksession.sql中?必须使用Dataset<Row>中的join函数进行关联操作?
第一次使用sparksql~~~~请大神指点
相关文章推荐
- 使用SparkSQL 读取Phoenix4.5.2出现下面的问题
- spark-sql中文字符使用问题
- 失败的sparkSql使用问题记录
- 使用网页文本编辑器的问题,请高手指点一下
- SQL中使用LIKE查询注意的问题
- asp.net中连接access数据库时,不能使用ISNull()T-SQL的问题解决
- [网络问题,截图以后再传]本实验是设计性实验。目的在于使用关系数据库标准语言SQL,掌握视图和索引的操作。
- 关于统计的一个sql问题,使用动态sql语句实现。
- SQL中使用LIKE查询注意的问题
- 使用hibernate3的createSQLQuery遇到的问题
- 使用hibernate3的createSQLQuery遇到的问题
- SQL SELECT INTO 语句使用问题
- 使用SQL存储过程要特别注意的问题-注意顺序读取
- 使用Jmeter对Mysql进行压力测试无法执行多条sql语句问题
- 使用Sql时应注意的问题
- 求解在SQL中使用了where列所遇到的问题
- SQL操作行更新问题---使用游标
- [哭]使用Data Access 2 插入Ntext类型数据时SqlParameter不指定类型的问题 , ,请为我解惑
- 使用SQL存储过程要特别注意的问题-注意顺序读取
- 使用SQL存储过程要特别注意的问题-注意顺序读取