in src/main/java/com/amazonaws/services/kinesisanalytics/flink/serialization/POJODeserializationSchema.java [46:48]
public boolean isEndOfStream(T t) { return false; }