RE: CsvTableSource Types.TIMESTAMP
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 Cc: Timo Walther ; 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 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
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 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 > > >
RE: CsvTableSource Types.TIMESTAMP
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
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