public class MapStoreConfig extends Object implements IdentifiedDataSerializable, com.hazelcast.nio.serialization.impl.Versioned
| Modifier and Type | Class and Description |
|---|---|
static class |
MapStoreConfig.InitialLoadMode
Initial load module
|
| Modifier and Type | Field and Description |
|---|---|
static boolean |
DEFAULT_OFFLOAD
Default offload behavior
|
static int |
DEFAULT_WRITE_BATCH_SIZE
Default batch size for writing
|
static boolean |
DEFAULT_WRITE_COALESCING
Default write coalescing behavior
|
static int |
DEFAULT_WRITE_DELAY_SECONDS
Default delay seconds for writing
|
| Constructor and Description |
|---|
MapStoreConfig() |
MapStoreConfig(MapStoreConfig config) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object o) |
int |
getClassId()
Returns type identifier for this class.
|
String |
getClassName()
Returns the name of the MapStore implementation class
|
String |
getFactoryClassName()
Returns the name of the MapStoreFactory implementation class
|
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
Object |
getFactoryImplementation()
Returns the map store factory implementation object.
|
Object |
getImplementation()
Returns the map store implementation object.
|
MapStoreConfig.InitialLoadMode |
getInitialLoadMode()
Returns the initial load mode.
|
Properties |
getProperties()
Returns all the properties
|
String |
getProperty(String name)
Returns the given property
|
int |
getWriteBatchSize()
Returns the number of operations to be included in each batch processing round.
|
int |
getWriteDelaySeconds()
Returns the number of seconds to delay the store writes.
|
int |
hashCode() |
boolean |
isEnabled()
Returns if this configuration is enabled
|
boolean |
isOffload()
Default value is true.
|
boolean |
isWriteCoalescing()
Returns
true if write-coalescing is enabled. |
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
MapStoreConfig |
setClassName(String className)
Sets the name for the MapStore implementation class
|
MapStoreConfig |
setEnabled(boolean enabled)
Enables and disables this configuration
|
MapStoreConfig |
setFactoryClassName(String factoryClassName)
Sets the name for the MapStoreFactory implementation class
|
MapStoreConfig |
setFactoryImplementation(Object factoryImplementation)
Sets the map store factory implementation object.
|
MapStoreConfig |
setImplementation(Object implementation)
Sets the map store implementation object
|
MapStoreConfig |
setInitialLoadMode(MapStoreConfig.InitialLoadMode initialLoadMode)
Sets the initial load mode.
|
MapStoreConfig |
setOffload(boolean offload)
Default value is true.
|
MapStoreConfig |
setProperties(Properties properties)
Sets the properties
|
MapStoreConfig |
setProperty(String name,
String value) |
MapStoreConfig |
setWriteBatchSize(int writeBatchSize)
Sets the number of operations to be included in each batch processing round.
|
MapStoreConfig |
setWriteCoalescing(boolean writeCoalescing)
Setting
writeCoalescing is meaningful
if you are using write-behind MapStore. |
MapStoreConfig |
setWriteDelaySeconds(int writeDelaySeconds)
Sets the number of seconds to delay before writing (storing) the dirty records
|
String |
toString() |
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
public static final int DEFAULT_WRITE_DELAY_SECONDS
public static final int DEFAULT_WRITE_BATCH_SIZE
public static final boolean DEFAULT_WRITE_COALESCING
public static final boolean DEFAULT_OFFLOAD
public MapStoreConfig()
public MapStoreConfig(MapStoreConfig config)
public String getClassName()
public MapStoreConfig setClassName(@Nonnull String className)
className - the name to set for the MapStore implementation classpublic String getFactoryClassName()
public MapStoreConfig setFactoryClassName(@Nonnull String factoryClassName)
factoryClassName - the name to set for the MapStoreFactory implementation classpublic int getWriteDelaySeconds()
public MapStoreConfig setWriteDelaySeconds(int writeDelaySeconds)
Default value is 0.
writeDelaySeconds - the number of seconds to delay before writing the dirty recordspublic int getWriteBatchSize()
public MapStoreConfig setWriteBatchSize(int writeBatchSize)
Default value is 1.
writeBatchSize - the number of operations to be included in each batch processing roundpublic boolean isEnabled()
true if this configuration is enabled, false otherwisepublic MapStoreConfig setEnabled(boolean enabled)
enabled - true to enables this configuration, false to disablepublic MapStoreConfig setOffload(boolean offload)
MapStore interaction can be slow compared to in-memory
processing of data, to make partition threads available during
MapStore interaction for other cluster operations,
MapStore/MapLoader implementations are offloaded from
partition threads to a different thread pool by default.
If you set this property to false, MapStore interaction will be done on partition threads.
This may introduce latency for other operations
which don't require MapStore interaction.
offload - set true to enable
offloading, otherwise set falsepublic boolean isOffload()
Enables and disables offloading behavior.
true if this configuration
is enabled, false otherwisesetOffload(boolean)public MapStoreConfig setImplementation(@Nonnull Object implementation)
implementation - the map store implementation object to setpublic Object getImplementation()
public MapStoreConfig setFactoryImplementation(@Nonnull Object factoryImplementation)
factoryImplementation - the factory implementation objectpublic Object getFactoryImplementation()
public MapStoreConfig setProperty(String name, String value)
public String getProperty(String name)
public Properties getProperties()
public MapStoreConfig setProperties(Properties properties)
properties - the properties to be setpublic MapStoreConfig.InitialLoadMode getInitialLoadMode()
public MapStoreConfig setInitialLoadMode(MapStoreConfig.InitialLoadMode initialLoadMode)
initialLoadMode - the initial load mode objectpublic boolean isWriteCoalescing()
true if write-coalescing is enabled.true if coalescing enabled, false otherwisesetWriteCoalescing(boolean)public MapStoreConfig setWriteCoalescing(boolean writeCoalescing)
writeCoalescing is meaningful
if you are using write-behind MapStore.
When writeCoalescing is true, only the latest
store operation on a key in the writeDelaySeconds
time-window will be reflected to MapStore.
Default value is true.
writeCoalescing - true to enable
write-coalescing, otherwise false.ClusterProperty.MAP_WRITE_BEHIND_QUEUE_CAPACITYpublic int getFactoryId()
IdentifiedDataSerializablegetFactoryId in interface IdentifiedDataSerializablepublic int getClassId()
IdentifiedDataSerializablegetClassId in interface IdentifiedDataSerializablepublic void writeData(ObjectDataOutput out) throws IOException
DataSerializablewriteData in interface DataSerializableout - outputIOException - if an I/O error occurs. In particular,
an IOException may be thrown if the
output stream has been closed.public void readData(ObjectDataInput in) throws IOException
DataSerializablereadData in interface DataSerializablein - inputIOException - if an I/O error occurs. In particular,
an IOException may be thrown if the
input stream has been closed.Copyright © 2023 Hazelcast, Inc.. All rights reserved.