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

# Amazon Managed Service for Apache Flink 入門 (Table API)
<a name="gs-table"></a>

このセクションでは、Managed Service for Apache Flink の基本概念、ならびに Table API および SQL を使用した Java でのアプリケーションの実装について紹介します。同じアプリケーション内で異なる API に切り替える方法を示し、アプリケーションの作成およびテストに使用できるオプションについて説明します。また、このガイドのチュートリアルを完了し、初めてアプリケーションを作成するのに必要なツールのインストール方法についても説明します。

**Topics**
+ [Managed Service for Apache Flink アプリケーションのコンポーネントを確認する](#gs-table-components)
+ [必要な前提条件を完了する](#gs-table-prerequisites)
+ [Apache Flink アプリケーション用 Managed Serviceを作成して実行する](gs-table-create.md)
+ [次のステップ](#gs-table-next-step-4)
+ [AWS リソースをクリーンアップする](gs-table-cleanup.md)
+ [他のリソースを調べる](gs-table-next-steps.md)

## Managed Service for Apache Flink アプリケーションのコンポーネントを確認する
<a name="gs-table-components"></a>

**注記**  
Managed Service for Apache Flink では、すべての [Apache Flink API](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/concepts/overview/#flinks-apis) がサポートされ、場合によってはすべての JVM 言語もサポートされます。選択した API に応じて、アプリケーションの構造および実装が若干異なります。このチュートリアルでは、Table API および SQL を使用したアプリケーションの実装、ならびに Java に実装された DataStream API との統合について説明します。

データを処理するため、Managed Service for Apache Flink アプリケーションでは、Apache Flink ランタイムを使用して入力を処理し、出力を生成する Java アプリケーションが使用されます。

通常の Apache Flink アプリケーションには、次のコンポーネントがあります。
+ **ランタイムプロパティ:** コードを変更して再発行せず、*ランタイムプロパティ* を使用し、設定パラメータをアプリケーションに渡すことができます。
+ **ソース:** アプリケーションは 1 つ以上の*ソース*からデータを消費します。ソースは[コネクタ](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/connectors/table/overview/)を使用して、Kinesis データストリームや Amazon MSK トピックなどの外部システムからデータを読み込みます。開発またはテストでは、ソースがランダムにテストデータを生成するようにできます。詳細については、「[Managed Service for Apache Flink にストリーミングデータソースを追加する](how-sources.md)」を参照してください。SQL または Table API を使用すると、ソースは*ソーステーブル*として定義されます。
+ **変換:** アプリケーションは、データをフィルタリング、強化、集計できる 1 つ以上の変換を通じてデータを処理します。SQL または Table API を使用すると、変換は*テーブルに対するクエリ*または*ビュー*として定義されます。
+ **シンク:** アプリケーションは*シンク*を通じて外部システムにデータを送信します。シンクは[コネクタ](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/connectors/table/overview/)を使用して、Kinesis データストリーム、Amazon MSK トピック、Amazon S3 バケット、リレーショナルデータベースなどの外部システムにデータを送信します。特別なコネクタを使用して、開発目的としてのみ出力データを出力することもできます。SQL または Table API を使用すると、シンクは結果を挿入する*シンクテーブル*として定義されます。詳細については、「[Managed Service for Apache Flink でシンクを使用してデータを書き込む](how-sinks.md)」を参照してください。

アプリケーションには、アプリケーションが使用する Flink コネクタ.(場合によっては Java ライブラリ) などの**外部依存関係**が一部必要です。Amazon Managed Service for Apache Flink を実行するには、アプリケーションを *fat-JAR* で依存関係と一緒にパッケージ化し、Amazon S3 バケットにアップロードする必要があります。次に、Apache Flink アプリケーション用 Managed Serviceを作成します。コードパッケージの場所は、他のランタイム設定パラメータと一緒に渡します。このチュートリアルでは、Apache Maven を使用してアプリケーションをパッケージ化し、選択した IDE でアプリケーションをローカルで実行する方法が示されます。

## 必要な前提条件を完了する
<a name="gs-table-prerequisites"></a>

このチュートリアルを開始する前に、[Amazon Managed Service for Apache Flink (DataStream API) の概要](getting-started.md) の最初の 2 つのステップを完了してください。
+ [演習を完了するための前提条件を満たす](getting-started.md#setting-up-prerequisites)
+ [AWS Command Line Interface (AWS CLI) のセットアップ](setup-awscli.md)

開始するには、 [ アプリケーションの作成](gs-table-create.md) を参照してください。

## 次のステップ
<a name="gs-table-next-step-4"></a>

[AWS リソースをクリーンアップする](gs-table-cleanup.md)