org.wali

Class DummyRecordSerde

java.lang.Object

org.wali.DummyRecordSerde

All Implemented Interfaces:

SerDe<DummyRecord>

public class DummyRecordSerde
extends java.lang.Object
implements SerDe<DummyRecord>

Constructor Summary

Constructors

Constructor and Description
DummyRecordSerde()

Method Summary

Modifier and Type	Method and Description
DummyRecord	deserializeEdit(java.io.DataInputStream in, java.util.Map<java.lang.Object,DummyRecord> currentVersion, int version) Reads an Edit Record from the given DataInputStream and merges that edit with the current version of the record, returning the new, merged version.
DummyRecord	deserializeRecord(java.io.DataInputStream in, int version) Reads a Record from the given DataInputStream and returns this record.
java.lang.String	getLocation(DummyRecord record) Returns the external location of the given record; this is used when a record is moved away from WALI or is being re-introduced to WALI.
java.lang.Object	getRecordIdentifier(DummyRecord record) Returns the unique ID for the given record
UpdateType	getUpdateType(DummyRecord record) Returns the UpdateType for the given record
int	getVersion() Returns the version that this SerDe will use when writing.
void	serializeEdit(DummyRecord previousState, DummyRecord record, java.io.DataOutputStream out) Serializes an Edit Record to the log via the given DataOutputStream.
void	serializeRecord(DummyRecord record, java.io.DataOutputStream out) Serializes a Record in a form suitable for a Snapshot via the given DataOutputStream.
void	setThrowIOEAfterNSerializeEdits(int n)
void	setThrowOOMEAfterNSerializeEdits(int n)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.wali.SerDe

close, readHeader, writeHeader

Constructor Detail

DummyRecordSerde

public DummyRecordSerde()

Method Detail

serializeEdit

public void serializeEdit(DummyRecord previousState,
                          DummyRecord record,
                          java.io.DataOutputStream out)
                   throws java.io.IOException

Description copied from interface: SerDe

Serializes an Edit Record to the log via the given DataOutputStream.

Specified by:

serializeEdit in interface SerDe<DummyRecord>

Parameters:

previousState - previous state

record - new state

out - stream to write to

Throws:

java.io.IOException - if fail during write

serializeRecord

public void serializeRecord(DummyRecord record,
                            java.io.DataOutputStream out)
                     throws java.io.IOException

Description copied from interface: SerDe

Serializes a Record in a form suitable for a Snapshot via the given DataOutputStream.

Specified by:

serializeRecord in interface SerDe<DummyRecord>

Parameters:

record - to serialize

out - to write to

Throws:

java.io.IOException - if failed to write

deserializeRecord

public DummyRecord deserializeRecord(java.io.DataInputStream in,
                                     int version)
                              throws java.io.IOException

Description copied from interface: SerDe

Reads a Record from the given DataInputStream and returns this record. If no data is available, returns null.

Specified by:

deserializeRecord in interface SerDe<DummyRecord>

Parameters:

in - stream to read from

version - the version of the SerDe that was used to serialize the record

Returns:

record

Throws:

java.io.IOException - failure reading

getRecordIdentifier

public java.lang.Object getRecordIdentifier(DummyRecord record)

Description copied from interface: SerDe

Returns the unique ID for the given record

Specified by:

getRecordIdentifier in interface SerDe<DummyRecord>

Parameters:

record - to obtain identifier for

Returns:

identifier of record

getUpdateType

public UpdateType getUpdateType(DummyRecord record)

Description copied from interface: SerDe

Returns the UpdateType for the given record

Specified by:

getUpdateType in interface SerDe<DummyRecord>

Parameters:

record - to retrieve update type for

Returns:

update type

deserializeEdit

public DummyRecord deserializeEdit(java.io.DataInputStream in,
                                   java.util.Map<java.lang.Object,DummyRecord> currentVersion,
                                   int version)
                            throws java.io.IOException

Description copied from interface: SerDe

Reads an Edit Record from the given DataInputStream and merges that edit with the current version of the record, returning the new, merged version. If the Edit Record indicates that the entity was deleted, must return a Record with an UpdateType of UpdateType.DELETE. This method must never return null.

Specified by:

deserializeEdit in interface SerDe<DummyRecord>

Parameters:

in - to deserialize from

currentVersion - an unmodifiable map of Record ID's to the current state of that record

version - the version of the SerDe that was used to serialize the edit record

Returns:

deserialized record

Throws:

java.io.IOException - if failure reading

getVersion

public int getVersion()

Description copied from interface: SerDe

Returns the version that this SerDe will use when writing. This used used when serializing/deserializing the edit logs so that if the version changes, we are still able to deserialize old versions

Specified by:

getVersion in interface SerDe<DummyRecord>

Returns:

version

setThrowIOEAfterNSerializeEdits

public void setThrowIOEAfterNSerializeEdits(int n)

setThrowOOMEAfterNSerializeEdits

public void setThrowOOMEAfterNSerializeEdits(int n)

getLocation

public java.lang.String getLocation(DummyRecord record)

Description copied from interface: SerDe

Returns the external location of the given record; this is used when a record is moved away from WALI or is being re-introduced to WALI. For example, WALI can be updated with a record of type UpdateType.SWAP_OUT that indicates a Location of file://tmp/external1 and can then be re-introduced to WALI by updating WALI with a record of type UpdateType.CREATE that indicates a Location of file://tmp/external1

Specified by:

getLocation in interface SerDe<DummyRecord>

Parameters:

record - to get location of

Returns:

location