com.neeve.rog.log
Class RogLog.Entry

java.lang.Object
  com.neeve.rog.log.RogLog.Entry

Enclosing class:

RogLog

public static final class RogLog.Entry
extends Object

Represents a transaction log entry

Threading:RogLog.Entrys are not safe for concurrent access by multiple threads.

Nested Class Summary

static class

RogLog.Entry.Type Enumerates the various entry types

Method Summary

void	dispose() May be called when the RogLog.Entry will no longer be used to indicate that it's backing objects can be returned to their pools
long	getCheckpointVersion() Get the entry's checkpoint version.
String	getClassName() Get the simple class name of the logged object
IStoreObject.EncodingType	getContentEncodingType() Get's the object's content encoding type.
RogLog.Entry.Type	getEntryType() Get the entry type
long	getFilePosition() Gets the current position of the entry in the file.
static String	getHeaderRow(boolean csv) Returns a row suitable to act as a header for information dumped by toString().
com.eaio.uuid.UUID	getId() Get the object id
RogLog	getLog() Returns the RogLog from which this entry was read.
String	getLogName() Gets the name of this RogLog.Entry's log.
IRogMetadata	getMetadata() Gets the metadata associated with this entry.
IStoreObject	getObject() Get the object associated with this entry or null, if the entry did not contain a serialized object.
ByteBuffer	getRawBody() Returns the object in its serialized form, or null if either the entry doesn't have a corresponding object or if the object's serialized form has been discarded as a result of deserializing it into it's object form.
PktBuffer	getSerializedMetadata() Gets the serialized metadata for this entry.
String	getSimpleClassName() Get the simple class name of the logged object
long	getStableTransactionId() Get the entry's stabilized transaction id.
long	getTimestamp() Gets the time at which this entry was persisted or 0 if no persist timestamp was recorded.
long	getTransactionId() Get the entry's transaction id.
boolean	isCommitEnd() Get if an entry marks the end of a commit
String	toString() Returns a tabular String format for this RogLog.Entry.
String	toString(boolean csv) Returns a csv or tabular formatted string for this RogLog.Entry

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getFilePosition

public final long getFilePosition()

Gets the current position of the entry in the file. Note that this is subject to change if the log is compacted or otherwise altered in which case the value reported by this entry will no longer be valid.

Returns:

The position of this entry in the log file.

getLogName

public final String getLogName()

Gets the name of this RogLog.Entry's log.

Returns:

The name of the log this RogLog.Entry cam from.

getTimestamp

public final long getTimestamp()

Gets the time at which this entry was persisted or 0 if no persist timestamp was recorded.

Returns:

The timestamp at which the entry was persisted.

getEntryType

public final RogLog.Entry.Type getEntryType()

Get the entry type

getClassName

public final String getClassName()

Get the simple class name of the logged object

getSimpleClassName

public final String getSimpleClassName()

Get the simple class name of the logged object

getId

public final com.eaio.uuid.UUID getId()

Get the object id

getTransactionId

public final long getTransactionId()

Get the entry's transaction id.

Returns:

the entry's transaction id.

See Also:

IStoreObject.getTransactionId()

getStableTransactionId

public final long getStableTransactionId()

Get the entry's stabilized transaction id.

Returns:

The entry's stabilized transaction id.

See Also:

IStoreObject.getStableTransactionId()

getCheckpointVersion

public final long getCheckpointVersion()

Get the entry's checkpoint version.

Returns:

The entry's checkpoint version.

See Also:

IStoreObject.getCheckpointVersion()

getObject

public final IStoreObject getObject()

Get the object associated with this entry or null, if the entry did not contain a serialized object. It is always preferable to use getMetadata() instead of getObject() since the latter requires full object deserialization whereas the former does not.

Note: RogLog.Entrys of type RogLog.Entry.Type.Remove are not expected to have an associated serialized object, but will have metadata

Throws:

RuntimeException - if there is an error deserializing the object

isCommitEnd

public final boolean isCommitEnd()

Get if an entry marks the end of a commit

getHeaderRow

public static final String getHeaderRow(boolean csv)

Returns a row suitable to act as a header for information dumped by toString().

Parameters:

csv - Indicates that the header row should be in csv format, otherwise a tabular format will be used.

Returns:

a row suitable to act as a header for information dumped by toString()

toString

public final String toString()

Returns a tabular String format for this RogLog.Entry.

Overrides:

toString in class Object

toString

public final String toString(boolean csv)

Returns a csv or tabular formatted string for this RogLog.Entry

getRawBody

public final ByteBuffer getRawBody()

Returns the object in its serialized form, or null if either the entry doesn't have a corresponding object or if the object's serialized form has been discarded as a result of deserializing it into it's object form.

Returns:

Returns the object in its serialized form

getContentEncodingType

public IStoreObject.EncodingType getContentEncodingType()

Get's the object's content encoding type. An entry's content encoding type indicates how the object should be materialized from it's serialized encoding type.

Returns:

The object's content encoding type.

getSerializedMetadata

public PktBuffer getSerializedMetadata()

Gets the serialized metadata for this entry.

Returns:

The serialized metadata for this entry.

getMetadata

public IRogMetadata getMetadata()

Gets the metadata associated with this entry.

Returns:

The metadata associated with the entry.

getLog

public RogLog getLog()

Returns the RogLog from which this entry was read.

Returns:

The RogLog that read this entry

dispose

public void dispose()

May be called when the RogLog.Entry will no longer be used to indicate that it's backing objects can be returned to their pools