com.neeve.rog.log

Class RogLogReader.Entry

java.lang.Object

com.neeve.rog.log.RogLogReader.Entry

All Implemented Interfaces:

UtlPool.Item<RogLogReader.Entry>

Enclosing class:

RogLogReader

public static final class RogLogReader.Entry
extends Object
implements UtlPool.Item<RogLogReader.Entry>

Represents a log entry

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RogLogReader.Entry.Type Enumerates the various entry types

Method Summary

Modifier and Type	Method and Description
static RogLogReader.Entry	create(RogLog log, PktPacket packet, long filePosition, int sizeInFile) Wraps an entry around a packet read from a log.
void	dispose() May be called when the RogLogReader.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.
int	getEntrySize() Get the size of the entry in the file.
RogLogReader.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 RogLogReader.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.
short	getOfid() When the entry has a serialized payload, returns the serialized object's object factory id
short	getOtype() When the entry has a serialized payload, returns the serialized object's object type
PktPacket	getPacket() Get the raw packet backing this entry.
int	getPayloadSize() Get the serialized size of an entry's payload.
UtlPool<RogLogReader.Entry>	getPool() Implementation of UtlPool.Item#getPool.
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.
RogLogReader.Entry	init() Implementation of UtlPool.Item#init.
boolean	isCommitEnd() Get if an entry marks the end of a commit
boolean	isCommitStart() Get if an entry marks the start of a commit
boolean	isPayloadDeserialized() Indicates whether the payload was deserialized via getObject().
RogLogReader.Entry	setPool(UtlPool<RogLogReader.Entry> pool) Implementation of UtlPool.Item#setPool.
String	toString() Returns a tabular String format for this RogLogReader.Entry.
String	toString(boolean csv) Returns a csv or tabular formatted string for this RogLogReader.Entry

Methods inherited from class java.lang.Object

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

Method Detail

create

public static final RogLogReader.Entry create(RogLog log,
                                              PktPacket packet,
                                              long filePosition,
                                              int sizeInFile)
                                       throws OdsException

Wraps an entry around a packet read from a log.

This method acquires the passed in packet. The returned Entry is itself pooled. The caller should dispose of it when done.

Parameters:

log - The log the packet was read from. Can be null.

packet - The packet from the log.

filePosition - The position of the entry in the log file

sizeInFile - The serialized length of the entry in the log file

Returns:

The entry.

Throws:

OdsException - If the packet cannot be wrapped in an entry.

getLog

public final RogLog getLog()

Returns the RogLog from which this entry was read.

Returns:

The RogLog that read this entry

getLogName

public final String getLogName()

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

Returns:

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

getPacket

public final PktPacket getPacket()

Get the raw packet backing this entry.

This method is reserved for internal use. Users of this api should use getObject().

Returns:

The entry's raw packet.

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.

getEntrySize

public final int getEntrySize()

Get the size of the entry in the file.

getEntryType

public final RogLogReader.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

getPayloadSize

public final int getPayloadSize()

Get the serialized size of an entry's payload.

isPayloadDeserialized

public final boolean isPayloadDeserialized()

Indicates whether the payload was deserialized via getObject(). Many operations that use an RogLogReader.Entry don't need the payload to be deserialized / unmarshalled. Which can result in

Returns:

Whether or not the entries payload has been deserialized yet.

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.

Returns:

The object that was removed (or null if a legacy Remove entry that didn't include the object).

Throws:

RuntimeException - if there is an error deserializing the object

getId

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

Get the object id

getOfid

public short getOfid()

When the entry has a serialized payload, returns the serialized object's object factory id

Returns:

The serialized object's factory id.

getOtype

public short getOtype()

When the entry has a serialized payload, returns the serialized object's object type

Returns:

The serialized object's type.

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.

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.

isCommitStart

public final boolean isCommitStart()

Get if an entry marks the start of a commit

isCommitEnd

public final boolean isCommitEnd()

Get if an entry marks the end of a commit

getTransactionId

public final long getTransactionId()

Get the entry's transaction id.

Returns:

the entry's transaction id.

See Also:

IStoreObjectMetadata.getTransactionId()

getStableTransactionId

public final long getStableTransactionId()

Get the entry's stabilized transaction id.

Returns:

The entry's stabilized transaction id.

See Also:

IStoreObjectMetadata.getStableTransactionId()

getCheckpointVersion

public final long getCheckpointVersion()

Get the entry's checkpoint version.

Returns:

The entry's checkpoint version.

See Also:

IStoreObjectMetadata.getCheckpointVersion()

getMetadata

public IRogMetadata getMetadata()

Gets the metadata associated with this entry.

Returns:

The metadata associated with the entry.

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 RogLogReader.Entry.

Overrides:

toString in class Object

toString

public final String toString(boolean csv)

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

dispose

public final void dispose()

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

init

public final RogLogReader.Entry init()

Implementation of UtlPool.Item#init.

Specified by:

init in interface UtlPool.Item<RogLogReader.Entry>

Returns:

Return 'this' object for method invocation chaining.

setPool

public final RogLogReader.Entry setPool(UtlPool<RogLogReader.Entry> pool)

Implementation of UtlPool.Item#setPool.

Specified by:

setPool in interface UtlPool.Item<RogLogReader.Entry>

Returns:

Return 'this' object for method invocation chaining.

getPool

public final UtlPool<RogLogReader.Entry> getPool()

Implementation of UtlPool.Item#getPool.

Specified by:

getPool in interface UtlPool.Item<RogLogReader.Entry>

Returns:

the pool set using UtlPool.Item.setPool(com.neeve.util.UtlPool<T>)