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

Packages that use MarshallableEntry

Package	Description
org.infinispan.expiration	Cache expiration.
org.infinispan.expiration.impl
org.infinispan.marshall.persistence.impl	This package should mainly contain MessageMarshaller implementations for classes which a static inner class is not possible.
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.manager	Implementations of the PersistenceManager interface, which define the logic of how infinispan interacts with external stores.
org.infinispan.persistence.modifications	Modifications that are used to encapsulate cache operations for application to a CacheStore.
org.infinispan.persistence.spi	The Persistence SPI.
org.infinispan.persistence.support
org.infinispan.xsite.statetransfer

Uses of MarshallableEntry in org.infinispan.expiration

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

Modifier and Type	Method and Description
void	ExpirationManager.handleInStoreExpiration(MarshallableEntry<K,V> marshalledEntry) Deprecated. since 9.3 this method is not intended for external use

Uses of MarshallableEntry in org.infinispan.expiration.impl

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

Modifier and Type	Method and Description
default void	InternalExpirationManager.handleInStoreExpiration(MarshallableEntry<K,V> marshalledEntry)
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.marshall.persistence.impl

Classes in org.infinispan.marshall.persistence.impl that implement MarshallableEntry

Modifier and Type	Class and Description
class	MarshallableEntryImpl<K,V>

Methods in org.infinispan.marshall.persistence.impl that return MarshallableEntry

Modifier and Type	Method and Description
MarshallableEntry	MarshalledEntryFactoryImpl.create(ByteBuffer key, ByteBuffer valueBytes)
MarshallableEntry	MarshalledEntryFactoryImpl.create(ByteBuffer key, ByteBuffer valueBytes, ByteBuffer metadataBytes, ByteBuffer internalMetadataBytes, long created, long lastUsed)
MarshallableEntry	MarshalledEntryFactoryImpl.create(Object key)
MarshallableEntry	MarshalledEntryFactoryImpl.create(Object key, ByteBuffer valueBytes, ByteBuffer metadataBytes, ByteBuffer internalMetadataBytes, long created, long lastUsed)
MarshallableEntry	MarshalledEntryFactoryImpl.create(Object key, MarshalledValue value)
MarshallableEntry	MarshalledEntryFactoryImpl.create(Object key, Object value)
MarshallableEntry	MarshalledEntryFactoryImpl.create(Object key, Object value, Metadata metadata, PrivateMetadata internalMetadata, long created, long lastUsed)
MarshallableEntry	MarshalledEntryFactoryImpl.getEmpty()

Uses of MarshallableEntry in org.infinispan.persistence

Methods in org.infinispan.persistence that return MarshallableEntry

Modifier and Type	Method and Description
static <K,V> MarshallableEntry<K,V>	PersistenceUtil.loadAndCheckExpiration(PersistenceManager persistenceManager, Object key, InvocationContext context, TimeService timeService) Deprecated. 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 and 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 and 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 and Description
CompletionStage<Void>	AsyncNonBlockingStore.write(int segment, MarshallableEntry<? extends K,? extends V> entry)

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

Modifier and Type	Method and Description
CompletionStage<Void>	AsyncNonBlockingStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)

Uses of MarshallableEntry in org.infinispan.persistence.cluster

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

Modifier and Type	Method and Description
MarshallableEntry	ClusterLoader.loadEntry(Object key) Deprecated.

Uses of MarshallableEntry in org.infinispan.persistence.file

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

Modifier and Type	Method and Description
MarshallableEntry<K,V>	SingleFileStore.loadEntry(Object key)

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

Modifier and Type	Method and Description
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>>	SingleFileStore.entryPublisher(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)

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

Modifier and Type	Method and Description
void	SingleFileStore.write(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 and Description
static <K,V> MarshallableEntry<K,V>	PersistenceUtil.loadAndCheckExpiration(PersistenceManager persistenceManager, Object key, int segment, InvocationContext context)

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

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

Uses of MarshallableEntry in org.infinispan.persistence.manager

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

Modifier and Type	Method and Description
<K,V> CompletionStage<MarshallableEntry<K,V>>	PassivationPersistenceManager.loadFromAllStores(Object key, boolean localInvocation, boolean includeStores)
<K,V> CompletionStage<MarshallableEntry<K,V>>	PersistenceManager.loadFromAllStores(Object key, boolean localInvocation, boolean includeStores) Loads an entry from the persistence store for the given key.
<K,V> CompletionStage<MarshallableEntry<K,V>>	PersistenceManagerImpl.loadFromAllStores(Object key, boolean localInvocation, boolean includeStores)
<K,V> CompletionStage<MarshallableEntry<K,V>>	PersistenceManagerStub.loadFromAllStores(Object key, boolean localInvocation, boolean includeStores)
<K,V> CompletionStage<MarshallableEntry<K,V>>	PassivationPersistenceManager.loadFromAllStores(Object key, int segment, boolean localInvocation, boolean includeStores)
default <K,V> CompletionStage<MarshallableEntry<K,V>>	PersistenceManager.loadFromAllStores(Object key, int segment, boolean localInvocation, boolean includeStores) Same as PersistenceManager.loadFromAllStores(Object, boolean, boolean) except that the segment of the key is also provided to avoid having to calculate the segment.
<K,V> CompletionStage<MarshallableEntry<K,V>>	PersistenceManagerImpl.loadFromAllStores(Object key, int segment, boolean localInvocation, boolean includeStores)
<K,V> CompletionStage<MarshallableEntry<K,V>>	PersistenceManagerStub.loadFromAllStores(Object key, int segment, boolean localInvocation, boolean includeStores)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PassivationPersistenceManager.publishEntries(boolean fetchValue, boolean fetchMetadata)
default <K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManager.publishEntries(boolean fetchValue, boolean fetchMetadata) See PersistenceManager.publishEntries(Predicate, boolean, boolean, Predicate)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManagerImpl.publishEntries(boolean fetchValue, boolean fetchMetadata)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PassivationPersistenceManager.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManager.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate) Returns a publisher that will publish entries that map to the provided segments.
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManagerImpl.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManagerStub.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PassivationPersistenceManager.publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManager.publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate) Returns a publisher that will publish all entries stored by the underlying cache store.
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManagerImpl.publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	PersistenceManagerStub.publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)

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

