com.hazelcast.cache.impl

Class PreJoinCacheConfig<K,V>

java.lang.Object

com.hazelcast.config.AbstractCacheConfig<K,V>

com.hazelcast.config.CacheConfig<K,V>

com.hazelcast.cache.impl.PreJoinCacheConfig<K,V>

Type Parameters:

K - the key type of this cache configuration

V - the value type

All Implemented Interfaces:

CacheConfiguration<K,V>, DataSerializable, IdentifiedDataSerializable, Versioned, SplitBrainMergeTypeProvider, Serializable, javax.cache.configuration.CompleteConfiguration<K,V>, javax.cache.configuration.Configuration<K,V>

public class PreJoinCacheConfig<K,V>
extends CacheConfig<K,V>
implements Versioned, IdentifiedDataSerializable

This subclass of CacheConfig is used to communicate cache configurations in pre-join cache operations when cluster version is at least 3.9. The key difference against CacheConfig is that the key/value class names are used in its serialized form, instead of the actual Class objects. Thus the actual key-value classes are only resolved when first used (by means of AbstractCacheConfig.getKeyType() or AbstractCacheConfig.getValueType()). This allows resolution of these classes from remote user code deployment repositories (which are not available while the pre-join operation is being deserialized and executed).

Since:

3.9

See Also:

Serialized Form

Field Summary

Fields inherited from class com.hazelcast.config.AbstractCacheConfig

cacheLoaderFactory, cacheWriterFactory, classLoader, expiryPolicyFactory, hotRestartConfig, isManagementEnabled, isReadThrough, isStatisticsEnabled, isStoreByValue, isWriteThrough, listenerConfigurations, serializationService

Constructor Summary

Constructors

Constructor and Description
PreJoinCacheConfig()
PreJoinCacheConfig(CacheConfig cacheConfig) Constructor that copies given cacheConfig's properties to a new PreJoinCacheConfig.
PreJoinCacheConfig(CacheConfig cacheConfig, boolean resolved)

Method Summary

Modifier and Type	Method and Description
static CacheConfig	asCacheConfig(CacheConfig cacheConfig)
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
int	getId() Returns type identifier for this class.
protected boolean	keyValueTypesEqual(AbstractCacheConfig that)
static PreJoinCacheConfig	of(CacheConfig cacheConfig)
protected void	readFactories(ObjectDataInput in)
protected void	readKeyValueTypes(ObjectDataInput in)
protected void	readListenerConfigurations(ObjectDataInput in)
protected void	readTenant(ObjectDataInput in)
protected void	writeFactories(ObjectDataOutput out)
protected void	writeKeyValueTypes(ObjectDataOutput out)
protected void	writeListenerConfigurations(ObjectDataOutput out)
protected void	writeTenant(ObjectDataOutput out)

Methods inherited from class com.hazelcast.config.CacheConfig

copy, equals, getAsReadOnly, getAsyncBackupCount, getBackupCount, getEvictionConfig, getInMemoryFormat, getManagerPrefix, getMergePolicy, getName, getNameWithPrefix, getPartitionLostListenerConfigs, getProvidedMergeTypes, getQuorumName, getTotalBackupCount, getUriString, getWanReplicationRef, hashCode, isDisablePerEntryInvalidationEvents, readData, setAsyncBackupCount, setBackupCount, setDisablePerEntryInvalidationEvents, setEvictionConfig, setInMemoryFormat, setManagerPrefix, setMergePolicy, setName, setPartitionLostListenerConfigs, setQuorumName, setUriString, setWanReplicationRef, toString, writeData

Methods inherited from class com.hazelcast.config.AbstractCacheConfig

addCacheEntryListenerConfiguration, createConcurrentSet, getCacheEntryListenerConfigurations, getCacheLoaderFactory, getCacheWriterFactory, getExpiryPolicyFactory, getHotRestartConfig, getKeyClassName, getKeyType, getListenerConfigurations, getValueClassName, getValueType, hasListenerConfiguration, isManagementEnabled, isReadThrough, isStatisticsEnabled, isStoreByValue, isWriteThrough, removeCacheEntryListenerConfiguration, setCacheLoaderFactory, setCacheWriterFactory, setClassLoader, setExpiryPolicyFactory, setHotRestartConfig, setKeyClassName, setKeyType, setListenerConfigurations, setListenerConfigurations, setManagementEnabled, setReadThrough, setStatisticsEnabled, setStoreByValue, setTypes, setValueClassName, setValueType, setWriteThrough

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Constructor Detail

PreJoinCacheConfig

public PreJoinCacheConfig()

PreJoinCacheConfig

public PreJoinCacheConfig(CacheConfig cacheConfig)

Constructor that copies given cacheConfig's properties to a new PreJoinCacheConfig. It is assumed that the given cacheConfig's key-value types have already been resolved to loaded classes.

Parameters:

cacheConfig - the original CacheConfig to copy into a new PreJoinCacheConfig

PreJoinCacheConfig

public PreJoinCacheConfig(CacheConfig cacheConfig,
                          boolean resolved)

Method Detail

writeKeyValueTypes

protected void writeKeyValueTypes(ObjectDataOutput out)
                           throws IOException

Overrides:

writeKeyValueTypes in class CacheConfig<K,V>

Throws:

IOException

readKeyValueTypes

protected void readKeyValueTypes(ObjectDataInput in)
                          throws IOException

Overrides:

readKeyValueTypes in class CacheConfig<K,V>

Throws:

IOException

writeTenant

protected void writeTenant(ObjectDataOutput out)
                    throws IOException

Overrides:

writeTenant in class CacheConfig<K,V>

Throws:

IOException

readTenant

protected void readTenant(ObjectDataInput in)
                   throws IOException

Overrides:

readTenant in class CacheConfig<K,V>

Throws:

IOException

writeFactories

protected void writeFactories(ObjectDataOutput out)
                       throws IOException

Overrides:

writeFactories in class CacheConfig<K,V>

Throws:

IOException

readFactories

protected void readFactories(ObjectDataInput in)
                      throws IOException

Overrides:

readFactories in class CacheConfig<K,V>

Throws:

IOException

writeListenerConfigurations

protected void writeListenerConfigurations(ObjectDataOutput out)
                                    throws IOException

Overrides:

writeListenerConfigurations in class CacheConfig<K,V>

Throws:

IOException

readListenerConfigurations

protected void readListenerConfigurations(ObjectDataInput in)
                                   throws IOException

Overrides:

readListenerConfigurations in class CacheConfig<K,V>

Throws:

IOException

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory ID

getId

public int getId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getId in interface IdentifiedDataSerializable

Returns:

type ID

keyValueTypesEqual

protected boolean keyValueTypesEqual(AbstractCacheConfig that)

Overrides:

keyValueTypesEqual in class AbstractCacheConfig<K,V>

asCacheConfig

public static CacheConfig asCacheConfig(CacheConfig cacheConfig)

Returns:

an instance of CacheConfig that is not a PreJoinCacheConfig

of

public static PreJoinCacheConfig of(CacheConfig cacheConfig)