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> 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] > *Sent:* Monday, March 5, 2018 3:15 PM > *To:* 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 > > >
