各操作がサポートされています。ようなキーを変更する操作が実行された場合、再パーティション化のステップが挿入されます。使用することをお勧めします。これらはキーを変更しないため、再パーティション化のステップを省略できます。値の変更時には、キーへの読み取り専用アクセスが必要になることがよくあります。ともに呼び出すことができます。拡張機能は、他のいくつかの演算子にも用意されています。特殊なケースとして、パーティションが維持される形でキーを変更しようとしているために、実際には再パーティション化の必要がない場合があります。このようなケースでは状況によって、集約の後にキーの変更操作を適用することで、再パーティション化のステップを回避できる可能性があります。属する場合に適用できます。使用してカスタムの集約を実行することができます。これらの操作では、直前の操作でキーが変更されたとしても、自動的に再パーティション化がトリガーされることはありません。自動的に呼び出されます。コードでは、この呼び出しを対応するシリアライザーと逆シリアライザーに転送する必要があります。このパターンが既に実装されています。手動で呼び出す必要があります。オブジェクトの作成直後に行ってください。置き換えるグローバル設定はありません。オペレーターごとに個別にカスタムストアを設定することは可能です。置き換えることができます。操作ごとに提供する必要があります。インメモリーストアも備えています。インメモリーサプライヤーは次のように取得できます。無効にすることもできます。呼び出しを追加します。インターフェイスを実装する必要があります。呼び出されるたびに、実装された独自のストアの新しいインスタンスを返します。サードパーティのストアを統合する場合、フォールトトレランスへの対応はすべて開発者の責任になります。トピックを通じたストアのバックアップは提供されないため、必要に応じて独自に実装する必要があります。アプリケーションからの受信レコードの一部が破損していることや、シリアライザーと逆シリアライザーが誤りやバグを含んでいたり、すべての種類のレコードを処理できなかったりすることがあります。インターフェイスを使用すると、このようなポイズンピルレコードの処理方法をカスタマイズできます。ライブラリには、一般的な処理パターンを表すいくつかの実装も含まれています。これはすべての逆シリアル化例外を処理します。アプリケーションを停止します。使用するように構成されている場合、アプリケーションのインスタンスはフェイルファストとなり、破損レコードを検出すると終了します。破損レコードを検出すると、アプリケーションはエラーメッセージを記録し、そのレコードの処理をスキップして、次のレコードの処理を続行します。いう名前のプロセッサーノードレベルのメトリックに記録されます。