概述

本章节内容适用于MRS 3.x及后续版本。

Flink从0.10.0版本开始提供了一套API可以将使用Storm API编写的业务平滑迁移到Flink平台上，只需要极少的改动即可完成。通过这项转换可以覆盖大部分的业务场景。

Flink支持两种方式的业务迁移：

1. 完整迁移Storm业务：转换并运行完整的由Storm API开发的Storm拓扑。
2. 嵌入式迁移Storm业务：在Flink的DataStream中嵌入Storm的代码，如使用Storm API编写的Spout/Bolt。

Flink提供了flink-storm包用来完成上述转换。