Uses of Interface
org.infinispan.persistence.spi.MarshallableEntry

Packages that use MarshallableEntry

Package	Description
org.infinispan.expiration.impl
org.infinispan.persistence	Persistence API.
org.infinispan.persistence.async
org.infinispan.persistence.cluster	A CacheLoader (not CacheWriter) that polls other nodes in the cluster for state.
org.infinispan.persistence.file	Simple filesystem-based CacheWriter implementation.
org.infinispan.persistence.internal
org.infinispan.persistence.jdbc.common	This package contains a AdvancedLoadWriteStore implementation based on a JDBC database connection.
org.infinispan.persistence.jdbc.common.impl
org.infinispan.persistence.jdbc.common.sql
org.infinispan.persistence.jdbc.stringbased	JDBC CacheStore implementation which maps keys to strings.
org.infinispan.persistence.modifications	Modifications that are used to encapsulate cache operations for application to a CacheStore.
org.infinispan.persistence.remote	Hot Rod-based AdvancedLoadWriteStore.
org.infinispan.persistence.rocksdb	RocksDB-based AdvancedLoadWriteStore.
org.infinispan.persistence.sifs	Soft Index AdvancedLoadWriteStore.
org.infinispan.persistence.spi	The Persistence SPI.
org.infinispan.persistence.sql	This package contains a AdvancedLoadWriteStore implementation based on a JDBC database connection.
org.infinispan.persistence.support
org.infinispan.xsite.statetransfer

Uses of MarshallableEntry in org.infinispan.expiration.impl

Methods in org.infinispan.expiration.impl with parameters of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<Void>	ClusterExpirationManager.handleInStoreExpirationInternal(MarshallableEntry<K,V> marshalledEntry)
CompletionStage<Void>	ExpirationManagerImpl.handleInStoreExpirationInternal(MarshallableEntry<K,V> marshalledEntry)
CompletionStage<Void>	InternalExpirationManager.handleInStoreExpirationInternal(MarshallableEntry<K,V> marshalledEntry)	This is to be invoked when a store entry expires and the value and/or metadata is available to be used.

Uses of MarshallableEntry in org.infinispan.persistence

Methods in org.infinispan.persistence that return MarshallableEntry

Modifier and Type	Method	Description
static <K, V> MarshallableEntry<K,V>	PersistenceUtil.loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager, Object key, InvocationContext context, TimeService timeService)	Deprecated, for removal: This API element is subject to removal in a future version. since 9.4 This method references PersistenceManager, which isn't a public class

Methods in org.infinispan.persistence with parameters of type MarshallableEntry

Modifier and Type	Method	Description
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.convert(MarshallableEntry<K,V> loaded, InternalEntryFactory factory)

Uses of MarshallableEntry in org.infinispan.persistence.async

Methods in org.infinispan.persistence.async that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<MarshallableEntry<K,V>>	AsyncNonBlockingStore.load(int segment, Object key)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	AsyncNonBlockingStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	AsyncNonBlockingStore.purgeExpired()

Methods in org.infinispan.persistence.async with parameters of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<Void>	AsyncNonBlockingStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.cluster

Methods in org.infinispan.persistence.cluster that return MarshallableEntry

Modifier and Type	Method	Description
MarshallableEntry	ClusterLoader.loadEntry(Object key)	Deprecated, for removal: This API element is subject to removal in a future version.

Uses of MarshallableEntry in org.infinispan.persistence.file

Methods in org.infinispan.persistence.file that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<MarshallableEntry<K,V>>	SingleFileStore.load(int segment, Object key)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	SingleFileStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	SingleFileStore.purgeExpired()

Methods in org.infinispan.persistence.file with parameters of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<Void>	SingleFileStore.write(int segment, MarshallableEntry<? extends K,? extends V> marshalledEntry)

Uses of MarshallableEntry in org.infinispan.persistence.internal

Methods in org.infinispan.persistence.internal that return MarshallableEntry

Modifier and Type	Method	Description
static <K, V> MarshallableEntry<K,V>	PersistenceUtil.loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager, Object key, int segment, InvocationContext context)

Methods in org.infinispan.persistence.internal with parameters of type MarshallableEntry

Modifier and Type	Method	Description
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.convert(MarshallableEntry<K,V> loaded, InternalEntryFactory factory)

Uses of MarshallableEntry in org.infinispan.persistence.jdbc.common

