org.wali

Class SingletonSerDeFactory<T>

java.lang.Object

org.wali.SingletonSerDeFactory<T>

All Implemented Interfaces:

SerDeFactory<T>

public class SingletonSerDeFactory<T>
extends java.lang.Object
implements SerDeFactory<T>

Constructor Summary

Constructors

Constructor and Description
SingletonSerDeFactory(SerDe<T> serde)

Method Summary

Modifier and Type	Method and Description
SerDe<T>	createSerDe(java.lang.String encodingName) Returns a new SerDe
java.lang.String	getLocation(T 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(T record) Returns the unique ID for the given record
UpdateType	getUpdateType(T record) Returns the UpdateType for the given record

Methods inherited from class java.lang.Object

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

Constructor Detail

SingletonSerDeFactory

public SingletonSerDeFactory(SerDe<T> serde)

Method Detail

createSerDe

public SerDe<T> createSerDe(java.lang.String encodingName)

Description copied from interface: SerDeFactory

Returns a new SerDe

Specified by:

createSerDe in interface SerDeFactory<T>

Parameters:

encodingName - the name of encoding that was used when writing the serialized data, or null if the SerDe is to be used for serialization purposes

Returns:

a SerDe

getRecordIdentifier

public java.lang.Object getRecordIdentifier(T record)

Description copied from interface: SerDeFactory

Returns the unique ID for the given record

Specified by:

getRecordIdentifier in interface SerDeFactory<T>

Parameters:

record - to obtain identifier for

Returns:

identifier of record

getUpdateType

public UpdateType getUpdateType(T record)

Description copied from interface: SerDeFactory

Returns the UpdateType for the given record

Specified by:

getUpdateType in interface SerDeFactory<T>

Parameters:

record - to retrieve update type for

Returns:

update type

getLocation

public java.lang.String getLocation(T record)

Description copied from interface: SerDeFactory

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 SerDeFactory<T>

Parameters:

record - to get location of

Returns:

location