PigのPython UDFを試してみた

[yokkuns]

PigのPython UDFを試してみました。
・http://d.hatena.ne.jp/yokkuns/20121217/1355756912


ホントは、集約して計算するUDFもやりたかったんですが、どうも上手く行かず・・・
何かご存知の方がいましたら、ご教授いただけると嬉しいです！

====
以下のコードで実行すると、「ERROR 6017: Job failed! Error - NA」になる。

---
@outputSchema("y:double")
def Median(bag):
s = sorted(map(float,bag))
l = len(s)
if not l % 2:
return (s[l/2] + s[(l/2)-1]) / 2.0
return s[l/2]
---
====