構造化ストリーミングの概要について説明します。トレランスを提供する、リアルタイムに近い処理エンジンです。データに対する計算を表現できます。データが到着すると結果を継続的に更新します。データストリームから読み取る構造化ストリーミングを使用して、サポートされているデータソースからデータを段階的に取り込むことができます。一般的なデータソースには、次のものがあります。クラウドオブジェクトストレージ内のデータファイル。Loaderとは」を参照してください。メッセージバスとキュー。ストリーミングデータソースの設定を参照してください。ストリーミングの読み取りと書き込みを参照してください。各データソースには、データのバッチをロードする方法を指定するためのオプションがいくつか用意されています。リーダーの設定中に、次の操作を行うためのオプションの設定が必要になる場合があります。(ポート設定や資格情報など)。オフセットやすべての既存ファイルの読み取り)。サイズを構成する」を参照してください。データシンクへの書き込みデータシンクは、ストリーミング書き込み操作のターゲットです。Databricksストリーミングワークロードで使用される一般的なシンクには次のものがあります。Lakeメッセージバスとキューキー値のデータベースデータソースと同様に、ほとんどのデータシンクには、ターゲットシステムへのデータの書き込み方法を制御するためのオプションが多数用意されています。ライターの構成時に、次のオプションを指定します。出力モード(デフォルトでは追加)。「構造化ストリーミングの出力モードを選択する」を参照してください。ライターごとに必要)。構造化ストリーミング・チェックポイントを参照してください。構造化ストリーミングのトリガー間隔の設定を参照してください。データシンクまたは形式(ファイルタイプ、区切り文字、スキーマなど)を指定するオプション。ターゲットシステムへのアクセスを構成するオプション(ポート設定や資格情報など)。Foundationの商標です。フィードバックの送信|プライバシーポリシー|。