org.infinispan.persistence.spi

Interface CacheWriter<K,V>

All Superinterfaces:

Lifecycle

All Known Subinterfaces:

AdvancedCacheExpirationWriter<K,V>, AdvancedCacheWriter<K,V>, AdvancedLoadWriteStore<K,V>, ExternalStore<K,V>, FlagAffectedStore<K,V>, SegmentedAdvancedLoadWriteStore<K,V>, TransactionalCacheWriter<K,V>

All Known Implementing Classes:

AbstractSegmentedAdvancedLoadWriteStore, ComposedSegmentedLoadWriteStore, DelegatingCacheWriter, SingleFileStore

Deprecated.

since 11.0 replaced by NonBlockingStore

@ThreadSafe
 @Deprecated
public interface CacheWriter<K,V>
extends Lifecycle

Allows persisting data to an external storage, as opposed to the CacheLoader.

Since:

6.0

Author:

Mircea Markus

Method Summary

Modifier and Type	Method and Description
default CompletionStage<Void>	bulkUpdate(org.reactivestreams.Publisher<MarshallableEntry<? extends K,? extends V>> publisher) Deprecated. Persist all provided entries to the store in chunks, with the size of each chunk determined by the store implementation.
boolean	delete(Object key) Deprecated.
default void	deleteBatch(Iterable<Object> keys) Deprecated. Remove all provided keys from the store in a single batch operation.
void	init(InitializationContext ctx) Deprecated. Used to initialize a cache loader.
default boolean	isAvailable() Deprecated.
void	write(MarshallableEntry<? extends K,? extends V> entry) Deprecated. Persists the entry to the storage.

Methods inherited from interface org.infinispan.commons.api.Lifecycle

start, stop

Method Detail

init

void init(InitializationContext ctx)

Deprecated.

Used to initialize a cache loader. Typically invoked by the PersistenceManager when setting up cache loaders.

Throws:

PersistenceException - in case of an error, e.g. communicating with the external storage

write

void write(MarshallableEntry<? extends K,? extends V> entry)

Deprecated.

Persists the entry to the storage.

Throws:

PersistenceException - in case of an error, e.g. communicating with the external storage

See Also:

MarshallableEntry

delete

boolean delete(Object key)

Deprecated.

Returns:

true if the entry existed in the persistent store and it was deleted.

Throws:

PersistenceException - in case of an error, e.g. communicating with the external storage

bulkUpdate

default CompletionStage<Void> bulkUpdate(org.reactivestreams.Publisher<MarshallableEntry<? extends K,? extends V>> publisher)

Deprecated.

Persist all provided entries to the store in chunks, with the size of each chunk determined by the store implementation. If chunking is not supported by the underlying store, then entries are written to the store individually via write(MarshallableEntry).

Parameters:

publisher - a Publisher of MarshallableEntry instances

Throws:

NullPointerException - if the publisher is null.

deleteBatch

default void deleteBatch(Iterable<Object> keys)

Deprecated.

Remove all provided keys from the store in a single batch operation. If this is not supported by the underlying store, then keys are removed from the store individually via delete(Object).

Parameters:

keys - an Iterable of entry Keys to be removed from the store.

Throws:

NullPointerException - if keys is null.

isAvailable

default boolean isAvailable()

Deprecated.

Returns:

true if the writer can be connected to, otherwise false