Add collector to PravegaDeserializationSchema

[crazyzhou]

Problem description
In FLIP-124, Flink has added the open/close method and included the collector in the deserialization schema to support more cases. We have covered the open in #519 , and we need to add the collector as well to fully adapt the new API.

This also helps to support the debezium format because it requires to call the method with a collector (ref: https://github.com/apache/flink/blob/1635f9326c8993114d8a5aa1881c2078393f8eb5/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java#L119)

Problem location
reader, table API and serialization

Suggestions for an improvement
ref: https://github.com/apache/flink/pull/12018/files