Package org.infinispan.persistence.support

Class AbstractSegmentedAdvancedLoadWriteStore<K,V>

java.lang.Object

org.infinispan.persistence.support.AbstractSegmentedAdvancedLoadWriteStore<K,V>

All Implemented Interfaces:

Lifecycle, AdvancedCacheExpirationWriter<K,V>, AdvancedCacheLoader<K,V>, AdvancedCacheWriter<K,V>, AdvancedLoadWriteStore<K,V>, CacheLoader<K,V>, CacheWriter<K,V>, ExternalStore<K,V>, SegmentedAdvancedLoadWriteStore<K,V>

Direct Known Subclasses:

ComposedSegmentedLoadWriteStore

public abstract class AbstractSegmentedAdvancedLoadWriteStore<K,V>
extends Object
implements SegmentedAdvancedLoadWriteStore<K,V>

Abstract segment loader writer that implements all the single key non segmented methods by invoking the segmented equivalent by passing in the segment returned from invoking getKeyMapper(). These methods are also all declared final as to make sure the end user does not implement the incorrect method. All other methods must be implemented as normal.

Since:

9.4

Author:

wburns

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.AdvancedCacheExpirationWriter

AdvancedCacheExpirationWriter.ExpirationPurgeListener<K,V>

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.AdvancedCacheWriter

AdvancedCacheWriter.PurgeListener<K>

Constructor Summary

Constructors

Constructor	Description
AbstractSegmentedAdvancedLoadWriteStore()

Method Summary

Modifier and Type	Method	Description
final boolean	contains(Object key)	Returns true if the storage contains an entry associated with the given key.
final boolean	delete(Object key)
protected abstract ToIntFunction<Object>	getKeyMapper()
final MarshallableEntry<K,V>	loadEntry(Object key)	Fetches an entry from the storage.
final void	write(MarshallableEntry<? extends K,? extends V> entry)	Persists the entry to the storage.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.persistence.spi.AdvancedCacheExpirationWriter

purge

Methods inherited from interface org.infinispan.persistence.spi.AdvancedCacheLoader

entryPublisher, publishKeys, size

Methods inherited from interface org.infinispan.persistence.spi.AdvancedCacheWriter

clear

Methods inherited from interface org.infinispan.persistence.spi.CacheLoader

init

Methods inherited from interface org.infinispan.persistence.spi.CacheWriter

bulkUpdate, deleteBatch, init, isAvailable

Methods inherited from interface org.infinispan.persistence.spi.ExternalStore

destroy, isAvailable

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

start, stop

Methods inherited from interface org.infinispan.persistence.spi.SegmentedAdvancedLoadWriteStore

addSegments, clear, contains, delete, entryPublisher, get, publishKeys, purge, removeSegments, size, write

Constructor Details

AbstractSegmentedAdvancedLoadWriteStore

public AbstractSegmentedAdvancedLoadWriteStore()

Method Details

getKeyMapper

protected abstract ToIntFunction<Object> getKeyMapper()

loadEntry

public final MarshallableEntry<K,V> loadEntry(Object key)

Description copied from interface: CacheLoader

Fetches an entry from the storage. If a MarshallableEntry needs to be created here, InitializationContext.getMarshallableEntryFactory() ()} and InitializationContext.getByteBufferFactory() should be used.

Specified by:

loadEntry in interface CacheLoader<K,V>

Returns:

the entry, or null if the entry does not exist

contains

public final boolean contains(Object key)

Description copied from interface: CacheLoader

Returns true if the storage contains an entry associated with the given key.

Specified by:

contains in interface CacheLoader<K,V>

write

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

Description copied from interface: CacheWriter

Persists the entry to the storage.

Specified by:

write in interface CacheWriter<K,V>

See Also:

• MarshallableEntry

delete

public final boolean delete(Object key)

Specified by:

delete in interface CacheWriter<K,V>

Returns:

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