public interface Event<T>
IMessage<T>
get()
long
getTimeStamp()
boolean
isWatermark()
long getTimeStamp()
IMessage<T> get()
boolean isWatermark()