com.bigdata.blueprints

Class MutationListener

java.lang.Object

com.bigdata.blueprints.MutationListener

All Implemented Interfaces:

IChangeLog

public class MutationListener
extends Object
implements IChangeLog

Constructor Summary

Constructors

Constructor and Description
MutationListener()

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	clear()
void	close() Close any open resources.
int	getNumInserted()
int	getNumRemoved()
int	getNumUpdated()
void	transactionAborted() Occurs if the current SAIL transaction is aborted.
void	transactionBegin() Message issued when a new transaction will begin.
void	transactionCommited(long arg0) Occurs when the current SAIL transaction is committed.
void	transactionPrepare() Message issued when preparing for a commit.

Methods inherited from class java.lang.Object

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

Constructor Detail

MutationListener

public MutationListener()

Method Detail

clear

public void clear()

getNumInserted

public int getNumInserted()

getNumRemoved

public int getNumRemoved()

getNumUpdated

public int getNumUpdated()

changeEvent

public void changeEvent(IChangeRecord record)

Description copied from interface: IChangeLog

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

Specified by:

changeEvent in interface IChangeLog

Parameters:

record - the IChangeRecord

close

public void close()

Description copied from interface: IChangeLog

Close any open resources.

Specified by:

close in interface IChangeLog

transactionAborted

public void transactionAborted()

Description copied from interface: IChangeLog

Occurs if the current SAIL transaction is aborted.

Specified by:

transactionAborted in interface IChangeLog

transactionBegin

public void transactionBegin()

Description copied from interface: IChangeLog

Message issued when a new transaction will begin.

Specified by:

transactionBegin in interface IChangeLog

transactionCommited

public void transactionCommited(long arg0)

Description copied from interface: IChangeLog

Occurs when the current SAIL transaction is committed.

Specified by:

transactionCommited in interface IChangeLog

Parameters:

arg0 - The timestamp associated with the commit point.

transactionPrepare

public void transactionPrepare()

Description copied from interface: IChangeLog

Message issued when preparing for a commit. The next message will be either IChangeLog.transactionCommited(long) or IChangeLog.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.

Specified by:

transactionPrepare in interface IChangeLog