是否可以将 Python UDF 传递给标量参数？答案

【问题标题】：Is it possible to pass a Python UDF a scalar argument?是否可以将 Python UDF 传递给标量参数？
【发布时间】：2013-12-17 21:56:15
【问题描述】：

是否可以向 Python UDF 传递一个标量参数，如下所示：

A = LOAD 'date_list' AS (date:chararray); --Example date: 20130131
B = FOREACH A GENERATE DATE_LIB.get_week('YYYYMMDD', date)

我希望能够给出一个标量参数来指定日期的格式（例如，对于像“31-JAN-13”这样的日期，“DD-MON-YY”——我可以重复使用相同的我在DATE_LIB 中使用控制流处理这种情况的 UDF 代码）。我将如何在 Python 中做到这一点？既然 Python UDF 永远只能是 EvalFunc，那么它们有这个能力吗？

【问题讨论】：

标签： python hadoop user-defined-functions apache-pig

【解决方案1】：

这是可能的 - 如果你看一下example scripts 你会看到

@outputSchemaFunction("squareSchema")
def square(num):
  return ((num)*(num))

和调用示例

b = foreach a generate myfuncs.square(3);

在您的情况下，udf 类似于

@outputSchemaFunction("dow:long")
def get_week(format,source_date):
    your code here

【讨论】：