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