user-defined-functions 相关问题

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

具有行输入类型的Snowpark UDF

我想定义一个输入类型为snowflake.snowpark.Row的Snowpark UDF。 这样做的原因是我想模仿 pandas.apply 方法 我可以在其中定义我的业务逻辑

回答 1 投票 0

pyspark udf 函数存储不正确的数据,尽管函数产生正确的结果

所以我有这个奇怪的问题。我正在使用一个巨大的数据集,其中的日期和时间由单个字符串表示。这些数据可以使用 datetime.strptime() 轻松转换,但问题是......

回答 1 投票 0

文档中的简单 UDF 应用函数在 Spark 3.3 中失败

最新文档中的这个简单代码不适用于 EMR Studio Spark 集群(当前版本:3.3.1-amzn-0) df = Spark.createDataFrame( [(1, 1.0), (1, 2.0), (2, 3.0), (2, 5.0), (2, 10.0)...

回答 1 投票 0

Spark中如何获取数组列的所有组合?

假设我有一个数组列group_ids +--------+----------+ |用户id|组id| +--------+----------+ |1 |[5, 8] | |3 |[1, 2, 3] | |2 |[1, 4] | +--------+----------+ 架构: ...

回答 4 投票 0

如何使用 RDD 函数以更有效的方式执行此 groupBy + agg?

假设我创建了一个像这样的新数据框 随机导入 导入字符串 数据 = [] 对于范围(100_000)内的 i: rid = string.ascii_uppercase[random.randint(0, len(string.ascii_uppercase) - 1)] ...

回答 2 投票 0

计算pyspark数据框中的地理距离

我的数据框: DF = Spark.createDataFrame([[114.038696, 22.5315, 114.047302, 22.531799], [ 114.027901, 22.5228, 114.026299, 22.5238], [ 114.026299, 22.5238,1 14.024597,22.5271], [114.024597, 22.52...

回答 1 投票 0

如何在Clickhouse中使用C集成Rust UDF?

有一个 C 语言的 UDF 主程序 #包括 #包括 #包括 extern char *u_shape_processor(char*camps_list_c); void Replacechar(char *s,char c1,char c2) ...

回答 1 投票 0

如何在Clickhouse中集成C UDF?

有一个 C 语言的 UDF 主程序 #包括 #包括 #包括 extern char *u_shape_processor(char*camps_list_c); void Replacechar(char *s,char c1,char c2) ...

回答 1 投票 0

PostgreSQL 错误:执行 SELECT ... INTO 未实现

当我从我定义的函数运行以下命令时,出现错误“EXECUTE of SELECT ... INTO 未实现”。这是否意味着不允许使用特定命令(即“SELECT ...INTO...

回答 2 投票 0

Scylladb中WASM+UDF性能对比,为什么没有明显差异?

我在wasm中编写了一个add函数来测试Scylladb中WASM的性能,同时我用lua编写了add函数来比较性能。不过,没有明显区别

回答 1 投票 0

从Snowflake仓库访问互联网或公共网络:对于UDF

我在 Snowflake SQL 中创建了一个 Python UDF(点击此链接),它调用我公司编写的应用程序的 python 代码。 python 代码需要公共互联网访问权限...

回答 2 投票 0

解压base64编码、gzip压缩的JSON

我在 Snowflake 二进制列中获得了 Base64 编码、gzip 压缩的 json,我正在尝试解包。 随着查询: 选择 base64_encode(my_binary_data) 作为 my_base64_string 来自我的表 我得到了一个 ba...

回答 2 投票 0

100 是 SELECT * FROM [多语句表值函数] 查询的基数估计的幻数吗?

我在 SQL Server 2019 上运行。每当我编写 SELECT * FROM [Multi-Statement-Table-Valued-Function] 形式的查询时,执行计划显示它预计从此过程中获取 100 行。 ..

回答 1 投票 0

Pyspark:在 pandas_udf 中传递多列

我的问题与此类似,但我需要使用 pandas_udf 而不是 udf。 我有一个包含许多列的 Spark 数据框(列数各不相同),我需要对它们应用自定义函数...

回答 1 投票 0

在 SQL Server 上使用用户定义的表类型时发生操作数类型冲突

我创建了一个用户定义的类型(带有用于创建的脚本),如下所示: 创建类型 [dbo].[udt_ProductID_SellingPrice] AS TABLE( [Product_Id] [int] NOT NULL, [销售价格] [金额] NULL, ...

回答 2 投票 0

在表值函数中声明变量

如何在表值函数中声明变量?

回答 2 投票 0

如何构造具有多输出功能的DolphinDB SQL语句?

我想定义一个UDF来计算一个特定列的不同指标。我可以在 SQL 语句中使用这样的多输出函数吗?例如: tb=表(1 2 3 为`a, 1 1 2 为`b) 绝对专业...

回答 1 投票 0

FillRow 方法的 CLR 表值函数参数计数错误

我有一个 C# (.NET Framework 4.7.2) 脚本来执行一些跟踪代码的自定义读取,我试图用它来创建 SQL (V14.0.3445.2) 表值函数。 C# FillRow 方法看起来像...

回答 1 投票 0

使用 Excel 中的单元格公式计算完成潜力

我正在尝试定义一个单元格内公式来计算 Excel 中的潜在交易完成率。我很难找到解决方案,我希望有人可以提供一些指导,如果......

回答 1 投票 0

Clickhouse UDF 未按预期传递参数

我在Clickhouse中创建了UDF,例如: 创建函数 test_function AS (in_param) -> (select col1 from table1 t1 join table2 t2 on t1.key=t2.key where t1.key = in_param); 效果很好...

回答 1 投票 0

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