com.bigdata.rdf.changesets

Class DelegatingChangeLog

java.lang.Object

com.bigdata.rdf.changesets.DelegatingChangeLog

All Implemented Interfaces:

IChangeLog

public class DelegatingChangeLog
extends Object
implements IChangeLog

This delegating change log allows change events to be propagated to multiple delegates through a listener pattern.

Author:

mike

Constructor Summary

Constructors

Constructor and Description
DelegatingChangeLog()

Method Summary

Methods

Modifier and Type	Method and Description
void	addDelegate(IChangeLog delegate)
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	removeDelegate(IChangeLog delegate)
String	toString()
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingChangeLog

public DelegatingChangeLog()

Method Detail

toString

public String toString()

Overrides:

toString in class Object

addDelegate

public void addDelegate(IChangeLog delegate)

removeDelegate

public void removeDelegate(IChangeLog delegate)

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

transactionBegin

public void transactionBegin()

Description copied from interface: IChangeLog

Message issued when a new transaction will begin.

Specified by:

transactionBegin in interface IChangeLog

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

transactionCommited

public void transactionCommited(long commitTime)

Description copied from interface: IChangeLog

Occurs when the current SAIL transaction is committed.

Specified by:

transactionCommited in interface IChangeLog

Parameters:

commitTime - The timestamp associated with the commit point.

transactionAborted

public void transactionAborted()

Description copied from interface: IChangeLog

Occurs if the current SAIL transaction is aborted.

Specified by:

transactionAborted in interface IChangeLog

close

public void close()

Description copied from interface: IChangeLog

Close any open resources.

Specified by:

close in interface IChangeLog