Re: Table Api and CSV builder

2018-03-08 Thread Timo Walther
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 con

Re: Table Api and CSV builder

2018-03-07 Thread Stefan Richter
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