com.bigdata.journal

Interface ICommitter

All Known Subinterfaces:

ICheckpointProtocol, ISolutionSet

All Known Implementing Classes:

AbstractBTree, AbstractHTree, BTree, CommitRecordIndex, CommitTimeIndex, CounterSetBTree, DeleteBlockCommitter, EventReceiver.EventBTree, HTree, IndexSegment, IndexSegmentIndex, JournalIndex, MetadataIndex, Name2Addr, RootBlockCommitter, SolutionSetStream, Stream, TestMROWTransactions.MyBTree, TestRestartSafe.MyBTree, TxId2CommitTimeIndex

public interface ICommitter

An interface implemented by a persistence capable data structure such as a btree so that it can participate in the commit protocol for the store.

This interface is invoked by AbstractJournal.commit() for each registered ICommitter. The address returned by #handleCommit() will be saved in the ICommitRecord under the index identified by the ICommitter when it was registered.

Author:

Bryan Thompson

See Also:

IAtomicStore.setCommitter(int, ICommitter)

Method Summary

Methods

Modifier and Type	Method and Description
long	handleCommit(long commitTime) Flush dirty state to the store in preparation for an atomic commit and return the address from which the persistence capable data structure may be reloaded.
void	invalidate(Throwable t) Mark an ICommitter as invalid.

Method Detail

handleCommit

long handleCommit(long commitTime)

Flush dirty state to the store in preparation for an atomic commit and return the address from which the persistence capable data structure may be reloaded.

Parameters:

commitTime - The timestamp assigned to the commit.

Returns:

The address of the record from which the persistence capable data structure may be reloaded. If no changes have been made then the previous address should be returned as it is still valid.

invalidate

void invalidate(Throwable t)

Mark an ICommitter as invalid. This will prevent it from allowing any writes through to the backing store.

Parameters:

t - A cause (required).

See Also:

https://jira.blazegraph.com/browse/BLZG-1953