in src/main/java/com/amazonaws/services/kinesisanalytics/flink/serialization/POJODeserializationSchema.java [51:53]
public TypeInformation<T> getProducedType() { return TypeInformation.of(clazz); }