回答情况：
提问时间：
问题标签：
我正在尝试测试我编写的一个功能，它的一部分是使用一个调用外部库的udf，我想模拟对该库的调用，并返回化装值，这可能吗？我想测试的代码如下所示： my_udf = udf(udf_foo) return some_library.foo(x)
我想模拟some_
浏览 4修改于2022-04-26得票数 2
street_address=None, subregion=None, type=None, zip_plus_4=None)])] 正如您所看到的，有一个名为isPrimary的字段，它是我想要选择的字段，这是我编写的函数Payload = {"lat":float(lat), "lon":float(lon)}| {}|| {}|| {}|
| {}
浏览 136提问于2021-07-30得票数 0
1回答
serviceConfig.getAdminKeyspace) }
cassandraSQLContext.udf.register所以它会触发getSiteId自定义函数，但由于某些原因，自定义函数总是有空指针异常。如果我将serviceConfig.getSiteId.toInt放在insertIntoCassandra函数中，该函数可以访问serviceConfi
浏览 3修改于2017-03-11得票数 0
我创建了一个简单的UDF来转换或提取spark中temptabl中的时间字段的一些值。我注册了该函数，但是当我使用sql调用该函数时，它抛出了一个NullPointerException。下面是我的函数和执行它的过程。我在用齐柏林飞艇。奇怪的是，昨天它还在工作，但今天早上它停止了工作。函数 val sdf = new java.text.SimpleDateFormat("HH:mm")
valti
浏览 14修改于2016-07-28得票数 11
回答已采纳
尝试使用UDF函数，但遇到错误： import timefrom pyspark.sql.functions import lit,unix_timestamp, udfreturn unix_timestamp(end, format=timefmt) - unix_timestamp(start, format=timefmt)
calc_time_udf= udf(lambda start, end: calc_time(start, end), Timesta
浏览 36修改于2021-07-23得票数 2
回答已采纳
我想要在Excel中创建一个函数UDF，它应该有一个长度为2或4个字符的值。当它是两个字符时，它返回相同的字符。如果是4，它应该随机选择左边的两个或右边的两个。问题是，当我想要使用公式RandBetween时，它不识别它(错误:子函数或未定义的函数)，但是我能够在子上使用它而不存在任何问题。
浏览 4提问于2021-10-15得票数 1
1回答
我需要编写一个复杂的用户定义函数(UDF)，它以多个列作为输入。类似于：val uudf = udf{(val:Int, lag:Int, cumsum_p:Double) => val + l
浏览 5提问于2019-10-11得票数 0
回答已采纳
我正在使用EMR集群，并添加了步骤配置，它选择我的UDF jar并创建函数。正在创建EMR集群，我可以从配置单元CLI中使用这些UDF函数。我正在创建永久函数-创建函数add AS 'brickhouse.udf.collect.CombineUDF‘
错误为org.apache.hive.service.cli.HiveSQLException:编译语句时出错:失败: SemanticException错误10011:无效函数添加
浏览 2提问于2017-11-07得票数 0
1回答
然而，我在创建函数时遇到了问题。找不到列dbo、用户定义函数或聚合dbo.GetWorkingDaysMin，或者名称不明确。[TEST_DATES] alter FUNCTION GetWorkingDaysMin @Date1 INT, )
浏览 11修改于2017-08-04得票数 0
我想将几个UDF作为函数参数与数据帧一起传递。val lkpUDF = udf{(i: Int) => if (i > 0) 1 else 0}
.withColumn("new_col) .withColumn("n
浏览 1提问于2017-02-08得票数 0
回答已采纳
我们使用纯SQL语法来转换数据，并具有自定义的UDF函数。示例：此函数可能会产生异常，我们希望为用户提供详细的错误信息。在行中，我们有关于文件和row_id的信息，这就是为什么我们要访问所提到的UDF中的整行，以提供有关file_uuid和row_id的详细错误。有人知道这件事吗？
谢谢
浏览 0提问于2019-12-10得票数 2
2回答
我可以发送一个关系到Pig函数作为输入吗？一个关系可以包含多个元组。如何在Pig函数中逐个读取每个元组？我需要这样的东西TCS Raja,AXIS,80000,TCS
SomeOne能帮我吗？
浏览 3修改于2014-06-04得票数 0
回答已采纳
我正在分析以下代码：def error(value, pred):我知道udf是一个用户定义的函数，但我不明白这意味着什么？因为udf之前没有在代码中定义任何位置？
浏览 2修改于2020-12-23得票数 1
回答已采纳
需要帮助编写一个cassandra来添加/除法/乘两个变量。尝试了下面的代码，但是它似乎不起作用。另外，我没有java方面的经验，所以我可能无法调试。在这件事上我很感激你。 RETURNS double LANGUAGE java return (val1 == null || val2 == null)?null:Double.valueOf( val1.doubleValue() + val2.doubleValue());
END BOD
浏览 1修改于2022-07-27得票数 0
回答已采纳
在某些情况下，我需要运行几个UDF函数。我的单元格包含具有不同参数的UDF，我在这里显示的是简化版本。[ExcelFunction(Name = "Test.TestMe", Description = "Some test", IsHidden = false)]
public static如果我尝试如下：Application.Evaluate("=Test.TestMe(1)
浏览 2提问于2019-08-25得票数 0
回答已采纳
我正在尝试在创建列之后应用UDF函数。Cannot resolve column name "previous_status" among alreadyAuthorized[id] = True
return
浏览 4提问于2019-10-15得票数 0
回答已采纳
如果在PySpark中将任何类型的登录添加到UDF函数中，它将不会出现在任何地方。这是一种实现这一目标的方法吗？def parse_data(attr): # execute something return Noneimport pyspark.sql.functions
浏览 0提问于2019-10-15得票数 5
我试图在PySpark中使用UDF函数创建一个列。* 0.856 return row * 0.8566 return row
res = res.withColumn("final_value",
浏览 11修改于2022-10-24得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号