回答情况：
提问时间：
问题标签：
我正在运行5个ksqldb实例(K8s)，每个实例线程(ksql服务器属性) num是3我还有一个问题，我目前正在k8s环境中运行一个ksqldb实例。即使在重新启动的情况下，ksqldb的表聚合数据也能正常工作而不会丢失吗？
浏览 9提问于2022-03-29得票数 0
我认为它需要一个用户定义的聚合函数。
浏览 31修改于2020-04-12得票数 1
回答已采纳
我想安装Vertica 7中预装的UDAF字符串函数，特别是group_concat。
我之前在Vertica 6中安装了这个，但情况似乎有了一些变化。
浏览 0提问于2015-12-15得票数 0
我正在尝试在PySpark中的Spark dataframe上使用一组预定义的sql函数以及我自己的UDAF。df.columns当我尝试将我的自定义函数与其他函数一起使用时Wrap '(avg(CAST(DBN AS DOUBLE)作为窗口函数中的avg(DBN)或将'DBN‘包装在first() (或first_
浏览 3提问于2019-11-15得票数 0
我想将Array作为输入模式传递到一个UDAF中。
我给出的例子非常简单，它只是两个向量之和。实际上，我的用例更复杂，我需要使用一个联新议程。
浏览 0修改于2019-06-01得票数 0
回答已采纳
'groupby_key']
无法调用split函数我想将validation_period作为参数传递给拆分函数。
浏览 5提问于2020-09-21得票数 0
我正在尝试通过PyFlink中的自定义UDAF调用外部函数。我使用的函数要求数据在字典对象中。我尝试使用row(t.rowtime, t.b, t.c).cast(schema)来达到这样的效果。在UDAF之外，这个表达式工作得很好。在UDAF中，此表达式被转换为InternalRow，而不能转换为字典对象。 有没有办法强制使用Row而不是InternalRow？import row, col, lit, row_interval
from pyflink.table.window import Tumb
浏览 43提问于2021-06-18得票数 1
回答已采纳
我正在使用Spark3.0，为了使用用户定义的函数作为窗口函数，我需要一个UserDefinedAggregateFunction实例。最初，我认为使用新的Aggregator和udaf可以解决这个问题(如所示)，但udaf返回的是UserDefinedFunction，而不是UserDefinedAggregateFunction。所以问题是:在Spark3.0中是否有一种正确(不反对)的方法来定义适当的UserDefinedAggregateFunction并将其用作窗口函数？
浏览 3修改于2021-03-26得票数 2
回答已采纳
我正在尝试将"moving median“函数实现为一个窗口函数，以便在Apache Spark SQL中使用它。1)作为SQL查询：...
timeSeries.registerTempTablemetrics_name order by time_column) from time_
浏览 2提问于2016-06-06得票数 2
我想要使一个用户定义的聚合函数在吡火花。我为找到了一些文档，并希望在Python中实现类似的功能。更确切地说，假设我已经实现了这样一个函数： ...# do something very complicated heresource_df.groupBy("Foo_ID").agg(UDAF(process_data))
现在的问题是-我应该用什么来代替UDAF</e
浏览 7提问于2022-09-22得票数 0
我想注册一个UDAF类(用Scala或Python编写)，并在Spark SQL中使用它。例如：// mock code:...然后我可以直接在spark sql中使用udaf，如下所示：
spark.sql("select
浏览 2提问于2019-02-01得票数 1
如何在PySpark SQL中实现用户定义的聚合函数？pyspark version = 3.0.2作为一个最小的例子，我想用一个UDAF替换AVG聚合函数：sqltoPandas()In [2]: rv id avg(value)1 2 3.5rv = sql.sql
浏览 24修改于2021-03-10得票数 4
回答已采纳
我正在使用pyspark 1.5从Hive表中获取数据，并尝试使用窗口函数。
根据的说法，存在一个名为firstValue的分析函数，它将为给定窗口提供第一个非空值。鉴于pyspark不支持UserDefinedAggregateFunctions (UDAF)，有没有办法实现这一点？
浏览 4修改于2017-12-26得票数 6
回答已采纳
2回答
11}]} |
| 2 | {order_id: 2, items: [{item_id: 3, price: 12}, {item_id: 4, price: 13}]} | 最初我认为UDAF可以做到这一点，但当我实现一个聚合器UDAF函数时，我不确定在merge方法中返回什么，因为如果order id不同，它们就不能被合并。
浏览 26修改于2021-09-18得票数 1
我正在编写一个UDAF聚合函数，我想返回一个数据类型，它要么是一个具有列名的结构(例如，开始和结束都是长类型)，要么是2列。
在计算函数中，尝试返回一个映射类型和一个数组，但这不是我所期望的。
浏览 5修改于2017-07-07得票数 1
假设我们在星火中有一个dataset/dataframe，其中有3列ID，Word，Timestampdf.show()
1 | "I am Jessica" | "2017-1-1 00:01" | "2017-1-1 00:03" |
问题是如何确保在我的Words中按正确的顺序合并列UDAF
浏览 0修改于2017-06-06得票数 1
回答已采纳
1|[a -> 2.0, b -> 1.0]|+---+--------------------+ 目前，在Spark 2.4.6中，我能够使用udaf当我碰到Spark3时，我想知道我是否可以摆脱这个udaf (我尝试使用新方法aggregate，但没有成功)。 有没有一种有效的方法来做到这一点？(对于效率部分，我可以很容易地进行测试)
浏览 55提问于2020-10-14得票数 3
回答已采纳
我的UDAF返回一个数组，但我得到的是一个SemanticException，所以这可能并不重要。ADD JAR udaf.jar; sum(i) i, myUDAF(f
浏览 1修改于2016-05-29得票数 0
最近，我使用了UDAF，查看了内置聚合函数collect_list的源代码，发现collect_list没有实现merge方法，尽管我认为这是非常直接的(只是连接两个数组)。
浏览 0提问于2018-02-15得票数 1
回答已采纳
我想为这个逻辑实现一个UDAF。我想把这个叫UDAF -+---+-------++---+-------+| 2|[D,A,C]|我正在尝试写一个UDAF
浏览 0修改于2018-04-05得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号