python udf in hi

Question

我想用python编写hiveudf来解析name列（使用https://pypi.python.org/pypi/nameparser），并将解析后的值放入表的不同列（title、first、middle、last、suffix、nickname）。在

我是python新手，我写的python代码是这样的

#!/usr/bin/python
import sys
from nameparser import HumanName
name = HumanName(name)
return name.title

在蜂巢里我就是这样做的

^{pr2}$

但是我得到了org.apache.hadoop.hive.ql.元数据.HiveException。在

Answer 1

在select语句using子句中，需要指定'python标题.py“而不是标题.py. 在

add file title.py;
SELECT TRANSFORM (name) using 'python title.py' AS (title STRING) from emp2;