インターフェース CassandraBatchOperations
public interface CassandraBatchOperations
テーブルに対する挿入 / 更新 / 削除アクションのバッチ操作。
CassandraBatchOperations は、単一のエンティティおよびエンティティのコレクションに対して、ログに記録された Cassandra BATCH を使用します。CassandraBatchOperations インスタンスは、実行後に変更 / 使用することはできません。 バッチはデフォルトでアトミックです。Cassandra バッチ操作のコンテキストでは、アトミックとは、バッチのいずれかが成功すると、すべてが成功することを意味します。バッチ内ではステートメントの順序は関係ありません。CassandraBatchOperations は、指定されている場合は同じ timestamp を使用してすべての行を適用し、指定されていない場合は Cassandra がタイムスタンプを生成します。
マルチパーティションバッチは、異なるテーブルへの少数の書き込みのアトミック性を実現するためにのみ使用してください。それ以外では、コストが高すぎるため使用しないでください。単一パーティションバッチはアトミック性と分離性を実現するために使用できますが、通常の書き込みよりもコストがそれほど高くありません。
- 導入:
- 1.5
- 作成者:
- Mark Paluch, Anup Sabbi
メソッドのサマリー
修飾子と型メソッド説明delete(IterableSE<?> entities) 削除のコレクションをバッチに追加します。delete(IterableSE<?> entities, WriteOptions options) 指定されたWriteOptionsを持つ削除のコレクションをバッチに追加します。削除の配列をバッチに追加します。default CassandraBatchOperationsdelete(ObjectSE entity, WriteOptions options) バッチに削除を追加します。execute()バッチを実行します。insert(IterableSE<?> entities) 挿入のコレクションをバッチに追加します。insert(IterableSE<?> entities, WriteOptions options) 指定されたWriteOptionsを持つ挿入のコレクションをバッチに追加します。挿入の配列をバッチに追加します。default CassandraBatchOperationsinsert(ObjectSE entity, WriteOptions options) バッチに挿入を追加します。update(IterableSE<?> entities) 更新のコレクションをバッチに追加します。update(IterableSE<?> entities, WriteOptions options) 指定されたWriteOptionsを持つ更新のコレクションをバッチに追加します。バッチに更新の配列を追加します。default CassandraBatchOperationsupdate(ObjectSE entity, WriteOptions options) バッチに更新を追加します。withTimestamp(long timestamp) 指定されたtimestampをバッチ全体に適用します。
メソッドの詳細
execute
WriteResult execute()バッチを実行します。バッチは 1 回だけ実行できます。- 戻り値:
- 一括操作用の
WriteResult。 - 例外:
IllegalStateExceptionSE- バッチがすでに実行された後に実行される場合。
withTimestamp
指定されたtimestampをバッチ全体に適用します。- パラメーター:
timestamp- 適用するタイムスタンプ。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。
insert
バッチに挿入を追加します。- パラメーター:
entity- 挿入するエンティティ。null であってはなりません。options- 適用する WriteOptions。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。- 導入:
- 3.2.2
insert
挿入の配列をバッチに追加します。- パラメーター:
entities- 挿入するエンティティ。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。
insert
挿入のコレクションをバッチに追加します。- パラメーター:
entities- 挿入するエンティティ。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。
insert
指定されたWriteOptionsを持つ挿入のコレクションをバッチに追加します。- パラメーター:
entities- 挿入するエンティティ。null であってはなりません。options- 適用する WriteOptions。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。- 導入:
- 2.0
- 関連事項:
update
バッチに更新を追加します。- パラメーター:
entity- 更新するエンティティ。null であってはなりません。options- 適用する WriteOptions。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。- 導入:
- 3.2.2
update
バッチに更新の配列を追加します。- パラメーター:
entities- 更新するエンティティ。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。
update
更新のコレクションをバッチに追加します。- パラメーター:
entities- 更新するエンティティ。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。
update
指定されたWriteOptionsを持つ更新のコレクションをバッチに追加します。- パラメーター:
entities- 更新するエンティティ。null であってはなりません。options- 適用する WriteOptions。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。- 導入:
- 2.0
- 関連事項:
delete
バッチに削除を追加します。- パラメーター:
entity- 削除するエンティティ。null であってはなりません。options- 適用する WriteOptions。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。- 導入:
- 3.2.2
delete
削除の配列をバッチに追加します。- パラメーター:
entities- 削除するエンティティ。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。
delete
削除のコレクションをバッチに追加します。- パラメーター:
entities- 削除するエンティティ。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。
delete
指定されたWriteOptionsを持つ削除のコレクションをバッチに追加します。- パラメーター:
entities- 削除するエンティティ。null であってはなりません。options- 適用する WriteOptions。null であってはなりません。- 戻り値:
thisCassandraBatchOperations。- 例外:
IllegalStateExceptionSE- バッチがすでに実行されている場合。- 導入:
- 2.2
- 関連事項: