Flink SQL 是否支持并行运行投影
我正在运行一个具有多个投影的SQL，每个投影都很耗时，例如：
SELECT UDF1(id), UDF2(id)
FROM prod
UDF1 和 UDF2 可能是耗时的功能，但看起来 Flink SQL 按顺序运行 UDF1 和 UDF2，我的问题是 UDF1 和 UDF2 是否可以并行运行以减少延迟？
共有1个答案
不支持在不同线程中并行计算标量 UDF。
然而，这可能是一个有趣的特性。请创建一个Jira问题或在Flink的开发人员邮件列表上开始讨论。
-
问题内容： 我们有几个数据模式，我们研究了向Liquibase的迁移。（其中一种数据模式已经迁移到Liquibase）。 对我们来说重要的问题是Liquibase是否支持空运行： 我们需要在所有架构上运行数据库更改而无需提交，以确保我们没有问题。 如果成功，则所有数据库更改都将再次通过提交运行。 答案后添加 我阅读了有关updateSQL的文档，但它不能满足“快速运行”的要求。它只是生成SQL（在
-
所以，如果我们只想在Liferay startup上运行一些东西，我们可以使用其他一些答案中描述的技术，比如下面。然而，为了使用OS管理表达式来表达自己，它提供了“自动运行”功能。每次启动Liferay时，此代码都会运行。这对于portlet初始化和其他工作非常有用，每次启动Liferay时都需要执行这些操作。 但是，我想知道的是，Liferay中是否有“运行一次”功能？那么，有没有一种方法可以指
-
我试图在本文之后创建一个简单的应用程序，但我无法获得节点Lambda函数来查找dynamodb-geo包。 以下是我的资料： Lambda抛出的错误是： START RequestId:5D40D132-040F-447D-BD76-35C4CEC0236A版本:$Latest 2019-10-05T10:04:24.719Z未定义错误未捕获异常{“ErrorType”：“Runtime.Impo
-
问题内容： 我知道，现在大多数处理器都有两个或多个内核，因此多核编程非常流行。有在Java中利用此功能的功能吗？我知道Java有一个Thread类，但是我也知道这是在多核流行之前的很长时间了。如果我可以使用Java中的多个内核，我将使用什么类/技术？ 问题答案： Java是否支持多核处理器/并行处理？ 是。它还是其他编程语言的平台，在该平台上，实现增加了“真正的多线程”或“真正的线程”卖点。在较新
-
我对测试有点陌生（吓人，嗯），所以如果这是无知的话，请原谅我。 根据对测试框架所做的更改，spock spring 0.7-groovy-2.0是否与新的spring 3.2版本兼容？ 我已经查看了正在测试的Spring 3.2文档： 以及新闻下的斯波克文档： 但是，没有任何东西可以帮助我判断新的Spring3.2测试框架是否仍然允许以Spring3.2测试（Spring3.2文档第11.3.4节
-
问题内容： 因此，我希望将其转换为这样的Java代码： JAXB是否可能？ 曾经看到一些WebService Client存根生成器正在执行此操作，但也许不确定axis2 Webservice。 问题答案： 的 JAXB（JSR-222） 规范没有盖产生快速失败逻辑到域模型。现在，一种常见的做法是以注释（或XML）的形式表示验证规则，并对它们进行验证。 Bean验证（JSR-303） 对此进行了标