Hi Thank you, it worked, but there was another problem now in same example.
How to use .filter(): val table = tEnv .scan("customers") .filter('name.isNotNull && 'last_update > "2016-01-01 00:00:00".toTimestamp) .select('id, 'name.lowerCase(), 'prefs) Error in compiling: "Value > is not member of Symbol" Is that syntactically correct, may it be problem with "imports" or is it deprecated ? Best, Esa From: Timo Walther [mailto:twal...@apache.org] Sent: Monday, March 5, 2018 3:15 PM To: firstname.lastname@example.org Subject: Re: CsvTableSource Types.TIMESTAMP Hi, SQL_TIMESTAMP is the same. A couple of months ago it was decided to rename this property such that it can be used for timestamps with timezone support in the future. Regards, Tiom Am 3/5/18 um 2:10 PM schrieb Esa Heikkinen: I have tried to following example to work, but no succeed yet. https://flink.apache.org/news/2017/03/29/table-sql-api-update.html Error .. value TIMESTAMP is not a member of object org.apache.glink.table.api.Types What would be the problem ? What the imports should I use ? Or should I use SQL_TIMESTAMP instead of it ? is it same ? Best, Esa