问题标签 [user-defined-aggregate]

为了获得排序后的聚合字符串，我在下面编写了 CLR 函数。但是，它总是返回空而不是我预期的，就像“001,002,003”一样。我试图在visual studio 2017中调试CLR函数，但抛出了错误信息

操作无法完成。未指定的错误

代码：

我有以下数据框：

我想计算治疗日期/时间[pkey]例如，我有这两行：

治疗日期/时间[DSTECH-55770] = [2013-03-29 13:34:...] - [2013-03-29 13:31:...]

我如何计算与前一个日期的差异，我发现我可以使用用户定义的聚合函数 UDAF 来做到这一点。但是，如果此解决方案对于在数字中显示两个日期之间的差异有用（例如：8h:30min），我并不是说 8H 是在时钟 8H，而是小时数是 8。

如果有人可以帮助我，我该如何使用 UDAF 或者您有其他解决方案？谢谢

在使用 sparkSql UDAF 函数时，我发现我的一些输入列意外地从 null 变为 0。

通过一些 REPL 实践，事实证明行为是 scala 2.10.5。

代码如下

您能否请有 scala 的家人帮助解释幕后发生的原因和情况？

我已经创建并使用了很多次连接值的 SQL CLR 聚合 - 它还按指定的数字对值进行排序，并使用用户输入分隔符来连接它们。

我在大量数据上使用了相同的聚合，并注意到没有使用分隔符 - 值是连接的，但没有分隔符。

经过大量测试，我发现在Terminate方法中，分隔符丢失/未读取。我使用硬编码分隔符仔细检查了这一点 - 一切正常。

我猜我的ReadandWrite方法有问题（在处理大量数据时使用）但无法理解是什么。

这是功能代码：

我正在使用 mariadb 10.3.9，并创建了一个用户定义的聚合函数 (UDAF) 并放置在 common_schema 中。此架构包含我的实用程序函数，供同一服务器上的其他架构/数据库使用。

问题是在使用任何其他模式时调用 UDAF 时，它总是返回 NULL！

下面是为了演示这个问题：

现在，以这种方式调用它，按预期返回结果：

使用任何其他模式调用它，它返回 NULL：

我在这里错过了什么吗？是否缺少任何配置？

感谢你的帮助。

我已经建立了一个自定义聚合

用 edmx 写的：

创建了这个类：

执行

并得到这个错误：

System.NotSupportedException: 'em_PriceTrackerModel.Store.MySqlFunctions' 类型上的指定方法 'Single Median(System.Collections.Generic.IEnumerable`1[System.Single])' 无法转换为 LINQ to Entities 存储表达式，因为它的返回类型与其 DbFunction 属性指定的函数的返回类型不匹配。

我做错了什么？

编写一个聚合来计算数字 40 在列中出现的次数。

使用您的聚合来计算目录表中 40 岁的人数。

这就是我正在做的事情：

我正在比较我的自定义 CLR 聚合与 AVG (SQL Server 2017)。我的查询是：

而CLR是

但是，执行计划完全不同。CLR 查询执行行模式排序，而 AVG 查询执行批处理模式哈希匹配。如何使 CLR 聚合表现得像 AVG 一样？

这是我想到的一个示例。当您使用聚合函数查询 tbl 时，您应该是这个 Result

Tally 聚合函数

SQL：

结果：

我对 C# 很陌生，所以如何创建它并使用 dll？

我正在考虑实施 a UserDefinedAggregateFunctionin spark 并看到 abufferSchema是必需的。我了解如何创建它，但我的问题是为什么它需要 bufferSchema？它不仅需要一个大小（用于聚合的元素数量）、一个 inputSchema 和一个 dataType 吗？bufferSchema 不是将其限制UserDefinedTypes在 sql 的中间步骤中吗？