public interface SerDeFactory<T>
| 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
|
SerDe<T> createSerDe(java.lang.String encodingName)
encodingName - the name of encoding that was used when writing the serialized data, or null if
the SerDe is to be used for serialization purposesjava.lang.Object getRecordIdentifier(T record)
record - to obtain identifier forUpdateType getUpdateType(T record)
record - to retrieve update type forjava.lang.String getLocation(T record)
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/external1record - to get location of