in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBStreamsRecordTransformer.java [45:51]
public Record toClass(final com.amazonaws.services.kinesis.model.Record record) throws IOException {
if (record instanceof RecordAdapter) {
return ((RecordAdapter) record).getInternalObject();
} else {
return MAPPER.readValue(new String(record.getData().array(), ENCODING), Record.class);
}
}