com.hazelcast.config

Class ReplicatedMapConfig

java.lang.Object

com.hazelcast.config.ReplicatedMapConfig

public class ReplicatedMapConfig
extends Object

Contains the configuration for an ReplicatedMap

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DEFAULT_ASNYC_FILLUP Default value of asynchronous fill up
static int	DEFAULT_CONCURRENCY_LEVEL Default value of concurrency level
static InMemoryFormat	DEFAULT_IN_MEMORY_FORMAT Default value of In-memory format
static String	DEFAULT_MERGE_POLICY Default policy for merging
static int	DEFAULT_REPLICATION_DELAY_MILLIS Default value of delay of replication in millisecond

Constructor Summary

Constructors

Constructor and Description
ReplicatedMapConfig()
ReplicatedMapConfig(ReplicatedMapConfig replicatedMapConfig)
ReplicatedMapConfig(String name) Creates a ReplicatedMapConfig with the given name.

Method Summary

Methods

Modifier and Type	Method and Description
ReplicatedMapConfig	addEntryListenerConfig(EntryListenerConfig listenerConfig)
ReplicatedMapConfig	getAsReadOnly()
int	getConcurrencyLevel() Deprecated. new implementation doesn't use mutexes
InMemoryFormat	getInMemoryFormat() Data type used to store entries.
List<ListenerConfig>	getListenerConfigs()
String	getMergePolicy() Gets the replicated map merge policy ReplicatedMapMergePolicy
String	getName() Returns the name of this ReplicatedMap.
long	getReplicationDelayMillis() Deprecated. since new implementation will route puts to the partition owner nodes, caching won't help replication speed because most of the time subsequent puts will end up in different nodes.
ScheduledExecutorService	getReplicatorExecutorService() Deprecated. new implementation doesn't use executor service for replication.
boolean	isAsyncFillup() True if the replicated map is available for reads before the initial replication is completed, false otherwise.
boolean	isStatisticsEnabled() Checks if statistics are enabled for this replicated map.
void	setAsyncFillup(boolean asyncFillup) True if the replicated map is available for reads before the initial replication is completed, false otherwise.
ReplicatedMapConfig	setConcurrencyLevel(int concurrencyLevel) Deprecated. new implementation doesn't use mutexes
ReplicatedMapConfig	setInMemoryFormat(InMemoryFormat inMemoryFormat) Data type used to store entries.
ReplicatedMapConfig	setListenerConfigs(List<ListenerConfig> listenerConfigs)
ReplicatedMapConfig	setMergePolicy(String mergePolicy) Sets the replicated map merge policy ReplicatedMapMergePolicy
ReplicatedMapConfig	setName(String name) Sets the name of this ReplicatedMap.
ReplicatedMapConfig	setReplicationDelayMillis(long replicationDelayMillis) Deprecated. since new implementation will route puts to the partition owner nodes, caching won't help replication speed because most of the time subsequent puts will end up in different nodes.
ReplicatedMapConfig	setReplicatorExecutorService(ScheduledExecutorService replicatorExecutorService) Deprecated. new implementation doesn't use executor service for replication.
ReplicatedMapConfig	setStatisticsEnabled(boolean statisticsEnabled) Sets statistics to enabled or disabled for this replicated map.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONCURRENCY_LEVEL

public static final int DEFAULT_CONCURRENCY_LEVEL

Default value of concurrency level

See Also:

Constant Field Values

DEFAULT_REPLICATION_DELAY_MILLIS

public static final int DEFAULT_REPLICATION_DELAY_MILLIS

Default value of delay of replication in millisecond

See Also:

Constant Field Values

DEFAULT_IN_MEMORY_FORMAT

public static final InMemoryFormat DEFAULT_IN_MEMORY_FORMAT

Default value of In-memory format

DEFAULT_ASNYC_FILLUP

public static final boolean DEFAULT_ASNYC_FILLUP

Default value of asynchronous fill up

See Also:

Constant Field Values

DEFAULT_MERGE_POLICY

public static final String DEFAULT_MERGE_POLICY

Default policy for merging

Constructor Detail

ReplicatedMapConfig

public ReplicatedMapConfig()

ReplicatedMapConfig

public ReplicatedMapConfig(String name)

Creates a ReplicatedMapConfig with the given name.

Parameters:

name - the name of the ReplicatedMap.

ReplicatedMapConfig

public ReplicatedMapConfig(ReplicatedMapConfig replicatedMapConfig)

Method Detail

getName

public String getName()

Returns the name of this ReplicatedMap.

Returns:

the name of the ReplicatedMap.

setName

public ReplicatedMapConfig setName(String name)

Sets the name of this ReplicatedMap.

Parameters:

name - the name of the ReplicatedMap.

Returns:

The current replicated map config instance.

getReplicationDelayMillis

@Deprecated
public long getReplicationDelayMillis()

Deprecated. since new implementation will route puts to the partition owner nodes, caching won't help replication speed because most of the time subsequent puts will end up in different nodes.

