我对apache flink中的处理概念有问题。当谈到apache flink中的处理时，这个过程涉及什么？有这样的例子吗？
6kkfgxo01#
flink提供了一系列示例，在线培训中还有几个更完整的示例。基本的体系结构包括一个有状态处理节点集群——您可以将其看作一个共享的键值存储。实时数据流正在通过这些节点。集群中的状态由业务逻辑更新以响应这些数据流，并且它们的输出受此状态的影响。典型用例：etl、欺诈/异常检测、共享平台、物流管理。flink可以非常大规模地运行，具有低延迟和高吞吐量。像这样的关于lyft动态定价的讨论应该有助于在实际应用的背景下理解一些重要的想法：https://www.ververica.com/resources/flink-forward-san-francisco-2019/streaming-your-lyft-ride-prices
1条答案
按热度按时间6kkfgxo01#
flink提供了一系列示例，在线培训中还有几个更完整的示例。
基本的体系结构包括一个有状态处理节点集群——您可以将其看作一个共享的键值存储。实时数据流正在通过这些节点。集群中的状态由业务逻辑更新以响应这些数据流，并且它们的输出受此状态的影响。
典型用例：etl、欺诈/异常检测、共享平台、物流管理。
flink可以非常大规模地运行，具有低延迟和高吞吐量。像这样的关于lyft动态定价的讨论应该有助于在实际应用的背景下理解一些重要的想法：https://www.ververica.com/resources/flink-forward-san-francisco-2019/streaming-your-lyft-ride-prices