ike yours.
>
> Regards,
> Dawid
>
> 2017-03-07 22:33 GMT+01:00 ext.eformichella <[hidden email]
> <http:///user/SendEmail.jtp?type=node&node=12092&i=0>>:
>
>> Hi Dawid, I'm working with Max on the project
>> Our cod
Hi Dawid, I'm working with Max on the project
Our code for the TimestampAndWatermarkAssigner is:
```
class TimestampAndWatermarkAssigner(val maxLateness: Long) extends
AssignerWithPeriodicWatermarks[Row] {
override def extractTimestamp(element: Row, previousElementTimestamp:
Long): Long = {
