是否可以使用Hive Streaming转换特定列?

use*_*221 6 python streaming hive

以下语法有效:

SELECT TRANSFORM(col1,col2,col3) USING 'python script.py' AS col_1,col_2,col_3 FROM...
Run Code Online (Sandbox Code Playgroud)

python脚本实际上只转换col3,而col1,col2只是通过python脚本而没有任何改变.我想重新使用这个python脚本,这样只要col1通过,我就可以用任意列替换col1,col2.但以下两个代码不起作用:

SELECT col1, col2, TRANSFORM(col3) USING 'python script.py' AS col_1 FROM... 

SELECT TRANSFORM(col3) USING 'python script.py' AS col_3, col1, col2 FROM... 
Run Code Online (Sandbox Code Playgroud)

如果有一种方法只将选定列的子集传递给流式脚本,同时使其他选定的列离开流式传输过程?

提前致谢.

小智 0

这是行不通的,因为转换可以返回多行。想象一下,如果某些 col3 的 script.py 返回 2 行(col31 和 col32)。语法意味着什么?返回 col1、col2、col31 和 col1、col2、col32?