org.apache.ignite.internal.processors.cache.persistence.file

Class FileVersionCheckingFactory

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.file.FileVersionCheckingFactory

All Implemented Interfaces:

FilePageStoreFactory

public class FileVersionCheckingFactory
extends Object
implements FilePageStoreFactory

Checks version in files if it's present on the disk, creates store with latest version otherwise.

Field Summary

Fields

Modifier and Type	Field and Description
static int	LATEST_VERSION Latest page store version.
static String	LATEST_VERSION_OVERRIDE_PROPERTY Property to override latest version.

Constructor Summary

Constructors

Constructor and Description
FileVersionCheckingFactory(FileIOFactory fileIOFactory, FileIOFactory fileIOFactoryStoreV1, DataStorageConfiguration memCfg)

Method Summary

Modifier and Type	Method and Description
PageStore	createPageStore(byte type, IgniteOutClosure<Path> pathProvider, LongAdderMetric allocatedTracker) Creates instance of PageStore based on file path provider.
int	headerSize(int ver)
int	latestVersion() Resolves latest page store version.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cache.persistence.file.FilePageStoreFactory

createPageStore

Field Detail

LATEST_VERSION_OVERRIDE_PROPERTY

public static final String LATEST_VERSION_OVERRIDE_PROPERTY

Property to override latest version. Should be used only in tests.

See Also:

Constant Field Values

LATEST_VERSION

public static final int LATEST_VERSION

Latest page store version.

See Also:

Constant Field Values

Constructor Detail

FileVersionCheckingFactory

public FileVersionCheckingFactory(FileIOFactory fileIOFactory,
                                  FileIOFactory fileIOFactoryStoreV1,
                                  DataStorageConfiguration memCfg)

Parameters:

fileIOFactory - File IO factory.

fileIOFactoryStoreV1 - File IO factory for V1 page store and for version checking.

memCfg - Memory configuration.

Method Detail

createPageStore

public PageStore createPageStore(byte type,
                                 IgniteOutClosure<Path> pathProvider,
                                 LongAdderMetric allocatedTracker)
                          throws IgniteCheckedException

Creates instance of PageStore based on file path provider.

Specified by:

createPageStore in interface FilePageStoreFactory

Parameters:

type - Data type, can be PageIdAllocator.FLAG_IDX or PageIdAllocator.FLAG_DATA

pathProvider - File Page store path provider.

allocatedTracker - metrics updater

Returns:

page store

Throws:

IgniteCheckedException - if failed

latestVersion

public int latestVersion()

Resolves latest page store version.

headerSize

public int headerSize(int ver)

Parameters:

ver - Version.

Returns:

Header size.