in src/main/java/com/amazonaws/services/kinesis/io/serializer/JsonSerializer.java [76:107]
public Object toClass(final InputEvent event) throws IOException {
// Return a class object from the json, or if we have no class then
// return a String list
List<String> jsonStringList = new ArrayList<>();
if (this.clazz == null) {
if (this.itemTerminator != null) {
// break up the json items as separate lines
String[] items = new String(event.getData(), this.charset).split(this.itemTerminator);
for (String item : items) {
if (filterRegex == null || (filterRegex != null && p.matcher(item).matches())) {
jsonStringList.add(item);
}
}
return jsonStringList;
} else {
// single json object per record
String item = new String(event.getData(), this.charset);
if (filterRegex == null || (filterRegex != null && p.matcher(item).matches())) {
jsonStringList.add(item);
}
return jsonStringList;
}
} else {
// use jackson to serialise a class instance
return mapper.readValue(event.getData(), clazz);
}
}