Hi Karim,
the CsvTableSource and its builder are currently not able to specify
event-time or processing-time. I'm sure this will change in the near
future. Until then I would recommend to either extend it yourself or use
the DataStream API first to do the parsing and watermarking and then
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
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
