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