Apache Beam で Apache Flink アプリケーション用 Managed Serviceを作成する - Managed Service for Apache Flink
Managed Service for Apache Flink で Apache Beam を使用するビーム機能

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Apache Beam で Apache Flink アプリケーション用 Managed Serviceを作成する

注記

Apache Beam は Apache Flink バージョン 1.19 ではサポートされていません。2024 年 6 月 27 日現在、Flink 1.18 と互換性のある Apache Flink Runner はありません。詳細については、Apache Beam ドキュメントの「Flink バージョンの互換性」を参照してください。＞

「Apache Beam」フレームワークを Apache Flink アプリケーション用 Managed Serviceで使用して、ストリーミングデータを処理できます。Apache Beam を使用する Apache Flink アプリケーション用 Managed Serviceでは、「Apache Flink ランナー」を使用して Beam パイプラインを実行します。

Apache Flink アプリケーション用 Managed Serviceで Apache Beam を使用する方法に関するチュートリアルについては、 Apache Flink CloudFormation 用マネージドサービスとの併用 を参照してください。

このトピックには、次のセクションが含まれています。

Managed Service for Apache Flink で Apache Beam を使用する

Apache Flink 用 Managed Serviceで Apache Flink ランナーを使用する際には、次の点に注意してください。

  • Apache Beam メトリクスは Apache Flink 用 Managed Serviceコンソールでは表示できません。

  • 「Apache Beam は Apache Flink バージョン 1.8 以降を使用する Apache Flink アプリケーション用 Managed Serviceでのみサポートされています。」 「Apache Beam は、Apache Flink バージョン 1.6 を使用する Apache Flink アプリケーション用 Managed Serviceではサポートされていません。」

ビーム機能

Apache Flink のマネージドサービスは、Apache Flink ランナーと同じ Apache Beam 能力をサポートしています。Apache Flink ランナーでサポートされている機能については、「ビーム互換性マトリックス」を参照してください。

Apache Flink 用 Managed Serviceで Apache Flink アプリケーションをテストして、アプリケーションに必要なすべての機能がサポートされていることを確認することをお勧めします。