Apache Flink是一个用于可扩展批处理和流数据处理的开源平台。 Flink在一个系统中支持批量和流分析。分析程序可以用Java和Scala中简洁优雅的API编写。
我的flink程序应该对每个输入记录进行Cassandra查找，并根据结果进行一些进一步的处理。但我目前仍在阅读Cassandra的数据。这是......
在阅读了Flink如何管理内存之后，传递给DataSet＃mapPartitions或KeyedWindowedStream #process的输入是否是一个惰性集合仍然不明显。有......
Flink：SocketWindowCount示例的结果不是我的预期
我是陌生人。我按照flink网站上的快速入门，在一台机器上部署flink。在我执行“./bin/flink run examples / streaming / SocketWindowWordCount.jar --port 9000”后输入...
假设我知道我的数据集是不平衡的，我知道密钥的分布。我想利用它来编写自定义分区器以充分利用运算符实例。我知道 ...
我有两个关于Flink检查点策略的问题，我知道检查点与状态有关（对吗？），所以如果我没有在我的工作代码中明确使用状态（ValueState类型的东西），那么我...