从flink群集外部访问flink状态的方法是什么？

Question

我是Apache flink的新手，并构建了一个简单的应用程序，从中读取运动学流中的事件，诸如此类]

TestEvent{
 String id,
 DateTime created_at,
 Long amount
} 
以amount为键的流上面的字段id上的[执行聚合（总和）]。转换等效于SQL select sum(amount) from testevents group by id，其中testevents是到目前为止收到的所有事件。汇总结果以flink状态存储，我希望通过API公开结果。有什么办法吗？

PS：我们可以将flink状态存储在dynamoDB中并在其中创建API吗？还是其他任何可以使国家暴露于外界的方式？

我是Apache flink的新手，正在构建一个简单的应用程序，在该应用程序中，我从运动学流中读取事件，例如TestEvent {String id，DateTime created_at，Long amount} ...

Answer 1

我建议现在暂时忽略状态，而将接收器视为流应用程序输出结果的主要方式。