Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
Managed Service for Apache Flink の Java の例
次の例は、Java で記述されたアプリケーションを作成する方法を示しています。
注記
ほとんどの例は、ローカル、開発マシン、IDE任意の 、Amazon Managed Service for Apache Flink の両方で実行されるように設計されています。これらは、アプリケーションパラメータを渡すために使用できるメカニズムと、両方の環境でアプリケーションを実行するための依存関係を正しく設定する方法を示しています。
この例では、 を使用して Kinesis データストリームから読み取り、別の Kinesis データストリームに書き込むシンプルなアプリケーションを示していますDataStreamAPI。この例では、ファイルを正しい依存関係でセットアップし、uber- を構築しJAR、設定パラメータを解析する方法を示しています。これにより、アプリケーションをローカル、 でIDE、Amazon Managed Service for Apache Flink で実行できます。
コードの例: GettingStarted
この例では、 TableAPIと を使用したシンプルなアプリケーションを示していますSQL。をSQL同じ Java アプリケーションで TableAPIまたは DataStreamAPIと統合する方法を示します。また、DataGenコネクタを使用して Flink アプリケーション自体内からランダムなテストデータを生成する方法を示し、外部データジェネレーターは必要ありません。
完全な例: GettingStartedTable
この例では、 DataStream APIの FileSink を使用して S3 バケットにJSONファイルを書き込む方法を示しています。
コード例: S3Sink
この例では、標準コンシューマーまたは を使用して Kinesis データストリームから消費するソースを設定する方法とEFO、Kinesis データストリームにシンクを設定する方法を示します。
コードの例: KinesisConnectors
この例では、Amazon Data Firehose (以前は Kinesis Data Firehose と呼ばれていました) にデータを送信する方法を示しています。
コードの例: KinesisFirehoseSink
この例では、 の 4 DataStream 種類のウィンドウ集約を示していますAPI。
-
処理時間に基づくスライディングウィンドウ
-
イベント時間に基づくスライディングウィンドウ
-
処理時間に基づくタンブリングウィンドウ
-
イベント時間に基づくタンブリングウィンドウ
コード例: ウィンドウ処理
この例では、カスタムメトリクスを Flink アプリケーションに追加し、 CloudWatch メトリクスに送信する方法を示します。
コードの例: CustomMetrics
この例では、Kafka 設定プロバイダーを使用して、Kafka コネクタの mTLS 認証用の証明書を使用してカスタムキーストアと信頼ストアを設定する方法を示しています。この方法では、Amazon S3 から必要なカスタム証明書をロードし、アプリケーションの開始時のシークレット AWS Secrets Manager をロードできます。
この例では、Kafka 設定プロバイダーを使用して Amazon S3 から認証情報を取得し AWS Secrets Manager 、信頼ストアをダウンロードして Kafka コネクタでセットアップSASL/SCRAM認証を行う方法を示しています。この方法では、Amazon S3 から必要なカスタム証明書をロードし、アプリケーションの開始時のシークレット AWS Secrets Manager をロードできます。
