apache flink中的处理是什么意思？答案

【问题标题】：What does mean processing in apache flink?apache flink中的处理是什么意思？
【发布时间】：2019-09-18 20:42:35
【问题描述】：

我对 apache Flink 中的处理概念有疑问。说到 apache Flink 中的处理，这个过程涉及到什么？有没有这样的例子？

【问题讨论】：

【解决方案1】：

Flink 附带了一堆示例，online training 中还有更多完整示例。

基本架构涉及一组有状态的处理节点——您可能会首先将其视为共享键值存储。实时数据流正在通过这些节点。您的业务逻辑正在更新集群中保存的状态以响应这些数据流，并且它们的输出受到此状态的影响。

典型用例：ETL、欺诈/异常检测、拼车平台、物流管理。

Flink 可以大规模运行，具有低延迟和高吞吐量。像这样关于 Lyft 动态定价的演讲应该有助于在实际应用程序的上下文中理解重要的想法：https://www.ververica.com/resources/flink-forward-san-francisco-2019/streaming-your-lyft-ride-prices

【讨论】：

感谢您的回复。但是我还是不明白被处理是什么意思。假设我从 Instagram 获取数据并转到 Apache Flink。然后它进入我的数据库。 Apache Flink 对我的 Instagram 数据进行了哪些处理？
随心所欲。例如，也许您使用 Flink 对每个 Instagram 帖子应用图像分类器，并将图像 URL 和一个字符串标签存储在数据库中，指示该帖子是风景、肖像、合影等。
比如可以高速打标签数据吗？或者可以用 Apache Flink 和高速完成数据搜索吗？
是的。我已经更新了我的答案，包括一个应该感兴趣的谈话链接。