在Apache Flink中注册聚合UDF
我正在尝试按照此处的步骤创建一个基本的 Flink 聚合 UDF。我已经添加了依赖项（）并实现了
public class MyAggregate extends AggregateFunction<Long, TestAgg> {..}
我已经实现了强制方法和其他一些方法:< code>accumulate，merge等。所有这些构建都没有错误。根据文件，我应该可以注册为
StreamExecutionEnvironment sEnv = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment sTableEnv = StreamTableEnvironment.getTableEnvironment(sEnv);
sTableEnv.registerFunction("MyMin", new MyAggregate());
但是，ynsterFucntion似乎只需要ScalarFunction作为输入。我收到一个不兼容的类型错误：类型Table环境中的方法ynsterFunction（String， ScalarFunction）不适用于参数（String， MyAggregate）
任何帮助都会很好。
共有1个答案
您需要为您选择的语言导入StreamTable环境，在您的情况下是org.apache.flink.table.api.java.StreamTableEnvironment。
< code > org . Apache . flink . table . API . StreamTableEnvironment 是< code > StreamTableEnvironment 的Java和Scala变体的通用抽象类。我们注意到API的这一部分让用户感到困惑，我们将在未来改进它。
-
抱歉，如果已经问过了，但一直潜伏在SO周围，找不到任何适合我需要的东西。 基本上，我在使用ES的第一次快速尝试中试图实现的是在术语聚合中添加更多计数器。 快速尝试一下，我将以下请求发送给ES。 我现在得到的只是样本在文档中显示的内容。 但是，我真的不知道如何在桶中包含更多的内部聚合。会导致这样的文档的东西。 我应该如何构造聚合，以便按桶包含这些聚合？
-
问题内容： 我有一个非常庞大的查询，其最简单的形式如下所示： 我需要再添加一个条件，该条件可以让我获得每个代表的应用程序日期不为空的用户数（例如：rep 1具有3个用户的应用程序日期已填写），并将其分配给类别（由于3个用户，rep是某个状态类别）。看起来像这样： 但是，如果我只是将其添加到select语句中，则所有代表将变为status1，因为sum（）是在所有使用申请日期的顾问程序上完成的： 您
-
我正在了解Confluent的模式注册表，以满足所有模式管理需求。 我不太理解他们的版本控制方法...有一个的概念，我将其视为一个名称空间。据我所知，subject在模式注册表中必须是唯一。 然后是模式id，或者只是，它也是唯一的。 最后，还有一个。 以下是文档中的片段： :此主题的架构版本，每个主题从1开始 :全局唯一的架构版本id，在所有主题中的所有架构中都是唯一的 因此，一旦我想修改特定主题
-
我想设置一个由多个步骤组成的用户注册。每个步骤将以条的形式突出显示。深灰色条将是完成的步骤，浅灰色条将是需要完成的步骤。似乎想不出这样做的方法。请建议。 我们可以在myfitnesspal注册中看到这一点。我在下图的红色框中突出显示了这一点。
-
Nacos 作为 Dubbo 生态系统中重要的注册中心实现，本文将会介绍如何进行 Dubbo 对接 Nacos 注册中心的工作。 预备工作 请确保后台已经启动 Nacos 服务，可先行参考 Nacos 快速入门。 快速上手 Dubbo 融合 Nacos 成为注册中心的操作步骤非常简单，大致步骤可分为“增加 Maven 依赖”以及“配置注册中心“。 增加 Maven 依赖 只需要依赖Dubbo客户端
-
我现在一直在查看Spring Cloud模式注册表和汇合模式注册表。我可以看到一些区别，例如Spring Cloud模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而汇合模式注册表保存在kafka主题中。 spring云模式注册表的这种方法是否会对性能产生任何影响。据我所知，即使数据保留在主题上，以防汇合，查询它时仍然会有延迟。但会有重大影响吗？ 我还可以看到，spring云模式注册表