台分のパワーが必要であるとします。しても、処理は続行されます。ストリーム処理アプリケーションで実行する必要のあるデータ処理の計算ロジックを定義するものです。トポロジーは、ストリーム(エッジ)によって接続されたストリームプロセッサー(ノード)を図式するものです。通じてトポロジーを定義できます。ドキュメントでは、トポロジーについてより詳しく説明しています。つの処理ステップを表します。データの変換に使用されます。初期設定時から使用できるストリームプロセッサーです。つの入力レコードを受け取り、操作を適用します。以上の出力レコードをダウンストリームプロセッサーに生成する場合もあります。初心者の方にはこちらをお勧めします。コードで表すことができます。組み込み操作を使用します。高い柔軟性が提供されますが、手動のコーディング作業もより多く必要になります。と直接やり取りしたりできます。ステートフルなストリーム処理¶ストリーム処理アプリケーションの中には、ステートを必要としないものがあります。つのメッセージの処理が、他のメッセージの処理から独立していることを意味します。つのメッセージしか変換しない場合や、ある条件に基づいてメッセージを除外する場合が該当します。あり、正常に動作するためにはステートが必要です。管理する必要があります。行う必要がある場合、そのアプリケーションはステートフルです。強力かつ柔軟で拡張性が高く、フォールトトレンラントなステートフル処理機能をアプリケーションに提供します。最新の顧客情報を追加して補完することがよくあります。ストリームはどこにでも存在しますが、データベースもあらゆる場所に存在しています。提供する必要があります。コアの抽象化を通して、このような機能を提供しています。この抽象化については後で説明します。