Modifier and Type	Method and Description
CompletionStage<Void>	PassivationPersistenceManager.passivate(MarshallableEntry marshallableEntry, int segment)
default CompletionStage<Void>	PersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate) Write to all stores that are not transactional.
CompletionStage<Void>	PersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate, long flags)
CompletionStage<Void>	PersistenceManagerImpl.writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate, long flags)
CompletionStage<Void>	PersistenceManagerStub.writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate, long flags)

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

Modifier and Type	Method and Description
<K,V> CompletionStage<Void>	PersistenceManager.writeEntries(Iterable<MarshallableEntry<K,V>> iterable, Predicate<? super StoreConfiguration> predicate) Writes the entries to the stores that pass the given predicate
<K,V> CompletionStage<Void>	PersistenceManagerImpl.writeEntries(Iterable<MarshallableEntry<K,V>> iterable, Predicate<? super StoreConfiguration> predicate)
<K,V> CompletionStage<Void>	PersistenceManagerStub.writeEntries(Iterable<MarshallableEntry<K,V>> iterable, Predicate<? super StoreConfiguration> predicate)

Uses of MarshallableEntry in org.infinispan.persistence.modifications

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

Modifier and Type	Method and Description
MarshallableEntry	Store.getStoredValue()

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

Constructor and Description
Store(Object key, MarshallableEntry storedValue)

Uses of MarshallableEntry in org.infinispan.persistence.spi

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

Modifier and Type	Method and Description
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>	MarshallableEntryFactory.create(Object key) value defaults to null
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(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>	SegmentedAdvancedLoadWriteStore.get(int segment, Object key) Deprecated. 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. Fetches an entry from the storage.

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

Modifier and Type	Method and Description
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	SegmentedAdvancedLoadWriteStore.entryPublisher(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata) Deprecated. Publishes all entries from this store.
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	AdvancedCacheLoader.entryPublisher(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata) Deprecated. 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 and Description
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.
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. Persists the entry to the storage with the given segment to optimize future lookups.
void	CacheWriter.write(MarshallableEntry<? extends K,? extends V> entry) Deprecated. Persists the entry to the storage.

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

Modifier and Type	Method and Description
default CompletionStage<Void>	NonBlockingStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) Writes and removes the entries provided by the Publishers into the store.
default CompletionStage<Void>	CacheWriter.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.
default CompletionStage<Void>	NonBlockingStore.prepareWithModifications(Transaction transaction, int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) Write remove and put modifications to the store in the prepare phase, which should not yet persisted until the same transaction is committed via NonBlockingStore.commit(Transaction) or they are discarded if the transaction is rolled back via NonBlockingStore.rollback(Transaction).

Uses of MarshallableEntry in org.infinispan.persistence.support

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

Modifier and Type	Method and Description
MarshallableEntry<K,V>	ComposedSegmentedLoadWriteStore.get(int segment, Object key)
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 and Description
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	ComposedSegmentedLoadWriteStore.entryPublisher(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	ComposedSegmentedLoadWriteStore.entryPublisher(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)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingPersistenceManager.publishEntries(boolean fetchValue, boolean fetchMetadata)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingNonBlockingStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingStoreAdapter.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingPersistenceManager.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingPersistenceManager.publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
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 and Description
void	BatchModification.addMarshalledEntry(Object key, MarshallableEntry<Object,Object> marshalledEntry)
void	ComposedSegmentedLoadWriteStore.write(int segment, 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)
void	AbstractSegmentedAdvancedLoadWriteStore.write(MarshallableEntry<? extends K,? extends V> entry)
void	DelegatingCacheWriter.write(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 and Description
CompletionStage<Void>	DelegatingNonBlockingStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
CompletionStage<Void>	NonBlockingStoreAdapter.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
CompletionStage<Void>	ComposedSegmentedLoadWriteStore.bulkUpdate(org.reactivestreams.Publisher<MarshallableEntry<? extends K,? extends V>> publisher)
CompletionStage<Void>	DelegatingNonBlockingStore.prepareWithModifications(Transaction transaction, int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
CompletionStage<Void>	NonBlockingStoreAdapter.prepareWithModifications(Transaction transaction, int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
<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 and Description
static XSiteState	XSiteState.fromCacheLoader(MarshallableEntry<?,?> marshalledEntry)