public class ReplicatedMapConfig extends Object
ReplicatedMap
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 and Description |
---|
ReplicatedMapConfig() |
ReplicatedMapConfig(ReplicatedMapConfig replicatedMapConfig) |
ReplicatedMapConfig(String name)
Creates a ReplicatedMapConfig with the given name.
|
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.
|
public static final int DEFAULT_CONCURRENCY_LEVEL
public static final int DEFAULT_REPLICATION_DELAY_MILLIS
public static final InMemoryFormat DEFAULT_IN_MEMORY_FORMAT
public static final boolean DEFAULT_ASNYC_FILLUP
public static final String DEFAULT_MERGE_POLICY
public ReplicatedMapConfig()
public ReplicatedMapConfig(String name)
name
- the name of the ReplicatedMap.public ReplicatedMapConfig(ReplicatedMapConfig replicatedMapConfig)
public String getName()
ReplicatedMap
.ReplicatedMap
.public ReplicatedMapConfig setName(String name)
ReplicatedMap
.name
- the name of the ReplicatedMap
.@Deprecated public long getReplicationDelayMillis()
@Deprecated public ReplicatedMapConfig setReplicationDelayMillis(long replicationDelayMillis)
replicationDelayMillis
- the number of milliseconds after a put is executed before the value is replicated
to other nodes.@Deprecated public int getConcurrencyLevel()
@Deprecated public ReplicatedMapConfig setConcurrencyLevel(int concurrencyLevel)
concurrencyLevel
- Number of parallel mutexes to minimize contention on keys.public InMemoryFormat getInMemoryFormat()
public ReplicatedMapConfig setInMemoryFormat(InMemoryFormat inMemoryFormat)
inMemoryFormat
- Data type used to store entries.@Deprecated public ScheduledExecutorService getReplicatorExecutorService()
@Deprecated public ReplicatedMapConfig setReplicatorExecutorService(ScheduledExecutorService replicatorExecutorService)
public List<ListenerConfig> getListenerConfigs()
public ReplicatedMapConfig setListenerConfigs(List<ListenerConfig> listenerConfigs)
public ReplicatedMapConfig addEntryListenerConfig(EntryListenerConfig listenerConfig)
public boolean isAsyncFillup()
public void setAsyncFillup(boolean asyncFillup)
asyncFillup
- True if the replicated map is available for reads before the initial
replication is completed, false otherwise.public ReplicatedMapConfig getAsReadOnly()
public boolean isStatisticsEnabled()
public ReplicatedMapConfig setStatisticsEnabled(boolean statisticsEnabled)
statisticsEnabled
- True to enable replicated map statistics, false to disable.public String getMergePolicy()
ReplicatedMapMergePolicy
public ReplicatedMapConfig setMergePolicy(String mergePolicy)
ReplicatedMapMergePolicy
mergePolicy
- the replicated map merge policy to setCopyright © 2016 Hazelcast, Inc.. All Rights Reserved.