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, DataStorageConfiguration memCfg)
FileVersionCheckingFactory(FileIOFactory fileIOFactory, FileIOFactory fileIOFactoryStoreV1, DataStorageConfiguration memCfg)

Method Summary

Modifier and Type	Method and Description
FilePageStore	createPageStore(byte type, File file, AllocatedPageTracker allocatedTracker) Creates instance of FilePageStore based on given file.
FilePageStore	createPageStore(byte type, File file, int ver, AllocatedPageTracker allocatedTracker) Instantiates specific version of FilePageStore.
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

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.

FileVersionCheckingFactory

public FileVersionCheckingFactory(FileIOFactory fileIOFactory,
                                  DataStorageConfiguration memCfg)

Parameters:

fileIOFactory - File IO factory for V1 & V2 page store and for version checking.

memCfg - Memory configuration.

Method Detail

createPageStore

public FilePageStore createPageStore(byte type,
                                     File file,
                                     AllocatedPageTracker allocatedTracker)
                              throws IgniteCheckedException

Creates instance of FilePageStore based on given file.

Specified by:

createPageStore in interface FilePageStoreFactory

Parameters:

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

file - File Page store file.

Throws:

IgniteCheckedException

latestVersion

public int latestVersion()

Resolves latest page store version.

createPageStore

public FilePageStore createPageStore(byte type,
                                     File file,
                                     int ver,
                                     AllocatedPageTracker allocatedTracker)

Instantiates specific version of FilePageStore.

Parameters:

type - Type.

file - File.

ver - Version.

allocatedTracker - Metrics updater