org.apache.flink.streaming.api.invokable.util.TimeStamp to org.apache.flink.streaming.api.windowing.helper.TimestampWrapper