当前位置: 首页 > 知识库问答 >
问题:

Apache Storm并行是如何工作的?

边浩波
2023-03-14
    null

共有1个答案

邢皓
2023-03-14
  1. 考虑到上述情况,我们的包含值4的元组有可能由A处理,而另一个包含值6的元组有可能由B处理。

是的。

看情况.您很可能控制了spout中的元组序列。如果序列很重要,那么最好减少并行性,或者使用字段分组,以确保相互依赖的元组进入同一个执行器。如果序列无关紧要,则使用shuffleGrouping或localOrShuffleGrouping从并行处理中获得好处。

 类似资料:
  • 在使用流进行聚合时,Brian Goetz将使用stream.collect()填充集合与使用stream.foreach()进行相同的操作进行了比较,其中有以下两个片段: 根据我的理解,只有在流是并行的情况下,多个线程才能在forEach()中工作。但是,在给出的示例中,forEach()是在一个顺序流上操作的(没有调用parallelStream())。 那么,是forEach()总是并行工作

  • 应用程序具有上下文路径-->/spring-form-simple-project 因此,为了访问,我使用: 这个控制器又返回student.jsp,当提交这个student.jsp时,它用-->@RequestMapping(value=“/AddStudent”,method=RequestMethod.post)调用controller 任何关于这通常如何工作的指示都将是有帮助的。 谢谢!

  • 我正在为 Elasticsearch 编写一个 Kafka Sink 连接器。 我实现了启动,把,刷新,关闭方法在Sink任务类。 但是,我不知道Kafka Sink Connector的行为到底起什么作用。 如果Connect Worker重复执行所有这些任务,即通过< code>put()方法从Kafka代理获取SinkRecord,在内部对其进行处理,然后将数据发送到Elasticsearc

  • 本文向大家介绍hibernate 是如何工作的?相关面试题,主要包含被问及hibernate 是如何工作的?时的应答技巧和注意事项,需要的朋友参考一下 读取并解析配置文件。 读取并解析映射文件,创建 SessionFactory。 打开 Session。 创建事务。 进行持久化操作。 提交事务。 关闭 Session。 关闭 SessionFactory。

  • 我很想知道谷歌应用商店服务中的Activity认可是如何工作的? 我认为活动是通过加速计数据识别的。是这样吗?。请告诉我详细情况如何

  • 我对GridBagLayout这一主题不熟悉,我无法理解约束、重量和填充之间的确切区别。 我可以而不分配。 除非您指定了至少一个非零值,否则所有组件都会聚集在其容器的中心。这是因为当权重为0.0(默认值)时,GridBagLayout会在其单元格网格和容器边缘之间放置任何额外的空间。 我的问题是,如果这是真的,那么为什么组件之间没有空间,它们看起来是连接的?