in src/main/java/com/amazonaws/services/kinesisanalytics/flink/serialization/POJODeserializationSchema.java [41:43]
public T deserialize(byte[] bytes) throws IOException { return mapper.readValue(bytes, clazz); }