Methods in org.infinispan.persistence.jdbc.common that return MarshallableEntry

Modifier and Type	Method	Description
MarshallableEntry<K,V>	TableOperations.loadEntry(Connection connection, int segment, Object key)

Methods in org.infinispan.persistence.jdbc.common that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>>	TableOperations.publishEntries(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter, boolean fetchValue)

Methods in org.infinispan.persistence.jdbc.common with parameters of type MarshallableEntry

Modifier and Type	Method	Description
void	TableOperations.upsertEntry(Connection connection, int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.jdbc.common.impl

Methods in org.infinispan.persistence.jdbc.common.impl that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<MarshallableEntry<K,V>>	BaseJdbcStore.load(int segment, Object key)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	BaseJdbcStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)

Methods in org.infinispan.persistence.jdbc.common.impl with parameters of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<Void>	BaseJdbcStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.jdbc.common.sql

Methods in org.infinispan.persistence.jdbc.common.sql that return MarshallableEntry

Modifier and Type	Method	Description
protected abstract MarshallableEntry<K,V>	BaseTableOperations.entryFromResultSet(ResultSet rs, Object keyIfProvided, boolean fetchValue, Predicate<? super K> keyPredicate)
protected MarshallableEntry<K,V>	BaseTableOperations.ResultSetEntryIterator.getNext()
MarshallableEntry<K,V>	BaseTableOperations.loadEntry(Connection connection, int segment, Object key)

Methods in org.infinispan.persistence.jdbc.common.sql that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>>	BaseTableOperations.publishEntries(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter, boolean fetchValue)

Methods in org.infinispan.persistence.jdbc.common.sql with parameters of type MarshallableEntry

