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

この例では、 APIの DataStream を使用して S3 バケットにJSONファイルをFileSink書き込む方法を示します。

コード例: S3Sink

この例では、標準コンシューマーまたはを使用して Kinesis データストリームから消費するソースを設定する方法とEFO、Kinesis データストリームへのシンクを設定する方法を示します。

コード例: KinesisConnectors

この例では、Amazon Data Firehose (以前は Kinesis Data Firehose と呼ばれていました) にデータを送信する方法を示します。

コード例: KinesisFirehoseSink

この例では、の 4 DataStream 種類のウィンドウ集約を示していますAPI。