Hi, I think you just need to specify a custom watermark extractor that constructs the watermark from the 3 fields, as described here: https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/event_timestamp_extractors.html <https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/event_timestamp_extractors.html>.
Best, Stefan > 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 >
