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

Class MetaStorage

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.metastorage.MetaStorage

All Implemented Interfaces:

CheckpointListener, ReadOnlyMetastorage, ReadWriteMetastorage

public class MetaStorage
extends Object
implements CheckpointListener, ReadWriteMetastorage

General purpose key-value local-only storage.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetaStorage.TmpStorage Temporary storage

Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.cache.persistence.checkpoint.CheckpointListener

CheckpointListener.Context

Field Summary

Fields

Modifier and Type	Field and Description
static int	METASTORAGE_CACHE_ID
static String	METASTORAGE_CACHE_NAME
static boolean	PRESERVE_LEGACY_METASTORAGE_PARTITION_ID This flag is used ONLY FOR TESTING the migration of a metastorage from Part 0 to Part 1.

Constructor Summary

Constructors

Constructor and Description
MetaStorage(GridCacheSharedContext<?,?> cctx, DataRegion dataRegion, DataRegionMetricsImpl regionMetrics, boolean readOnly)

Method Summary

Modifier and Type	Method and Description
void	applyUpdate(String key, byte[] value)
void	beforeCheckpointBegin(CheckpointListener.Context ctx) Do some actions before checkpoint write lock.
void	init(GridCacheDatabaseSharedManager db)
void	iterate(String keyPrefix, BiConsumer<String,? super Serializable> cb, boolean unmarshal) Read all key/value pairs where key has provided prefix.
Marshaller	marshaller()
void	onCheckpointBegin(CheckpointListener.Context ctx)
void	onMarkCheckpointBegin(CheckpointListener.Context ctx)
PageMemory	pageMemory()
Serializable	read(String key)
byte[]	readRaw(String key)
void	remove(@NotNull String key)
void	removeData(String key)
void	write(@NotNull String key, @NotNull Serializable val)
void	writeRaw(String key, byte[] data)

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.checkpoint.CheckpointListener

afterCheckpointEnd

Field Detail

METASTORAGE_CACHE_NAME

public static final String METASTORAGE_CACHE_NAME

See Also:

Constant Field Values

METASTORAGE_CACHE_ID

public static final int METASTORAGE_CACHE_ID

PRESERVE_LEGACY_METASTORAGE_PARTITION_ID

public static boolean PRESERVE_LEGACY_METASTORAGE_PARTITION_ID

This flag is used ONLY FOR TESTING the migration of a metastorage from Part 0 to Part 1.

Constructor Detail

MetaStorage

public MetaStorage(GridCacheSharedContext<?,?> cctx,
                   DataRegion dataRegion,
                   DataRegionMetricsImpl regionMetrics,
                   boolean readOnly)

Method Detail

init

public void init(GridCacheDatabaseSharedManager db)
          throws IgniteCheckedException

Throws:

IgniteCheckedException

read

public Serializable read(String key)
                  throws IgniteCheckedException

Specified by:

read in interface ReadOnlyMetastorage

Throws:

IgniteCheckedException

iterate

public void iterate(String keyPrefix,
                    BiConsumer<String,? super Serializable> cb,
                    boolean unmarshal)
             throws IgniteCheckedException

Read all key/value pairs where key has provided prefix. It is guaranteed that callback will be applied to matching keys in ascending order.

Specified by:

iterate in interface ReadOnlyMetastorage

Parameters:

keyPrefix - Key prefix.

cb - Callback to invoke on each matching key/value pair.

unmarshal - True if object passed into cb should be unmarshalled.

Throws:

IgniteCheckedException - If failed.

write

public void write(@NotNull
                  @NotNull String key,
                  @NotNull
                  @NotNull Serializable val)
           throws IgniteCheckedException

Specified by:

write in interface ReadWriteMetastorage

Throws:

IgniteCheckedException

remove

public void remove(@NotNull
                   @NotNull String key)
            throws IgniteCheckedException

Specified by:

remove in interface ReadWriteMetastorage

Throws:

IgniteCheckedException

writeRaw

public void writeRaw(String key,
                     byte[] data)
              throws IgniteCheckedException

Specified by:

writeRaw in interface ReadWriteMetastorage

Throws:

IgniteCheckedException

readRaw

public byte[] readRaw(String key)
               throws IgniteCheckedException

Specified by:

readRaw in interface ReadOnlyMetastorage

Throws:

IgniteCheckedException

removeData

public void removeData(String key)
                throws IgniteCheckedException

Throws:

IgniteCheckedException

pageMemory

public PageMemory pageMemory()

Returns:

Page memory.

onMarkCheckpointBegin

public void onMarkCheckpointBegin(CheckpointListener.Context ctx)
                           throws IgniteCheckedException

Specified by:

onMarkCheckpointBegin in interface CheckpointListener

Throws:

IgniteCheckedException - If failed.

beforeCheckpointBegin

public void beforeCheckpointBegin(CheckpointListener.Context ctx)
                           throws IgniteCheckedException

Do some actions before checkpoint write lock.

Specified by:

beforeCheckpointBegin in interface CheckpointListener

Throws:

IgniteCheckedException - If failed.

onCheckpointBegin

public void onCheckpointBegin(CheckpointListener.Context ctx)
                       throws IgniteCheckedException

Specified by:

onCheckpointBegin in interface CheckpointListener

Throws:

IgniteCheckedException - If failed.

applyUpdate

public void applyUpdate(String key,
                        byte[] value)
                 throws IgniteCheckedException

Throws:

IgniteCheckedException

marshaller

public Marshaller marshaller()