The number of milliseconds after a put is executed before the value is replicated to other nodes. During this time, multiple puts can be operated and cached up to be sent out all at once after the delay. Default value is 100ms before a replication is operated. If 0, no delay is used and all values are replicated one by one.

Returns:

the number of milliseconds after a put is executed before the value is replicated to other nodes.

setReplicationDelayMillis

@Deprecated
public ReplicatedMapConfig setReplicationDelayMillis(long replicationDelayMillis)

Deprecated. since new implementation will route puts to the partition owner nodes, caching won't help replication speed because most of the time subsequent puts will end up in different nodes.

Sets the number of milliseconds after a put is executed before the value is replicated to other nodes. During this time, multiple puts can be operated and cached up to be sent out all at once after the delay. Default value is 100ms before a replication is operated. If set to 0, no delay is used and all values are replicated one by one.

Parameters:

replicationDelayMillis - the number of milliseconds after a put is executed before the value is replicated to other nodes.

Returns:

The current replicated map config instance.

getConcurrencyLevel

@Deprecated
public int getConcurrencyLevel()

Deprecated. new implementation doesn't use mutexes

Number of parallel mutexes to minimize contention on keys. The default value is 32 which is a good number for lots of applications. If higher contention is seen on writes to values inside of the replicated map, this value can be adjusted to the needs.

Returns:

Number of parallel mutexes to minimize contention on keys.

setConcurrencyLevel

@Deprecated
public ReplicatedMapConfig setConcurrencyLevel(int concurrencyLevel)

Deprecated. new implementation doesn't use mutexes

Sets the number of parallel mutexes to minimize contention on keys. The default value is 32 which is a good number for lots of applications. If higher contention is seen on writes to values inside of the replicated map, this value can be adjusted to the needs.

Parameters:

concurrencyLevel - Number of parallel mutexes to minimize contention on keys.

Returns:

The current replicated map config instance.

getInMemoryFormat

public InMemoryFormat getInMemoryFormat()

Data type used to store entries. Possible values: BINARY: keys and values are stored as binary data. OBJECT (default): values are stored in their object forms. NATIVE: keys and values are stored in native memory.

Returns:

Data type used to store entries.

setInMemoryFormat

public ReplicatedMapConfig setInMemoryFormat(InMemoryFormat inMemoryFormat)

Data type used to store entries. Possible values: BINARY: keys and values are stored as binary data. OBJECT (default): values are stored in their object forms. NATIVE: keys and values are stored in native memory.

Parameters:

inMemoryFormat - Data type used to store entries.

Returns:

The current replicated map config instance.

getReplicatorExecutorService

@Deprecated
public ScheduledExecutorService getReplicatorExecutorService()

Deprecated. new implementation doesn't use executor service for replication.

setReplicatorExecutorService

@Deprecated
public ReplicatedMapConfig setReplicatorExecutorService(ScheduledExecutorService replicatorExecutorService)

Deprecated. new implementation doesn't use executor service for replication.

getListenerConfigs

public List<ListenerConfig> getListenerConfigs()

setListenerConfigs

public ReplicatedMapConfig setListenerConfigs(List<ListenerConfig> listenerConfigs)

addEntryListenerConfig

public ReplicatedMapConfig addEntryListenerConfig(EntryListenerConfig listenerConfig)

isAsyncFillup

public boolean isAsyncFillup()

True if the replicated map is available for reads before the initial replication is completed, false otherwise. Default is true. If false, no Exception will be thrown when the replicated map is not yet ready, but `null` values can be seen until the initial replication is completed.

Returns:

True if the replicated map is available for reads before the initial replication is completed, false otherwise.

setAsyncFillup

public void setAsyncFillup(boolean asyncFillup)

True if the replicated map is available for reads before the initial replication is completed, false otherwise. Default is true. If false, no Exception will be thrown when the replicated map is not yet ready, but `null` values can be seen until the initial replication is completed.

Parameters:

asyncFillup - True if the replicated map is available for reads before the initial replication is completed, false otherwise.

getAsReadOnly

public ReplicatedMapConfig getAsReadOnly()

isStatisticsEnabled

public boolean isStatisticsEnabled()

Checks if statistics are enabled for this replicated map.

Returns:

True if statistics are enabled, false otherwise.

setStatisticsEnabled

public ReplicatedMapConfig setStatisticsEnabled(boolean statisticsEnabled)

Sets statistics to enabled or disabled for this replicated map.

Parameters:

statisticsEnabled - True to enable replicated map statistics, false to disable.

Returns:

The current replicated map config instance.

getMergePolicy

public String getMergePolicy()

Gets the replicated map merge policy ReplicatedMapMergePolicy

Returns:

the updated replicated map configuration

setMergePolicy

public ReplicatedMapConfig setMergePolicy(String mergePolicy)

Sets the replicated map merge policy ReplicatedMapMergePolicy

Parameters:

mergePolicy - the replicated map merge policy to set

Returns:

the updated replicated map configuration

toString

public String toString()

Overrides:

toString in class Object