com.bigdata.rdf.changesets

Interface IChangeLog

All Known Implementing Classes:

BigdataGraphBulkLoad, BigdataGraphEmbedded, DelegatingChangeLog, InferenceChangeLogReporter, InMemChangeLog, MutationListener, RDRHistory, TestRDRHistory.CustomRDRHistory, TestSparqlUpdateCommit.CommitCounter

public interface IChangeLog

Provides detailed information on changes made to statements in the database. Change records are generated for any statements that are used in addStatement() or removeStatements() operations on the SAIL connection, as well as any inferred statements that are added or removed as a result of truth maintenance when the database has inference enabled. Change records will be sent to an instance of this class via the changeEvent(IChangeRecord) method. These events will occur on an ongoing basis as statements are added to or removed from the indices. It is the change log's responsibility to collect change records. When the transaction is actually committed (or aborted), the change log will receive notification via #transactionCommited() or transactionAborted().

Method Summary

Methods

Modifier and Type	Method and Description
void	changeEvent(IChangeRecord record) Occurs when a statement add or remove is flushed to the indices (but not yet committed).
void	close() Close any open resources.
void	transactionAborted() Occurs if the current SAIL transaction is aborted.
void	transactionBegin() Message issued when a new transaction will begin.
void	transactionCommited(long commitTime) Occurs when the current SAIL transaction is committed.
void	transactionPrepare() Message issued when preparing for a commit.

Method Detail

changeEvent

void changeEvent(IChangeRecord record)

Occurs when a statement add or remove is flushed to the indices (but not yet committed).

Parameters:

record - the IChangeRecord

transactionBegin

void transactionBegin()

Message issued when a new transaction will begin.

transactionPrepare

void transactionPrepare()

Message issued when preparing for a commit. The next message will be either transactionCommited(long) or transactionAborted().

Note: The listener will have observed all updates by the time this message is generated. Thus, this message can be used to validate post-conditions for the transaction.

transactionCommited

void transactionCommited(long commitTime)

Occurs when the current SAIL transaction is committed.

Parameters:

commitTime - The timestamp associated with the commit point.

transactionAborted

void transactionAborted()

Occurs if the current SAIL transaction is aborted.

close

void close()

Close any open resources.