小编Gan*_*mar的帖子

Spark支持条款吗?

我有一个employee_1带有属性ID和名称(带有数据)的表,还有另一个employee_2具有相同属性的表,我想通过将ID值增加+1来加载数据

我的有子句如下所示:

WITH EXP AS (SELECT  ALIASNAME.ID+1 ID, ALIASNAME.NAME NAME FROM employee_1 ALIASNAME)
INSERT INTO TABLE employee_2 SELECT * FROM EXP; 
Run Code Online (Sandbox Code Playgroud)

执行步骤:

我在HDFS位置有一个文件(包含数据)。

  1. 根据hdfs位置创建RDD。
  2. RDD到Hive临时表
  3. 从临时表到Hive目标(employee_2)。

当我从后端成功运行测试程序时。但数据未加载。employee_2是空的。

注意:如果您在Hive中运行上述with子句,它将成功并加载数据。但是火花不会在1.6中吗?

hadoop apache-spark

5
推荐指数
1
解决办法
3952
查看次数

标签 统计

apache-spark ×1

hadoop ×1