Hi It works now. It was because of the missing “import”. Thank you.
Best, Esa From: Hequn Cheng [mailto:chenghe...@gmail.com] Sent: Wednesday, March 7, 2018 3:00 PM To: Esa Heikkinen <esa.heikki...@student.tut.fi> Cc: Timo Walther <twal...@apache.org>; user@flink.apache.org Subject: Re: CsvTableSource Types.TIMESTAMP Hi Esa, Have you ever imported org.apache.flink.table.api.scala._ ? There are some examples here[1]. Best, Hequn [1] https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/TableSinkITCase.scala On Tue, Mar 6, 2018 at 5:24 PM, Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> wrote: 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<mailto:twal...@apache.org>] Sent: Monday, March 5, 2018 3:15 PM To: user@flink.apache.org<mailto:user@flink.apache.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
