Class InitializationContextImpl

java.lang.Object

org.infinispan.persistence.InitializationContextImpl

All Implemented Interfaces:

InitializationContext

public class InitializationContextImpl
extends Object
implements InitializationContext

Since:

6.0

Author:

Mircea Markus

Constructor Summary

Constructors

Constructor	Description
InitializationContextImpl(StoreConfiguration configuration, Cache cache, KeyPartitioner keyPartitioner, PersistenceMarshaller marshaller, TimeService timeService, ByteBufferFactory byteBufferFactory, MarshallableEntryFactory marshallableEntryFactory, Executor nonBlockingExecutor, GlobalConfiguration globalConfiguration, BlockingManager blockingManager, NonBlockingManager nonBlockingManager)

Method Summary

Modifier and Type	Method	Description
boolean	canStoreDirectlyPurgeOnStartup()	This method returns whether the store can directly purge its contents on startup, which can be more performant than a clear.
BlockingManager	getBlockingManager()	Returns a manager that is designed to execute tasks that might block.
ByteBufferFactory	getByteBufferFactory()	To be used for building ByteBuffer objects.
Cache	getCache()
StoreConfiguration	getConfiguration()
GlobalConfiguration	getGlobalConfiguration()	Returns the global configuration
KeyPartitioner	getKeyPartitioner()	The configured partitioner that can be used to determine which segment a given key belongs to.
<K,V> MarshallableEntryFactory<K,V>	getMarshallableEntryFactory()	Should be used to build all MarshallableEntry objects.
Executor	getNonBlockingExecutor()	Returns an executor for non-blocking tasks.
NonBlockingManager	getNonBlockingManager()	Returns a manager that is designed to help with non blocking operations.
PersistenceMarshaller	getPersistenceMarshaller()	Returns the persistence marshaller which should be used to marshall/unmarshall all stored bytes.
TimeService	getTimeService()

Methods inherited from class java.lang.Object

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

Constructor Details

InitializationContextImpl

public InitializationContextImpl(StoreConfiguration configuration,
 Cache cache,
 KeyPartitioner keyPartitioner,
 PersistenceMarshaller marshaller,
 TimeService timeService,
 ByteBufferFactory byteBufferFactory,
 MarshallableEntryFactory marshallableEntryFactory,
 Executor nonBlockingExecutor,
 GlobalConfiguration globalConfiguration,
 BlockingManager blockingManager,
 NonBlockingManager nonBlockingManager)

Method Details

getConfiguration

public StoreConfiguration getConfiguration()

Specified by:

getConfiguration in interface InitializationContext

getCache

public Cache getCache()

Specified by:

getCache in interface InitializationContext

getKeyPartitioner

public KeyPartitioner getKeyPartitioner()

Description copied from interface: InitializationContext

The configured partitioner that can be used to determine which segment a given key belongs to. This is useful when a store is segmented.

Specified by:

getKeyPartitioner in interface InitializationContext

Returns:

partitioner that can provide what segment a key maps to

getTimeService

public TimeService getTimeService()

Specified by:

getTimeService in interface InitializationContext

getByteBufferFactory

public ByteBufferFactory getByteBufferFactory()

Description copied from interface: InitializationContext

To be used for building ByteBuffer objects.

Specified by:

getByteBufferFactory in interface InitializationContext

getMarshallableEntryFactory

public <K,V> MarshallableEntryFactory<K,V> getMarshallableEntryFactory()

Description copied from interface: InitializationContext

Should be used to build all MarshallableEntry objects.

Specified by:

getMarshallableEntryFactory in interface InitializationContext

getNonBlockingExecutor

public Executor getNonBlockingExecutor()

Description copied from interface: InitializationContext

Returns an executor for non-blocking tasks. Users must guarantee that the tasks they submit to this executor do not block the thread in which the executor runs. Doing so can cause Infinispan to handle operations more slowly, reducing performance, because threads are limited to the number of cores and are used extensively.

Specified by:

getNonBlockingExecutor in interface InitializationContext

Returns:

an executor that can submit non-blocking tasks.

getBlockingManager

public BlockingManager getBlockingManager()

Description copied from interface: InitializationContext

Returns a manager that is designed to execute tasks that might block. This manager ensures that only the blocking code is run on a blocking thread and any stage continues on a non-blocking thread.

Specified by:

getBlockingManager in interface InitializationContext

Returns:

a manager that should be used to execute blocking operations.

getNonBlockingManager

public NonBlockingManager getNonBlockingManager()

Description copied from interface: InitializationContext

Returns a manager that is designed to help with non blocking operations.

Specified by:

getNonBlockingManager in interface InitializationContext

Returns:

a manager that can be used to help with offloading non blocking work.

getPersistenceMarshaller

public PersistenceMarshaller getPersistenceMarshaller()

Description copied from interface: InitializationContext

Returns the persistence marshaller which should be used to marshall/unmarshall all stored bytes.

Specified by:

getPersistenceMarshaller in interface InitializationContext

getGlobalConfiguration

public GlobalConfiguration getGlobalConfiguration()

Description copied from interface: InitializationContext

Returns the global configuration

Specified by:

getGlobalConfiguration in interface InitializationContext

canStoreDirectlyPurgeOnStartup

public boolean canStoreDirectlyPurgeOnStartup()

Description copied from interface: InitializationContext

This method returns whether the store can directly purge its contents on startup, which can be more performant than a clear. This will only be true if StoreConfiguration.purgeOnStartup() is true, but it may be false even when it is if there are other constraints limiting purge until after contents are loaded.

Specified by:

canStoreDirectlyPurgeOnStartup in interface InitializationContext

Returns:

whether a store can directly purge its contents on startup