Modifier and Type	Method	Description
protected abstract void	BaseTableOperations.prepareValueStatement(PreparedStatement ps, int segment, MarshallableEntry<? extends K,? extends V> entry)
void	BaseTableOperations.upsertEntry(Connection connection, int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.jdbc.stringbased

Methods in org.infinispan.persistence.jdbc.stringbased that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	JdbcStringBasedStore.purgeExpired()

Uses of MarshallableEntry in org.infinispan.persistence.modifications

Methods in org.infinispan.persistence.modifications that return MarshallableEntry

Modifier and Type	Method	Description
MarshallableEntry	Store.getStoredValue()

Constructors in org.infinispan.persistence.modifications with parameters of type MarshallableEntry

Modifier	Constructor	Description
	Store(Object key, MarshallableEntry storedValue)

Uses of MarshallableEntry in org.infinispan.persistence.remote

Methods in org.infinispan.persistence.remote that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<MarshallableEntry<K,V>>	RemoteStore.load(int segment, Object key)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	RemoteStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	RemoteStore.purgeExpired()

Methods in org.infinispan.persistence.remote with parameters of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<Void>	RemoteStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.rocksdb

Methods in org.infinispan.persistence.rocksdb that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<MarshallableEntry<K,V>>	RocksDBStore.load(int segment, Object key)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	RocksDBStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	RocksDBStore.purgeExpired()

Methods in org.infinispan.persistence.rocksdb with parameters of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<Void>	RocksDBStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.sifs

Methods in org.infinispan.persistence.sifs that return MarshallableEntry

Modifier and Type	Method	Description
MarshallableEntry<K,V>	NonBlockingSoftIndexFileStore.EntryCreator.create(ByteBuffer key, ByteBuffer value, ByteBuffer metadata, ByteBuffer internalMetadata, long created, long lastUsed)

Methods in org.infinispan.persistence.sifs that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<MarshallableEntry<K,V>>	NonBlockingSoftIndexFileStore.load(int segment, Object key)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingSoftIndexFileStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingSoftIndexFileStore.purgeExpired()

Methods in org.infinispan.persistence.sifs with parameters of type MarshallableEntry

Modifier and Type	Method	Description
<K, V> CompletionStage<Void>	LogAppender.storeRequest(int segment, MarshallableEntry<K,V> entry)
CompletionStage<Void>	NonBlockingSoftIndexFileStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.spi

Methods in org.infinispan.persistence.spi that return MarshallableEntry

Modifier and Type	Method	Description
MarshallableEntry<K,V>	MarshallableEntryFactory.cloneWithExpiration(MarshallableEntry<K,V> me, long creationTime, long lifespan)	Clone the provided MarshallableEntry if needed to apply lifespan expiration.
MarshallableEntry<K,V>	MarshallableEntryFactory.create(Object key)	value defaults to null
MarshallableEntry<K,V>	MarshallableEntryFactory.create(Object key, Object value)	metadata defaults to null created defaults to -1 lastUsed defaults to -1
MarshallableEntry<K,V>	MarshallableEntryFactory.create(Object key, Object value, Metadata metadata, PrivateMetadata internalMetadata, long created, long lastUsed)	Creates a MarshallableEntry using non-marshalled POJOs as arguments
MarshallableEntry<K,V>	MarshallableEntryFactory.create(Object key, ByteBuffer valueBytes, ByteBuffer metadataBytes, ByteBuffer internalMetadataBytes, long created, long lastUsed)	Creates a MarshallableEntry using a object key and already marshalled value/metadata as arguments
default MarshallableEntry<K,V>	MarshallableEntryFactory.create(Object key, InternalCacheValue<V> v)	Creates a MarshallableEntry instance from a key and an InternalCacheValue.
MarshallableEntry<K,V>	MarshallableEntryFactory.create(Object key, MarshalledValue value)	Creates a MarshallableEntry using a Key MarshalledValue.
MarshallableEntry<K,V>	MarshallableEntryFactory.create(ByteBuffer key, ByteBuffer valueBytes)	metadataBytes defaults to null created defaults to -1 lastUsed defaults to -1
MarshallableEntry<K,V>	MarshallableEntryFactory.create(ByteBuffer key, ByteBuffer valueBytes, ByteBuffer metadataBytes, ByteBuffer internalMetadataBytes, long created, long lastUsed)	Creates a MarshallableEntry using already marshalled objects as arguments
default MarshallableEntry<K,V>	MarshallableEntryFactory.create(InternalCacheEntry<K,V> e)	Creates a MarshallableEntry instance from an InternalCacheEntry.
MarshallableEntry<K,V>	SegmentedAdvancedLoadWriteStore.get(int segment, Object key)	Deprecated, for removal: This API element is subject to removal in a future version. Fetches an entry from the storage given a segment to optimize this lookup based on.
MarshallableEntry<K,V>	MarshallableEntryFactory.getEmpty()
MarshallableEntry<K,V>	CacheLoader.loadEntry(Object key)	Deprecated, for removal: This API element is subject to removal in a future version. Fetches an entry from the storage.

Methods in org.infinispan.persistence.spi that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	AdvancedCacheLoader.entryPublisher(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)	Deprecated, for removal: This API element is subject to removal in a future version. Publishes all entries from this store.
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	SegmentedAdvancedLoadWriteStore.entryPublisher(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)	Deprecated, for removal: This API element is subject to removal in a future version. Publishes all entries from this store.
CompletionStage<MarshallableEntry<K,V>>	NonBlockingStore.load(int segment, Object key)	Returns a stage that will contain the value loaded from the store.
default org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)	Publishes entries from this store that are in one of the provided segments and also pass the provided filter.
default org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingStore.purgeExpired()	Returns a Publisher that, after it is subscribed to, removes any expired entries from the store and publishes them to the returned Publisher.

Methods in org.infinispan.persistence.spi with parameters of type MarshallableEntry

Modifier and Type	Method	Description
MarshallableEntry<K,V>	MarshallableEntryFactory.cloneWithExpiration(MarshallableEntry<K,V> me, long creationTime, long lifespan)	Clone the provided MarshallableEntry if needed to apply lifespan expiration.
void	AdvancedCacheExpirationWriter.ExpirationPurgeListener.marshalledEntryPurged(MarshallableEntry<K,V> entry)	If possible, AdvancedCacheExpirationWriter implementors should invoke this method for every entry that is purged from the store.
void	CacheWriter.write(MarshallableEntry<? extends K,? extends V> entry)	Deprecated, for removal: This API element is subject to removal in a future version. Persists the entry to the storage.
CompletionStage<Void>	NonBlockingStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)	Writes the entry to the store for the given segment returning a stage that completes normally when it is finished.
void	SegmentedAdvancedLoadWriteStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)	Deprecated, for removal: This API element is subject to removal in a future version. Persists the entry to the storage with the given segment to optimize future lookups.

Method parameters in org.infinispan.persistence.spi with type arguments of type MarshallableEntry

Modifier and Type	Method	Description
default CompletionStage<Void>	CacheWriter.bulkUpdate(org.reactivestreams.Publisher<MarshallableEntry<? extends K,? extends V>> publisher)	Deprecated, for removal: This API element is subject to removal in a future version. Persist all provided entries to the store in chunks, with the size of each chunk determined by the store implementation.

