user-defined-functions 相关问题

程序或环境的用户提供的功能

如何在电话号码中添加 1 并删除破折号?

我需要我的数据值看起来像这样18184789564。 我使用了这段代码: REGEXP_REPLACE(+1, b.PHONE_NUMBER, '[^0-9]', '') AS PHONE_NUMBER 我收到一个错误 无法识别数值 希望...

回答 1 投票 0

如何在电话号码中添加 1 并删除破折号,这是我在下面使用的代码

我需要我的数据值看起来像这样18184789564我使用了这段代码 REGEXP_REPLACE(+1,b.PHONE_NUMBER,'[^0-9]','') as PHONE_NUMBER 给我一个错误,数值无法识别。希望...

回答 1 投票 0

使用窗口函数运行 Total UDF(用户定义函数)会抛出“无法强制输出值”

输入数据集: 日期 ID 数字 期望的 2020-01-01 1 8 8 2020-01-02 1 11.5 19.5 2020-01-03 1 -20 0 2020-01-04 1 10 10 2020-01-05 1 -5 5 2020-01-06 2 -9 0 2020-01-07 2 26 26 2020-01-08 2 5 31

回答 1 投票 0

如何使用 pandas_udf 在 pyspark 中对分组/分区数据帧进行迭代

spark版本:3.2 我定义了 pandas_udf defcalculate_shap(迭代器:迭代器[pd.DataFrame]) -> 迭代器[pd.DataFrame]: 对于迭代器中的 X: 产量 pd.DataFrame( 解释一下...

回答 1 投票 0

spark 数据帧中两列中两个向量之间的欧几里德距离

我正在尝试获取 Spark 数据框中不同列中两个向量之间的欧氏距离。我需要在 Spark 上完成此操作。我花了很多时间尝试做到这一点,但无法想象......

回答 1 投票 0

用户定义的函数仅返回列中的第一个值

我正在为一个类编写一个函数,该函数应该转换我表中的列之一。我正在使用他们给我的数据库(DVD 租赁)。我认为最终目标是将这个函数添加为

回答 1 投票 0

如何在Python函数内更新pyspark数据框

我有一个Python函数,它接收pyspark数据帧并检查它是否具有脚本中使用的其他函数所需的所有列。特别是,如果缺少“体重”列,我想...

回答 1 投票 0

使用 Flink SQL 和表聚合函数(UDTAGG)

我正在使用 Flink 1.18 和 Java,并且我正在尝试使用用户定义的表聚合函数 (UDTAGG)。该文档仅包含 UDTAGG 的表 API 示例。 然而,当我尝试实现时...

回答 1 投票 0

围绕 CRC32 编写 MySQL 包装器

我需要编写一些跨供应商的 SQL 查询,并且我想隐藏某些在上下文中不太重要的细节。 也就是说,我想围绕 ...

回答 2 投票 0

Apache IoTDB中当一个字段有值而多个字段没有值时,如何将物理量存储在udf中以触发函数?

如果我有一个有 100 个物理量的设备,并且我希望数据仅在数据发生变化时才存储在 Apache IoTDB 中。从物理量来看,经常变化的只有5个,而

回答 1 投票 0

UserDefinedFunction 比普通 sql 查询花费的时间长 10 倍

再次出现用户定义函数的问题,也许有人有想法。 调用函数: 选择 * FROM get_process_single_real('Befuellung','P24A2A009','24_NTest','Gewicht'); 最多需要 15 秒...

回答 1 投票 0

如何从Spark UDF返回Row?

我有一个用例,我想向 Map 对象添加另一个条目。设置如下(使用 Scala 2.13.13 + Spark 3.3.1): val json = ”“” [ { ...

回答 1 投票 0

在 pyspark 数据帧的列值中查找列表的平均值和众数

我有一个 pyspark 数据框,如下所示: +--------------------------+--------------+ |评分|评论| +--------------------------+--------------+ |[83.52, 81.79, ...

回答 2 投票 0

使用极坐标自定义每行转换

我有一个数据集,其中包含使用带有 Polars 的 for 循环的工作解决方案。但是,我想使用内置的 Polars 函数(如 map_elements)来应用创建 var 结构的函数...

回答 1 投票 0

C 中的用户定义函数中的这些返回值是怎么回事?

C 语言中打印用户输入整数的逆序的程序 #包括 int 反转(int x) { int 最后一位数字; 当(x>0)时 { 最后一位=x%10; printf("%d",

回答 1 投票 0

在某些 excel 文件中使用 xlwings 中的 UDF 时遇到“需要对象”问题,而在其他文件中则完全没有问题

我已经在Python中创建了一个UDF并尝试在Excel中使用它。我在某些 excel 文件中的 xlwings 中使用此 UDF 时遇到“需要对象”问题,而在其他 excel 文件中则没有

回答 1 投票 0

创建/注册 PySpark UDF 并将其应用到一列

我只是对如何创建spark udf有点困惑。我现在有一个函数 parse_xml 并执行以下操作: Spark.udf.register(“parse_xml_udf”,parse_xml) parsed_df = xml_df.

回答 1 投票 0

错误6046:无法生成存储函数的函数导入返回类型

我的 SQL 数据库中有一个标量值函数。 将此函数导入实体框架模型时收到此错误: 错误 6046:无法生成...的函数导入返回类型

回答 3 投票 0

将表值 UDF 应用于另一个表中的多行

我有以下UDF: 创建或替换临时函数 sphere_regular_polygon_vertices( lon1 浮子, lat1 浮点数, s 浮动, n 整数 ) 返回表(i 整数、a 浮点、lon2 浮点、l...

回答 1 投票 0

Snowflake 支持 Java UDF 的 JDK 版本是什么?

Snowflake 现在支持 Java UDF: https://medium.com/snowflake/new-in-snowflake-java-udfs-with-a-kotlin-nlp-example-e52d94d33468 如何知道 Snowflake 使用的是哪个版本的 JDK?

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.