Amazon Managed Service for Apache Flink (Amazon MSF) は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
Amazon Managed Service for Apache Flink 入門 (Table API)
このセクションでは、Managed Service for Apache Flink の基本概念、ならびに Table API および SQL を使用した Java でのアプリケーションの実装について紹介します。同じアプリケーション内で異なる API に切り替える方法を示し、アプリケーションの作成およびテストに使用できるオプションについて説明します。また、このガイドのチュートリアルを完了し、初めてアプリケーションを作成するのに必要なツールのインストール方法についても説明します。
トピック
Managed Service for Apache Flink アプリケーションのコンポーネントを確認する
注記
Managed Service for Apache Flink では、すべての Apache Flink API
データを処理するため、Managed Service for Apache Flink アプリケーションでは、Apache Flink ランタイムを使用して入力を処理し、出力を生成する Java アプリケーションが使用されます。
通常の Apache Flink アプリケーションには、次のコンポーネントがあります。
-
ランタイムプロパティ: コードを変更して再発行せず、ランタイムプロパティ を使用し、設定パラメータをアプリケーションに渡すことができます。
-
ソース: アプリケーションは 1 つ以上のソースからデータを消費します。ソースはコネクタ
を使用して、Kinesis データストリームや Amazon MSK トピックなどの外部システムからデータを読み込みます。開発またはテストでは、ソースがランダムにテストデータを生成するようにできます。詳細については、「Managed Service for Apache Flink にストリーミングデータソースを追加する」を参照してください。SQL または Table API を使用すると、ソースはソーステーブルとして定義されます。 -
変換: アプリケーションは、データをフィルタリング、強化、集計できる 1 つ以上の変換を通じてデータを処理します。SQL または Table API を使用すると、変換はテーブルに対するクエリまたはビューとして定義されます。
-
シンク: アプリケーションはシンクを通じて外部システムにデータを送信します。シンクはコネクタ
を使用して、Kinesis データストリーム、Amazon MSK トピック、Amazon S3 バケット、リレーショナルデータベースなどの外部システムにデータを送信します。特別なコネクタを使用して、開発目的としてのみ出力データを出力することもできます。SQL または Table API を使用すると、シンクは結果を挿入するシンクテーブルとして定義されます。詳細については、「Managed Service for Apache Flink でシンクを使用してデータを書き込む」を参照してください。
アプリケーションには、アプリケーションが使用する Flink コネクタ.(場合によっては Java ライブラリ) などの外部依存関係が一部必要です。Amazon Managed Service for Apache Flink を実行するには、アプリケーションを fat-JAR で依存関係と一緒にパッケージ化し、Amazon S3 バケットにアップロードする必要があります。次に、Apache Flink アプリケーション用 Managed Serviceを作成します。コードパッケージの場所は、他のランタイム設定パラメータと一緒に渡します。このチュートリアルでは、Apache Maven を使用してアプリケーションをパッケージ化し、選択した IDE でアプリケーションをローカルで実行する方法が示されます。
必要な前提条件を完了する
このチュートリアルを開始する前に、Amazon Managed Service for Apache Flink (DataStream API) の概要 の最初の 2 つのステップを完了してください。
開始するには、 アプリケーションの作成 を参照してください。
次のステップ
