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