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

在Flink中分裂流

公西繁
2023-03-14

如果我想在Flink中分裂一个流,那么最好的方法是什么?

共有1个答案

云弘壮
2023-03-14

侧输出通常是分割流的首选方式。它们的优点是能够将一个流以N种方式分割成不同类型的流,并且具有出色的性能

还有另一种方法可以拆分您没有提到的流,那就是通过拆分和选择。不建议使用拆分/选择。这个实现有点麻烦,而且性能也不是很好。

 类似资料:
  • 只是为了澄清事情,我知道正确的代码是: 但我的问题是关于“错误”代码的内部工作。拉库是怎么得出那个结果的?

  • 我试图了解是如何工作的,以及拆分器是如何设计的。我认识到可能是更重要的方法之一,但是当我看到一些第三方实现时,有时我看到他们的拆分器无条件地为返回null。 问题: 普通迭代器和无条件返回null的拆分器有何不同?这样的分裂者似乎违背了分裂的目的

  • 本文向大家介绍SQL 分裂,包括了SQL 分裂的使用技巧和注意事项,需要的朋友参考一下 示例 使用字符分隔符拆分字符串表达式。请注意,这STRING_SPLIT()是一个表值函数。 结果:            

  • 由于sstables是不可变的,因此必须离线执行sstable拆分,即关闭节点。在保持节点在线的同时,在短时间重新启动节点期间,用一组分割的sstable文件交换极端sstable,以最大限度地减少节点停机时间? 或者,淘汰一个节点,将数据分散到集群的其余部分,然后作为一个新的空节点重新加入,这样会更好吗 例如,有一些大的表不会很快进入压缩视图。我想在另一个盒子上的另一个目录/FS/中进行这样的离

  • 在第二种聚合物的情况下,它将是'b'而不是'a'。当然,如果选择了最终的聚合物,则翻转的定义如下 A[127]=2*A[126]+A[127] 需要注意的是,由于翻转,位置将改变为2、0或-2。 不管怎么说,现在我的问题是,平衡距离比应该的要高得多。理想情况下,我被告知它应该是0,或者最大可能是2和4。比这更大的可能性是微乎其微的。但我的代码经常给出22、30等值。谁能告诉我怎么了?请随时要求进一

  • 我使用preg_split正则表达式将句子拆分成数组。我能够成功地做到这一点。然而,我告诉preg_replace查找的模式的一部分是文本本身的一部分。所以部分文字也被删除了。有没有办法把模式重新插入数组?例如,如果我告诉preg_spit搜索一个句点和其后的一个大写字母,它将从数组中删除这个大写字母,这是我不想要的。 这是代码: 示例字符串: 这是第一句。这是第二句吗?这是第三句!这是第四句:这