udf

1热度

2回答

我想将其他python/csv文件导入到我的python udf中以执行一些操作。 Like，将表数据（以流的形式逐行输入）与外部.csv行进行比较。当我尝试读取.csv文件的数据，它给了我一个错误 IOError: File /home/abc/xyz/myfile.csv does not exist 虽然代码工作得很好，当它被写成正规的Python脚本（不喜欢UDF）

0热度

1回答

猪：多个UDF在一个类

我想定义多个猪UDF。他们每个人都将提取不同部分的数据。在我的情况下，数据是具有包括许多嵌套JSON对象的复杂结构的JSON文档。问题是，现在我已经为我需要的每个函数创建了不同的Eval类。这些类中的每一个都实现了exec（）。有没有办法把所有的功能放到同一个UDF类中，然后从猪中调用它们？我UDF的一个实例： public class PigGetTimestamps extends Ev

0热度

1回答

UDF内的UDF不起作用（ByRef参数类型不匹配）

我正在构建一个内部使用另一个udf的udf，但我在迭代变量中收到了错误“ByRef argument missing”，我有这个字符串“-60981- - ：54044，-60981 - ：54044，-60981 - ：53835，-60981 - ：53835，“我想删除重复的项目，所以我想取回这个字符串”-60981 - ：54044， 60981 - ：53835，”这里是第一UDF，这就

5热度

1回答

塞式UDF的NodeJS聚集错误

我创建了一个聚合函数，这在塞在其中工作的AQL工作： AGGREGATE filter2.check_teamId('123', 0, 1456499994597) ON analytics.tracking WHERE teamId = '123' 这将返回结果。我然后尝试使用相同的UDF中的NodeJS： var statement = { aggregationUDF: {

0热度

1回答

PIG给出错误的Python UDF

我有一个Python UDF，它将十六进制数据转换为字符串。当我尝试在多个字段上调用UDF时，出现错误。这是我的Python UDF。脚本是hex_to_str.py #!/usr/bin/python @outputSchema("field:chararray") def hextoStr(field): if(field!=""): return field.decode

0热度

1回答

SQL - 在UDF case语句中使用逻辑运算符

因此，我花了一段时间才弄清楚如何创建我的第一个UDF，但在修复它之后，我想我的下一个将是小菜一碟。不幸的是，情况并非如此。我正在拉一个字段（ORIG_CLAIM，float），我想对这个数字进行分类。这里是我的代码： CREATE FUNCTION [dbo].[fnOC_LEVEL](@ORIG_CLAIM float) RETURNS nvarchar(255) AS BEGIN

0热度

1回答

Teradata Aggregate UDF中的数组定义

我正尝试在teradata中创建一个Aggregate UDF函数。作为它的一部分即时尝试decalre在中间存储阵列。当我试图将它链接到teradata时，它不断抛出下面的错误。 Executed as Single statement. Failed [7504 : HY000] in UDF/XSP/UDM DBC.IRR: SQLSTATE U0001: Elapsed time =

0热度

1回答

Excel WBA UDF操作字符串不起作用

我在VBA中的UDF抱怨无效限定符，我不明白为什么。预先感谢您的帮助。

1热度

1回答

udf在Spark SQL中DSL

我想在Spark SQL作业中使用DSL而不是纯SQL，但是我无法获得我的UDF工作。 sqlContext.udf.register("subdate",(dateTime: Long)=>dateTime.toString.dropRight(6)) 这不起作用 rdd1.toDF.join(rdd2.toDF).where("subdate(rdd1(date_time)) === su

1热度

1回答

用户定义函数返回＃值I2

我遇到过这种情况，需要我平均Vlookups数组的结果。我不知道如何用公式来实现这一点，并且似乎StackOverflow上的其他人也没有任何想法。所以我决定写一个函数来为我完成这个工作。不幸的是它返回“#VALUE！”错误，我不知道为什么！该功能在使用msgbox进行测试时工作正常。我有以下注释我的代码： Option Explicit Public Function AvgVlookup