Uses of MarshallableEntry in org.infinispan.persistence.sql

Methods in org.infinispan.persistence.sql that return MarshallableEntry

Modifier and Type	Method	Description
protected MarshallableEntry<K,V>	AbstractSchemaJdbcStore.SchemaTableOperations.entryFromResultSet(ResultSet rs, Object keyIfProvided, boolean fetchValue, Predicate<? super K> keyPredicate)

Methods in org.infinispan.persistence.sql with parameters of type MarshallableEntry

Modifier and Type	Method	Description
protected void	AbstractSchemaJdbcStore.SchemaTableOperations.prepareValueStatement(PreparedStatement ps, int segment, MarshallableEntry<? extends K,? extends V> entry)

Uses of MarshallableEntry in org.infinispan.persistence.support

Methods in org.infinispan.persistence.support that return MarshallableEntry

Modifier and Type	Method	Description
MarshallableEntry<K,V>	ComposedSegmentedLoadWriteStore.get(int segment, Object key)
final MarshallableEntry<K,V>	AbstractSegmentedAdvancedLoadWriteStore.loadEntry(Object key)
MarshallableEntry<K,V>	DelegatingCacheLoader.loadEntry(Object key)

Methods in org.infinispan.persistence.support that return types with arguments of type MarshallableEntry

Modifier and Type	Method	Description
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	ComposedSegmentedLoadWriteStore.entryPublisher(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	ComposedSegmentedLoadWriteStore.entryPublisher(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
Collection<MarshallableEntry<Object,Object>>	BatchModification.getMarshallableEntries()
CompletionStage<MarshallableEntry<K,V>>	DelegatingNonBlockingStore.load(int segment, Object key)
CompletionStage<MarshallableEntry<K,V>>	NonBlockingStoreAdapter.load(int segment, Object key)
<K, V> CompletionStage<MarshallableEntry<K,V>>	DelegatingPersistenceManager.loadFromAllStores(Object key, boolean localInvocation, boolean includeStores)
<K, V> CompletionStage<MarshallableEntry<K,V>>	DelegatingPersistenceManager.loadFromAllStores(Object key, int segment, boolean localInvocation, boolean includeStores)
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<Object,Object>>	DelegatingPersistenceManager.preloadPublisher()
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingNonBlockingStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
<K, V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingPersistenceManager.publishEntries(boolean fetchValue, boolean fetchMetadata)
<K, V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingPersistenceManager.publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K, V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingPersistenceManager.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingStoreAdapter.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingNonBlockingStore.purgeExpired()
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingStoreAdapter.purgeExpired()

Methods in org.infinispan.persistence.support with parameters of type MarshallableEntry

Modifier and Type	Method	Description
void	BatchModification.addMarshalledEntry(Object key, MarshallableEntry<Object,Object> marshalledEntry)
final void	AbstractSegmentedAdvancedLoadWriteStore.write(MarshallableEntry<? extends K,? extends V> entry)
void	ComposedSegmentedLoadWriteStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)
void	DelegatingCacheWriter.write(MarshallableEntry<? extends K,? extends V> entry)
CompletionStage<Void>	DelegatingNonBlockingStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)
CompletionStage<Void>	NonBlockingStoreAdapter.write(int segment, MarshallableEntry<? extends K,? extends V> entry)
CompletionStage<Void>	DelegatingPersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate)
CompletionStage<Void>	DelegatingPersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate, long flags)

Method parameters in org.infinispan.persistence.support with type arguments of type MarshallableEntry

Modifier and Type	Method	Description
CompletionStage<Void>	ComposedSegmentedLoadWriteStore.bulkUpdate(org.reactivestreams.Publisher<MarshallableEntry<? extends K,? extends V>> publisher)
<K, V> CompletionStage<Void>	DelegatingPersistenceManager.writeEntries(Iterable<MarshallableEntry<K,V>> iterable, Predicate<? super StoreConfiguration> predicate)

Uses of MarshallableEntry in org.infinispan.xsite.statetransfer

Methods in org.infinispan.xsite.statetransfer with parameters of type MarshallableEntry

Modifier and Type	Method	Description
static XSiteState	XSiteState.fromCacheLoader(MarshallableEntry<?,?> marshalledEntry)