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

Class CheckpointHistory

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.checkpoint.CheckpointHistory

public class CheckpointHistory
extends Object

Checkpoint history. Holds chronological ordered map with CheckpointEntries. Data is loaded from corresponding checkpoint directory. This directory holds files for checkpoint start and end.

Constructor Summary

Constructors

Constructor and Description
CheckpointHistory(GridKernalContext ctx) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addCheckpoint(CheckpointEntry entry) Adds checkpoint entry after the corresponding WAL record has been written to WAL.
Collection<Long>	checkpoints()
Collection<Long>	checkpoints(boolean descending)
CheckpointEntry	firstCheckpoint()
WALPointer	firstCheckpointPointer()
boolean	hasSpace()
void	initialize(List<CheckpointEntry> checkpoints)
CheckpointEntry	lastCheckpoint()
CheckpointEntry	lastCheckpointMarkingAsInapplicable(Integer grpId) Prepare last checkpoint in history that will marked as inapplicable.
List<CheckpointEntry>	onCheckpointFinished(GridCacheDatabaseSharedManager.Checkpoint chp, boolean truncateWal) Logs and clears checkpoint history after checkpoint finish.
List<CheckpointEntry>	onWalTruncated(WALPointer ptr) Clears checkpoint history after WAL truncation.
Map<Integer,Map<Integer,CheckpointEntry>>	searchAndReserveCheckpoints(Map<Integer,Set<Integer>> groupsAndPartitions) Finds and reserves earliest valid checkpoint for each of given groups and partitions.
@Nullable Map<GroupPartitionId,CheckpointEntry>	searchCheckpointEntry(Map<T2<Integer,Integer>,Long> searchCntrMap) Tries to search for a WAL pointer for the given partition counter start.
@Nullable WALPointer	searchEarliestWalPointer(int grpId, Map<Integer,Long> partsCounter) Search the earliest WAL pointer for particular group, matching by counter for partitions.

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckpointHistory

public CheckpointHistory(GridKernalContext ctx)

Constructor.

Parameters:

ctx - Context.

Method Detail

initialize

public void initialize(List<CheckpointEntry> checkpoints)

Parameters:

checkpoints - Checkpoints.

firstCheckpoint

public CheckpointEntry firstCheckpoint()

Returns:

First checkpoint entry if exists. Otherwise null.

lastCheckpoint

public CheckpointEntry lastCheckpoint()

Returns:

Last checkpoint entry if exists. Otherwise null.

firstCheckpointPointer

public WALPointer firstCheckpointPointer()

Returns:

First checkpoint WAL pointer if exists. Otherwise null.

checkpoints

public Collection<Long> checkpoints(boolean descending)

Returns:

Collection of checkpoint timestamps.

checkpoints

public Collection<Long> checkpoints()

addCheckpoint

public void addCheckpoint(CheckpointEntry entry)

Adds checkpoint entry after the corresponding WAL record has been written to WAL. The checkpoint itself is not finished yet.

Parameters:

entry - Entry to add.

lastCheckpointMarkingAsInapplicable

public CheckpointEntry lastCheckpointMarkingAsInapplicable(Integer grpId)

Prepare last checkpoint in history that will marked as inapplicable.

Parameters:

grpId - Group id.

Returns:

Checkpoint witch it'd be marked as inapplicable.

hasSpace

public boolean hasSpace()

Returns:

true if there is space for next checkpoint.

onWalTruncated

public List<CheckpointEntry> onWalTruncated(WALPointer ptr)

Clears checkpoint history after WAL truncation.

Returns:

List of checkpoint entries removed from history.

onCheckpointFinished

public List<CheckpointEntry> onCheckpointFinished(GridCacheDatabaseSharedManager.Checkpoint chp,
                                                  boolean truncateWal)

Logs and clears checkpoint history after checkpoint finish.

Returns:

List of checkpoints removed from history.

searchEarliestWalPointer

@Nullable
public @Nullable WALPointer searchEarliestWalPointer(int grpId,
                                                               Map<Integer,Long> partsCounter)
                                                        throws IgniteCheckedException

Search the earliest WAL pointer for particular group, matching by counter for partitions.

Parameters:

grpId - Group id.

partsCounter - Partition mapped to update counter.

Returns:

Earliest WAL pointer for group specified.

Throws:

IgniteCheckedException

searchCheckpointEntry

@Nullable
public @Nullable Map<GroupPartitionId,CheckpointEntry> searchCheckpointEntry(Map<T2<Integer,Integer>,Long> searchCntrMap)

Tries to search for a WAL pointer for the given partition counter start.

Parameters:

searchCntrMap - Search map contains (Group Id, partition, counter).

Returns:

Map of group-partition on checkpoint entry or empty map if nothing found.

searchAndReserveCheckpoints

public Map<Integer,Map<Integer,CheckpointEntry>> searchAndReserveCheckpoints(Map<Integer,Set<Integer>> groupsAndPartitions)

Finds and reserves earliest valid checkpoint for each of given groups and partitions.

Parameters:

groupsAndPartitions - Groups and partitions to find and reserve earliest valid checkpoint.

Returns:

Map (groupId: Map (partitionId, earliest valid checkpoint to history search)).