org.bluedb.disk.recovery

Class PendingChange<T extends java.io.Serializable>

java.lang.Object

org.bluedb.disk.recovery.PendingChange<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Comparable<Recoverable<?>>, Recoverable<T>

public class PendingChange<T extends java.io.Serializable>
extends java.lang.Object
implements java.io.Serializable, Recoverable<T>

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
void	apply(BlueCollectionOnDisk<T> collection)
void	applyChange(Segment<T> segment)
static <T extends java.io.Serializable> PendingChange<T>	createDelete(BlueKey key, T value)
static <T extends java.io.Serializable> PendingChange<T>	createInsert(BlueKey key, T value, BlueSerializer serializer)
static <T extends java.io.Serializable> PendingChange<T>	createUpdate(BlueEntity<T> entity, Mapper<T> mapper, BlueSerializer serializer)
static <T extends java.io.Serializable> PendingChange<T>	createUpdate(BlueKey key, T value, Mapper<T> mapper, BlueSerializer serializer)
static <T extends java.io.Serializable> PendingChange<T>	createUpdate(BlueKey key, T value, Updater<T> updater, BlueSerializer serializer)
BlueKey	getKey()
T	getNewValue()
T	getOldValue()
long	getRecoverableId()
long	getTimeCreated()
boolean	isDelete()
boolean	isInsert()
boolean	isUpdate()
void	setRecoverableId(long recoverableId)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.bluedb.disk.recovery.Recoverable

compareTo

Method Detail

createDelete

public static <T extends java.io.Serializable> PendingChange<T> createDelete(BlueKey key,
                                                                             T value)

createInsert

public static <T extends java.io.Serializable> PendingChange<T> createInsert(BlueKey key,
                                                                             T value,
                                                                             BlueSerializer serializer)

createUpdate

public static <T extends java.io.Serializable> PendingChange<T> createUpdate(BlueKey key,
                                                                             T value,
                                                                             Updater<T> updater,
                                                                             BlueSerializer serializer)

createUpdate

public static <T extends java.io.Serializable> PendingChange<T> createUpdate(BlueEntity<T> entity,
                                                                             Mapper<T> mapper,
                                                                             BlueSerializer serializer)

createUpdate

public static <T extends java.io.Serializable> PendingChange<T> createUpdate(BlueKey key,
                                                                             T value,
                                                                             Mapper<T> mapper,
                                                                             BlueSerializer serializer)

apply

public void apply(BlueCollectionOnDisk<T> collection)
           throws BlueDbException

Specified by:

apply in interface Recoverable<T extends java.io.Serializable>

Throws:

BlueDbException

applyChange

public void applyChange(Segment<T> segment)
                 throws BlueDbException

Throws:

BlueDbException

getKey

public BlueKey getKey()

getOldValue

public T getOldValue()

getNewValue

public T getNewValue()

getTimeCreated

public long getTimeCreated()

Specified by:

getTimeCreated in interface Recoverable<T extends java.io.Serializable>

isDelete

public boolean isDelete()

isInsert

public boolean isInsert()

isUpdate

public boolean isUpdate()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getRecoverableId

public long getRecoverableId()

Specified by:

getRecoverableId in interface Recoverable<T extends java.io.Serializable>

setRecoverableId

public void setRecoverableId(long recoverableId)

Specified by:

setRecoverableId in interface Recoverable<T extends java.io.Serializable>