如何知道在Apache Flink中可以链接哪些操作符
我正在阅读Apache Flink的文档：https://ci.apache.org/projects/flink/flink-docs-stable/concepts/runtime.html.
正如医生提到的，
对于分布式执行，Flink将运算符子任务链接到任务中。每个任务都由一个线程执行。将运算符链接到任务中是一种有用的优化：它减少了线程到线程切换和缓冲的开销，并在减少延迟的同时提高了整体吞吐量。
所以，根据我的理解，知道哪些运算符可以被链接是很重要的。但是我们怎么知道呢？我的意思是，我们怎么知道哪些运算符可以被链接，哪些运算符不能被链接？
例如，在WordCount的示例中，
当我们开始编码时，我们怎么知道Source和map（）可以链接，map（）和keyBy（）/窗口（）/应用程序（）不能链接？
共有1个答案
只要两个操作员通过转发数据连接进行连接，就可以将它们链接起来。换言之，keyBy、再平衡或并行性的改变（这也是一种再平衡）会迫使网络通信，并使运营商链接变得不可能。
-
本文向大家介绍js的哪些操作可以改变作用域链？相关面试题，主要包含被问及js的哪些操作可以改变作用域链？时的应答技巧和注意事项，需要的朋友参考一下 比较有名的是的间接调用：
-
问题内容： TL; DR; 我正在寻找一个可以查找特定中间操作或终端操作的地方。在哪里可以找到此类文档？ 编辑 这不是如何确保java8流中的处理顺序的重复项？，因为该问题未提供完整的操作列表。 该软件包的文件说： 流是否具有遇到顺序取决于源和中间操作 为了确保在整个流操作中维持顺序，您必须研究流源，所有中间操作和终端操作的文档，以了解它们是否维持顺序（或源是否在第一个顺序中具有顺序）地点）。 一
-
从研究中，我发现thunk是一种工具，您可以使用它将动作链接在一起和/或处理回调、异步动作和副作用。 我无法理解thunk中间件指南。他们总是引用store.dispatch（就像大多数关于redux的教程一样），但我从未真正调用调度，也从未访问过商店，所以我不确定如何实现他们提出的任何建议。（我假设这是因为我在反应中使用mapDispatchToProps......这在我的动作创建者文件中不是
-
我在laravel 5中工作，我有一个模块，用户可以在其中更新学生的信息，因为用户有一个带有当前数据的预加载表单，并且可以修改他想要的字段。然后，在控制器中，我执行以下操作： 那工作得很好。所以我的问题是：有一种方法可以获得已经更新的字段的名称？
-
问题内容： 我是新手，所以请保持温柔。 因此，我已经在某些代码中使用互斥锁了几周了。我了解其背后的概念：锁定对特定资源的访问权限，与之交互（读或写），然后为其他人再次解锁。 我使用的互斥锁代码主要是复制粘贴调整。该代码可以运行，但是我仍在努力解决其内部问题。到目前为止，我一直在结构中使用互斥锁来锁定该结构。今天，我发现了这个例子，这使我完全不清楚互斥锁实际上是在锁定什么。以下是一段示例代码： 让我
-
问题内容： 有没有一种方法（在编码时）知道在执行python代码时期望哪些异常？由于不知道会抛出哪种异常类型（并且不要告诉我阅读文档，所以很多时候我都会捕获90％的基础Exception类）。很多时候，异常可以从深处传播出去。次文档未更新或不正确）。有某种工具可以检查吗？（例如通过阅读python代码和库）？ 问题答案： 我猜一个解决方案可能只是不精确，因为缺少静态的输入规则。 我不知道有什么工具