public class DataStorageConfiguration extends Object implements Serializable
getPageSize()
). An individual page can store one or many cache key-value entries
that allows reusing the memory in the most efficient way and avoid memory fragmentation issues.
By default, the durable memory allocates a single expandable data region with default settings. All the caches that
will be configured in an application will be mapped to this data region by default, thus, all the cache data will
reside in that data region. Parameters of default data region can be changed by setting
setDefaultDataRegionConfiguration(DataRegionConfiguration)
.
Other data regions (except default) can be configured with
setDataRegionConfigurations(DataRegionConfiguration...)
.
Data region can be used in memory-only mode, or in persistent mode, when memory is used as a caching layer for disk.
Persistence for data region can be turned on with DataRegionConfiguration.setPersistenceEnabled(boolean)
flag. To learn more about data regions refer to DataRegionConfiguration
documentation.
Sample configuration below shows how to make 5 GB data regions the default one for Apache Ignite:
<property name="dataStorageConfiguration">
<bean class="org.apache.ignite.configuration.DataStorageConfiguration">
<property name="systemCacheInitialSize" value="#{100L * 1024 * 1024}"/>
<property name="defaultDataRegionConfiguration">
<bean class="org.apache.ignite.configuration.DataRegionConfiguration">
<property name="name" value="default_data_region"/>
<property name="initialSize" value="#{5L * 1024 * 1024 * 1024}"/>
</bean>
</property>
</bean>
</property>
Modifier and Type | Field and Description |
---|---|
static String |
DFLT_BINARY_METADATA_PATH
Default path (relative to working directory) of binary metadata folder
|
static long |
DFLT_CDC_WAL_DIRECTORY_MAX_SIZE
Default change data capture directory maximum size.
|
static int |
DFLT_CHECKPOINT_FREQ |
static int |
DFLT_CHECKPOINT_THREADS
Default number of checkpoint threads.
|
static CheckpointWriteOrder |
DFLT_CHECKPOINT_WRITE_ORDER
Default checkpoint write order.
|
static String |
DFLT_DATA_REG_DEFAULT_NAME
This name is assigned to default Dataregion if no user-defined default MemPlc is specified
|
static long |
DFLT_DATA_REGION_INITIAL_SIZE
Default data region start size (256 MB).
|
static long |
DFLT_DATA_REGION_MAX_SIZE
Default data region's size is 20% of physical memory available on current machine.
|
static int |
DFLT_DEFRAGMENTATION_THREAD_POOL_SIZE
Default defragmentation thread pool size.
|
static int |
DFLT_LOCK_WAIT_TIME
Lock default wait time, 10 sec.
|
static String |
DFLT_MARSHALLER_PATH
Default path (relative to working directory) of marshaller mappings folder
|
static boolean |
DFLT_METRICS_ENABLED
Deprecated.
Will be removed in upcoming releases.
|
static int |
DFLT_PAGE_SIZE
Default memory page size.
|
static int |
DFLT_RATE_TIME_INTERVAL_MILLIS
Default length of interval over which rate-based metric is calculated.
|
static int |
DFLT_SUB_INTERVALS
Default amount of sub intervals to calculate rate-based metric.
|
static int |
DFLT_TLB_SIZE
Default thread local buffer size.
|
static boolean |
DFLT_USE_ASYNC_FILE_IO_FACTORY |
static boolean |
DFLT_WAL_ALWAYS_WRITE_FULL_PAGES
Default wal always write full pages.
|
static long |
DFLT_WAL_ARCHIVE_MAX_SIZE
Default max size of WAL archive files, in bytes.
|
static String |
DFLT_WAL_ARCHIVE_PATH
Default wal archive directory.
|
static int |
DFLT_WAL_BUFF_SIZE
Default thread local buffer size.
|
static String |
DFLT_WAL_CDC_PATH
Default change data capture directory.
|
static boolean |
DFLT_WAL_COMPACTION_ENABLED
Default wal compaction enabled.
|
static int |
DFLT_WAL_COMPACTION_LEVEL
Default wal compaction level.
|
static int |
DFLT_WAL_FLUSH_FREQ
Default Wal flush frequency.
|
static int |
DFLT_WAL_FSYNC_DELAY
Default wal fsync delay.
|
static int |
DFLT_WAL_HISTORY_SIZE
Default number of checkpoints to be kept in WAL after checkpoint is finished
|
static WALMode |
DFLT_WAL_MODE
Default wal mode.
|
static DiskPageCompression |
DFLT_WAL_PAGE_COMPRESSION
Default compression algorithm for WAL page snapshot records.
|
static String |
DFLT_WAL_PATH
Default wal directory.
|
static int |
DFLT_WAL_RECORD_ITERATOR_BUFFER_SIZE
Default wal record iterator buffer size.
|
static int |
DFLT_WAL_SEGMENT_SIZE
Default WAL file segment size, 64MBytes
|
static int |
DFLT_WAL_SEGMENTS |
static boolean |
DFLT_WRITE_THROTTLING_ENABLED
Default write throttling enabled.
|
static long |
HALF_MAX_WAL_ARCHIVE_SIZE
Value used to indicate the use of half of the
getMaxWalArchiveSize() . |
static int |
MAX_PAGE_SIZE
Max memory page size.
|
static int |
MIN_PAGE_SIZE
Min memory page size.
|
static long |
UNLIMITED_WAL_ARCHIVE
Value used for making WAL archive size unlimited.
|
Constructor and Description |
---|
DataStorageConfiguration()
Creates valid durable memory configuration with all default values.
|
Modifier and Type | Method and Description |
---|---|
long |
getCdcWalDirectoryMaxSize()
Sets the
CDC directory maximum size in bytes. |
String |
getCdcWalPath()
Gets a path to the CDC directory.
|
long |
getCheckpointFrequency()
Gets checkpoint frequency.
|
Long |
getCheckpointReadLockTimeout()
Returns timeout for checkpoint read lock acquisition.
|
int |
getCheckpointThreads()
Gets a number of threads to use for the checkpoint purposes.
|
CheckpointWriteOrder |
getCheckpointWriteOrder()
This property defines order of writing pages to disk storage during checkpoint.
|
int |
getConcurrencyLevel()
Returns the number of concurrent segments in Ignite internal page mapping tables.
|
DataRegionConfiguration[] |
getDataRegionConfigurations()
Gets an array of all data regions configured.
|
DataRegionConfiguration |
getDefaultDataRegionConfiguration() |
@Nullable WarmUpConfiguration |
getDefaultWarmUpConfiguration()
Gets default warm-up configuration.
|
int |
getDefragmentationThreadPoolSize()
Maximum number of partitions which can be defragmented at the same time.
|
EncryptionConfiguration |
getEncryptionConfiguration()
Gets encryyption configuration.
|
org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory |
getFileIOFactory()
Factory to provide implementation of FileIO interface
which is used for data storage files read/write operations
|
long |
getLockWaitTime()
Timeout in milliseconds to wait when acquiring persistence store lock file before failing the local node.
|
long |
getMaxWalArchiveSize()
Gets a max allowed size(in bytes) of WAL archives.
|
@Nullable MemoryAllocator |
getMemoryAllocator() |
long |
getMetricsRateTimeInterval()
Deprecated.
Use
MetricsMxBean.configureHitRateMetric(String, long) instead. |
int |
getMetricsSubIntervalCount()
Deprecated.
Use
MetricsMxBean.configureHitRateMetric(String, long) instead. |
long |
getMinWalArchiveSize()
Gets a min allowed size(in bytes) of WAL archives.
|
int |
getPageSize()
The page memory consists of one or more expandable data regions defined by
DataRegionConfiguration . |
String |
getStoragePath() |
SystemDataRegionConfiguration |
getSystemDataRegionConfiguration()
Configuration of system data region.
|
long |
getSystemRegionInitialSize()
Deprecated.
|
long |
getSystemRegionMaxSize()
Deprecated.
|
String |
getWalArchivePath()
Gets a path to the WAL archive directory.
|
long |
getWalAutoArchiveAfterInactivity() |
int |
getWalBufferSize()
Property defines size(in bytes) of WAL buffer.
|
int |
getWalCompactionLevel() |
long |
getWalFlushFrequency()
This property define how often WAL will be fsync-ed in
BACKGROUND mode. |
long |
getWalForceArchiveTimeout() |
long |
getWalFsyncDelayNanos() |
int |
getWalHistorySize()
Deprecated.
Instead of walHistorySize use maxWalArchiveSize for manage of archive size.
|
WALMode |
getWalMode()
Property that defines behavior of wal fsync.
|
DiskPageCompression |
getWalPageCompression()
Gets compression algorithm for WAL page snapshot records.
|
Integer |
getWalPageCompressionLevel()
Gets
algorithm specific WAL page compression level. |
String |
getWalPath()
Gets a path to the directory where WAL is stored.
|
int |
getWalRecordIteratorBufferSize()
Property define how many bytes iterator read from
disk (for one reading), during go ahead wal.
|
int |
getWalSegments()
Gets a number of WAL segments to work with.
|
int |
getWalSegmentSize()
Gets size(in bytes) of a WAL segment.
|
int |
getWalThreadLocalBufferSize()
Property for size of thread local buffer.
|
boolean |
isAlwaysWriteFullPages() |
boolean |
isMetricsEnabled()
Deprecated.
Will be removed in upcoming releases.
|
boolean |
isWalCompactionEnabled() |
boolean |
isWalHistorySizeParameterUsed()
If WalHistorySize was set by user will use this parameter for compatibility.
|
boolean |
isWriteThrottlingEnabled() |
DataStorageConfiguration |
setAlwaysWriteFullPages(boolean alwaysWriteFullPages)
Sets flag that enforces writing full page to WAL on every change (instead of delta record).
|
DataStorageConfiguration |
setCdcWalDirectoryMaxSize(long cdcWalDirMaxSize)
Sets the CDC directory maximum size in bytes.
|
DataStorageConfiguration |
setCdcWalPath(String cdcWalPath)
Sets a path for the CDC directory.
|
DataStorageConfiguration |
setCheckpointFrequency(long checkpointFreq)
Sets the checkpoint frequency which is a minimal interval when the dirty pages will be written
to the Persistent Store.
|
DataStorageConfiguration |
setCheckpointReadLockTimeout(long checkpointReadLockTimeout)
Sets timeout for checkpoint read lock acquisition.
|
DataStorageConfiguration |
setCheckpointThreads(int checkpointThreads)
Sets a number of threads to use for the checkpoint purposes.
|
DataStorageConfiguration |
setCheckpointWriteOrder(CheckpointWriteOrder checkpointWriteOrder)
This property defines order of writing pages to disk storage during checkpoint.
|
DataStorageConfiguration |
setConcurrencyLevel(int concLvl)
Sets the number of concurrent segments in Ignite internal page mapping tables.
|
DataStorageConfiguration |
setDataRegionConfigurations(DataRegionConfiguration... dataRegionConfigurations)
Sets data regions configurations.
|
DataStorageConfiguration |
setDefaultDataRegionConfiguration(DataRegionConfiguration dfltDataRegConf)
Overrides configuration of default data region which has been created automatically.
|
DataStorageConfiguration |
setDefaultWarmUpConfiguration(@Nullable WarmUpConfiguration dfltWarmUpCfg)
Sets default warm-up configuration.
|
DataStorageConfiguration |
setDefragmentationThreadPoolSize(int defragmentationThreadPoolSize)
Sets maximum number of partitions which can be defragmented at the same time.
|
DataStorageConfiguration |
setEncryptionConfiguration(EncryptionConfiguration encCfg)
Sets encryption configuration.
|
DataStorageConfiguration |
setFileIOFactory(org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory fileIOFactory)
Sets factory to provide implementation of FileIO interface
which is used for data storage files read/write operations
|
DataStorageConfiguration |
setLockWaitTime(long lockWaitTime)
Timeout in milliseconds to wait when acquiring persistence store lock file before failing the local node.
|
DataStorageConfiguration |
setMaxWalArchiveSize(long walArchiveMaxSize)
Sets a max allowed size(in bytes) of WAL archives.
|
DataStorageConfiguration |
setMemoryAllocator(MemoryAllocator allocator)
Sets default memory allocator for all memory regions.
|
DataStorageConfiguration |
setMetricsEnabled(boolean metricsEnabled)
Deprecated.
Will be removed in upcoming releases.
|
DataStorageConfiguration |
setMetricsRateTimeInterval(long metricsRateTimeInterval)
Deprecated.
Use
MetricsMxBean.configureHitRateMetric(String, long) instead. |
DataStorageConfiguration |
setMetricsSubIntervalCount(int metricsSubIntervalCnt)
Deprecated.
Use
MetricsMxBean.configureHitRateMetric(String, long) instead. |
DataStorageConfiguration |
setMinWalArchiveSize(long walArchiveMinSize)
Sets a min allowed size(in bytes) of WAL archives.
|
DataStorageConfiguration |
setPageSize(int pageSize)
Changes the page size.
|
DataStorageConfiguration |
setStoragePath(String persistenceStorePath)
Sets a path to the root directory where the Persistent Store will persist data and indexes.
|
DataStorageConfiguration |
setSystemDataRegionConfiguration(SystemDataRegionConfiguration sysDataRegConf)
Overrides configuration of system data region which has been created automatically.
|
DataStorageConfiguration |
setSystemRegionInitialSize(long sysRegionInitSize)
Deprecated.
|
DataStorageConfiguration |
setSystemRegionMaxSize(long sysRegionMaxSize)
Deprecated.
|
DataStorageConfiguration |
setWalArchivePath(String walArchivePath)
Sets a path for the WAL archive directory.
|
DataStorageConfiguration |
setWalAutoArchiveAfterInactivity(long walAutoArchiveAfterInactivity)
Note: setting this value with
WALMode.FSYNC may generate file size overhead for WAL segments in case
grid is used rarely. |
DataStorageConfiguration |
setWalBufferSize(int walBuffSize)
Property defines size(in bytes) of WAL buffer.
|
DataStorageConfiguration |
setWalCompactionEnabled(boolean walCompactionEnabled)
Sets flag indicating whether WAL compaction is enabled.
|
void |
setWalCompactionLevel(int walCompactionLevel) |
DataStorageConfiguration |
setWalFlushFrequency(long walFlushFreq)
This property define how often WAL will be fsync-ed in
BACKGROUND mode. |
DataStorageConfiguration |
setWalForceArchiveTimeout(long walForceArchiveTimeout) |
DataStorageConfiguration |
setWalFsyncDelayNanos(long walFsyncDelayNanos)
Sets property that allows to trade latency for throughput in
WALMode.FSYNC mode. |
DataStorageConfiguration |
setWalHistorySize(int walHistSize)
Deprecated.
Instead of walHistorySize use maxWalArchiveSize for manage of archive size.
|
DataStorageConfiguration |
setWalMode(WALMode walMode)
Sets property that defines behavior of wal fsync.
|
DataStorageConfiguration |
setWalPageCompression(DiskPageCompression walPageCompression)
Sets compression algorithm for WAL page snapshot records.
|
DataStorageConfiguration |
setWalPageCompressionLevel(Integer walPageCompressionLevel)
Sets
algorithm specific page compression level. |
DataStorageConfiguration |
setWalPath(String walStorePath)
Sets a path to the directory where WAL is stored.
|
DataStorageConfiguration |
setWalRecordIteratorBufferSize(int walRecordIterBuffSize)
Sets property defining how many bytes iterator read from
disk (for one reading), during go ahead wal.
|
DataStorageConfiguration |
setWalSegments(int walSegments)
Sets a number of WAL segments to work with.
|
DataStorageConfiguration |
setWalSegmentSize(int walSegmentSize)
Sets size(in bytes) of a WAL segment.
|
DataStorageConfiguration |
setWalThreadLocalBufferSize(int walTlbSize)
Sets size of thread local buffer.
|
DataStorageConfiguration |
setWriteThrottlingEnabled(boolean writeThrottlingEnabled)
Sets flag indicating whether write throttling is enabled.
|
String |
toString() |
public static final long UNLIMITED_WAL_ARCHIVE
public static final long DFLT_DATA_REGION_INITIAL_SIZE
public static final long DFLT_DATA_REGION_MAX_SIZE
public static final int DFLT_PAGE_SIZE
public static final int MAX_PAGE_SIZE
public static final int MIN_PAGE_SIZE
public static final String DFLT_DATA_REG_DEFAULT_NAME
public static final int DFLT_CHECKPOINT_FREQ
public static final int DFLT_LOCK_WAIT_TIME
@Deprecated public static final boolean DFLT_METRICS_ENABLED
public static final int DFLT_SUB_INTERVALS
public static final int DFLT_RATE_TIME_INTERVAL_MILLIS
public static final int DFLT_CHECKPOINT_THREADS
public static final CheckpointWriteOrder DFLT_CHECKPOINT_WRITE_ORDER
public static final int DFLT_WAL_HISTORY_SIZE
public static final long DFLT_WAL_ARCHIVE_MAX_SIZE
public static final int DFLT_WAL_SEGMENTS
public static final int DFLT_WAL_SEGMENT_SIZE
public static final WALMode DFLT_WAL_MODE
public static final int DFLT_TLB_SIZE
public static final int DFLT_WAL_BUFF_SIZE
public static final int DFLT_WAL_FLUSH_FREQ
public static final int DFLT_WAL_FSYNC_DELAY
public static final int DFLT_WAL_RECORD_ITERATOR_BUFFER_SIZE
public static final boolean DFLT_WAL_ALWAYS_WRITE_FULL_PAGES
public static final String DFLT_WAL_PATH
public static final String DFLT_WAL_ARCHIVE_PATH
public static final String DFLT_WAL_CDC_PATH
public static final long DFLT_CDC_WAL_DIRECTORY_MAX_SIZE
public static final String DFLT_BINARY_METADATA_PATH
public static final String DFLT_MARSHALLER_PATH
public static final boolean DFLT_WRITE_THROTTLING_ENABLED
public static final boolean DFLT_WAL_COMPACTION_ENABLED
public static final int DFLT_WAL_COMPACTION_LEVEL
public static final int DFLT_DEFRAGMENTATION_THREAD_POOL_SIZE
public static final DiskPageCompression DFLT_WAL_PAGE_COMPRESSION
public static final boolean DFLT_USE_ASYNC_FILE_IO_FACTORY
public static final long HALF_MAX_WAL_ARCHIVE_SIZE
getMaxWalArchiveSize()
.public DataStorageConfiguration()
@Deprecated public long getSystemRegionInitialSize()
SystemDataRegionConfiguration.getInitialSize()
.@Deprecated public DataStorageConfiguration setSystemRegionInitialSize(long sysRegionInitSize)
SystemDataRegionConfiguration.setInitialSize(long)
.sysRegionInitSize
- Size in bytes.this
for chaining.@Deprecated public long getSystemRegionMaxSize()
SystemDataRegionConfiguration.getMaxSize()
.@Deprecated public DataStorageConfiguration setSystemRegionMaxSize(long sysRegionMaxSize)
SystemDataRegionConfiguration.setMaxSize(long)
.sysRegionMaxSize
- Maximum size in bytes for system cache data region.this
for chaining.public int getPageSize()
DataRegionConfiguration
.
Every data region is split on pages of fixed size that store actual cache entries.public DataStorageConfiguration setPageSize(int pageSize)
pageSize
- Page size in bytes. Supported values are: 1024
, 2048
, 4096
, 8192
and 16384
. If value is not set (or zero), DFLT_PAGE_SIZE
(4096
) will be used.this
for chaining.MIN_PAGE_SIZE
,
MAX_PAGE_SIZE
public DataRegionConfiguration[] getDataRegionConfigurations()
CacheConfiguration.setDataRegionName(String)
method.public DataStorageConfiguration setDataRegionConfigurations(DataRegionConfiguration... dataRegionConfigurations)
dataRegionConfigurations
- Data regions configurations.this
for chaining.public int getConcurrencyLevel()
public DataStorageConfiguration setConcurrencyLevel(int concLvl)
concLvl
- Mapping table concurrency level.this
for chaining.public DataRegionConfiguration getDefaultDataRegionConfiguration()
CacheConfiguration.setDataRegionName(String)
.public DataStorageConfiguration setDefaultDataRegionConfiguration(DataRegionConfiguration dfltDataRegConf)
dfltDataRegConf
- Default data region configuration.this
for chaining.public SystemDataRegionConfiguration getSystemDataRegionConfiguration()
public DataStorageConfiguration setSystemDataRegionConfiguration(SystemDataRegionConfiguration sysDataRegConf)
sysDataRegConf
- System data region configuration.this
for chaining.public String getStoragePath()
public DataStorageConfiguration setStoragePath(String persistenceStorePath)
persistenceStorePath
- Persistence store path.this
for chaining.public long getCheckpointFrequency()
public DataStorageConfiguration setCheckpointFrequency(long checkpointFreq)
DFLT_CHECKPOINT_FREQ
will be used.checkpointFreq
- Checkpoint frequency in milliseconds.this
for chaining.public int getCheckpointThreads()
public DataStorageConfiguration setCheckpointThreads(int checkpointThreads)
checkpointThreads
- Number of checkpoint threads. Four threads are used by default.this
for chaining.public long getLockWaitTime()
public DataStorageConfiguration setLockWaitTime(long lockWaitTime)
lockWaitTime
- Lock wait time in milliseconds.this
for chaining.@Deprecated public int getWalHistorySize()
getMaxWalArchiveSize()
@Deprecated public DataStorageConfiguration setWalHistorySize(int walHistSize)
walHistSize
- Number of checkpoints to keep after a checkpoint is finished.this
for chaining.setMaxWalArchiveSize(long)
public boolean isWalHistorySizeParameterUsed()
true
if use WalHistorySize for compatibility.public long getMaxWalArchiveSize()
UNLIMITED_WAL_ARCHIVE
if
WAL archive size is unlimited).public DataStorageConfiguration setMaxWalArchiveSize(long walArchiveMaxSize)
UNLIMITED_WAL_ARCHIVE
, DFLT_WAL_ARCHIVE_MAX_SIZE
will be used.walArchiveMaxSize
- max size(in bytes) of WAL archive directory.this
for chaining.public int getWalSegments()
public DataStorageConfiguration setWalSegments(int walSegments)
walSegments
- Number of WAL segments. Value must be greater than 1.this
for chaining.public int getWalSegmentSize()
public DataStorageConfiguration setWalSegmentSize(int walSegmentSize)
DFLT_WAL_SEGMENT_SIZE
will be used.walSegmentSize
- WAL segment size(in bytes). Value must be between 512Kb and 2Gb.This
for chaining.public String getWalPath()
public DataStorageConfiguration setWalPath(String walStorePath)
walStorePath
- WAL persistence path, absolute or relative to Ignite work directory.this
for chaining.public String getWalArchivePath()
public DataStorageConfiguration setWalArchivePath(String walArchivePath)
walArchivePath
- WAL archive directory.this
for chaining.public String getCdcWalPath()
public DataStorageConfiguration setCdcWalPath(String cdcWalPath)
cdcWalPath
- CDC directory.this
for chaining.public long getCdcWalDirectoryMaxSize()
CDC directory
maximum size in bytes.public DataStorageConfiguration setCdcWalDirectoryMaxSize(long cdcWalDirMaxSize)
directory
exceeds the limit.
The CDC application will log an error due to a gap in wal files sequence. Note that cache changes will be lost.
Default is no limit.cdcWalDirMaxSize
- CDC directory maximum size in bytes.this
for chaining.@Deprecated public boolean isMetricsEnabled()
DFLT_METRICS_ENABLED
.@Deprecated public DataStorageConfiguration setMetricsEnabled(boolean metricsEnabled)
metricsEnabled
- Metrics enabled flag.this
for chaining.public boolean isWriteThrottlingEnabled()
public DataStorageConfiguration setWriteThrottlingEnabled(boolean writeThrottlingEnabled)
writeThrottlingEnabled
- Write throttling enabled flag.this
for chaining.@Deprecated public long getMetricsRateTimeInterval()
MetricsMxBean.configureHitRateMetric(String, long)
instead.DFLT_RATE_TIME_INTERVAL_MILLIS
.@Deprecated public DataStorageConfiguration setMetricsRateTimeInterval(long metricsRateTimeInterval)
MetricsMxBean.configureHitRateMetric(String, long)
instead.metricsRateTimeInterval
- Time interval in milliseconds.this
for chaining.@Deprecated public int getMetricsSubIntervalCount()
MetricsMxBean.configureHitRateMetric(String, long)
instead.getMetricsRateTimeInterval()
into to track the update history.
Default value is DFLT_SUB_INTERVALS
.@Deprecated public DataStorageConfiguration setMetricsSubIntervalCount(int metricsSubIntervalCnt)
MetricsMxBean.configureHitRateMetric(String, long)
instead.getMetricsRateTimeInterval()
into to track the update history.metricsSubIntervalCnt
- The number of sub-intervals for history tracking.this
for chaining.public WALMode getWalMode()
WALMode
for details.public DataStorageConfiguration setWalMode(WALMode walMode)
WALMode
for details.walMode
- Wal mode.this
for chaining.public int getWalThreadLocalBufferSize()
public DataStorageConfiguration setWalThreadLocalBufferSize(int walTlbSize)
walTlbSize
- Thread local buffer size (in bytes).this
for chaining.public int getWalBufferSize()
public DataStorageConfiguration setWalBufferSize(int walBuffSize)
getWalSegmentSize()
.walBuffSize
- WAL buffer size(in bytes).this
for chaining.public long getWalFlushFrequency()
BACKGROUND
mode. Ignored for
all other WAL modes.public DataStorageConfiguration setWalFlushFrequency(long walFlushFreq)
BACKGROUND
mode. Ignored for
all other WAL modes.walFlushFreq
- WAL flush frequency, in milliseconds.this
for chaining.public long getWalFsyncDelayNanos()
WALMode.FSYNC
mode.
It limits minimum time interval between WAL fsyncs. First thread that initiates WAL fsync will wait for
this number of nanoseconds, another threads will just wait fsync of first thread (similar to CyclicBarrier).
Total throughput should increase under load as total WAL fsync rate will be limited.public DataStorageConfiguration setWalFsyncDelayNanos(long walFsyncDelayNanos)
WALMode.FSYNC
mode.
It limits minimum time interval between WAL fsyncs. First thread that initiates WAL fsync will wait for
this number of nanoseconds, another threads will just wait fsync of first thread (similar to CyclicBarrier).
Total throughput should increase under load as total WAL fsync rate will be limited.walFsyncDelayNanos
- Wal fsync delay, in nanoseconds.this
for chaining.public int getWalRecordIteratorBufferSize()
public DataStorageConfiguration setWalRecordIteratorBufferSize(int walRecordIterBuffSize)
walRecordIterBuffSize
- Wal record iterator buffer size.this
for chaining.public boolean isAlwaysWriteFullPages()
public DataStorageConfiguration setAlwaysWriteFullPages(boolean alwaysWriteFullPages)
alwaysWriteFullPages
- Always write full pages flag.this
for chaining.public org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory getFileIOFactory()
public DataStorageConfiguration setFileIOFactory(org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory fileIOFactory)
fileIOFactory
- File I/O factorythis
for chaining.public DataStorageConfiguration setWalAutoArchiveAfterInactivity(long walAutoArchiveAfterInactivity)
WALMode.FSYNC
may generate file size overhead for WAL segments in case
grid is used rarely.walAutoArchiveAfterInactivity
- time in millis to run auto archiving segment (even if incomplete) after last
record logging. public long getWalAutoArchiveAfterInactivity()
public DataStorageConfiguration setWalForceArchiveTimeout(long walForceArchiveTimeout)
walForceArchiveTimeout
- Time in millis after last data change logged to run segment auto archivation
(even if incomplete).public long getWalForceArchiveTimeout()
public CheckpointWriteOrder getCheckpointWriteOrder()
public DataStorageConfiguration setCheckpointWriteOrder(CheckpointWriteOrder checkpointWriteOrder)
checkpointWriteOrder
- Checkpoint write order.this
for chaining.public boolean isWalCompactionEnabled()
public DataStorageConfiguration setWalCompactionEnabled(boolean walCompactionEnabled)
walCompactionEnabled
- Wal compaction enabled flag.this
for chaining.public int getWalCompactionLevel()
public void setWalCompactionLevel(int walCompactionLevel)
walCompactionLevel
- New ZIP level to WAL compaction.public Long getCheckpointReadLockTimeout()
setCheckpointReadLockTimeout(long)
public DataStorageConfiguration setCheckpointReadLockTimeout(long checkpointReadLockTimeout)
When any thread cannot acquire checkpoint read lock in this time, then critical failure handler is being called.
checkpointReadLockTimeout
- Timeout for checkpoint read lock acquisition in milliseconds.this
for chaining.public DiskPageCompression getWalPageCompression()
public DataStorageConfiguration setWalPageCompression(DiskPageCompression walPageCompression)
walPageCompression
- Page compression algorithm.this
for chaining.public Integer getWalPageCompressionLevel()
algorithm
specific WAL page compression level.null
for default.public DataStorageConfiguration setWalPageCompressionLevel(Integer walPageCompressionLevel)
algorithm
specific page compression level.public EncryptionConfiguration getEncryptionConfiguration()
public DataStorageConfiguration setEncryptionConfiguration(EncryptionConfiguration encCfg)
encCfg
- Encryption configuration.this
for chaining.public DataStorageConfiguration setDefaultWarmUpConfiguration(@Nullable @Nullable WarmUpConfiguration dfltWarmUpCfg)
dfltWarmUpCfg
- Default warm-up configuration. To assign a special
warm-up configuration for a data region, use
DataRegionConfiguration.setWarmUpConfiguration(org.apache.ignite.configuration.WarmUpConfiguration)
.this
for chaining.@Nullable public @Nullable WarmUpConfiguration getDefaultWarmUpConfiguration()
public DataStorageConfiguration setDefragmentationThreadPoolSize(int defragmentationThreadPoolSize)
defragmentationThreadPoolSize
- Maximum number of partitions which can be defragmented at the same time.
Default is DFLT_DEFRAGMENTATION_THREAD_POOL_SIZE
.this
for chaining.public int getDefragmentationThreadPoolSize()
public long getMinWalArchiveSize()
HALF_MAX_WAL_ARCHIVE_SIZE
).public DataStorageConfiguration setMinWalArchiveSize(long walArchiveMinSize)
HALF_MAX_WAL_ARCHIVE_SIZE
will be used.walArchiveMinSize
- min size(in bytes) of WAL archive directory.this
for chaining.@Nullable public @Nullable MemoryAllocator getMemoryAllocator()
public DataStorageConfiguration setMemoryAllocator(MemoryAllocator allocator)
Unsafe
allocator will be used. Allocator can be overrided for data region using
DataRegionConfiguration.setMemoryAllocator(MemoryAllocator)
allocator
- Memory allocator instance.this
for chaining.
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.16.0 Release Date : December 15 2023