public T deserialize()

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);
    }