I think you just need to specify a custom watermark extractor that constructs 
the watermark from the 3 fields, as described here: 


> Am 07.03.2018 um 00:52 schrieb Karim Amer <karim.amer...@gmail.com>:
> Hi there 
> I Have a CSV file with the timestamp deconstructed into 3 fields and I was 
> wondering what is the best way to  specify the those 3 fields are the event  
> time ? Should I make extend  CsvTableSource and do the preprocessing or can 
> CsvTableSource.builder() handle it. Or is there a better way in general to 
> tackle this obstacle.
> Thanks

Reply via email to