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 <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
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>
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
