You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Esa Heikkinen <es...@student.tut.fi> on 2018/03/05 13:10:58 UTC
CsvTableSource Types.TIMESTAMP
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
Posted by Esa Heikkinen <es...@student.tut.fi>.
Hi
It works now. It was because of the missing “import”. Thank you.
Best, Esa
From: Hequn Cheng [mailto:chenghequn@gmail.com]
Sent: Wednesday, March 7, 2018 3:00 PM
To: Esa Heikkinen <es...@student.tut.fi>
Cc: Timo Walther <tw...@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 <es...@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:twalthr@apache.org<ma...@apache.org>]
Sent: Monday, March 5, 2018 3:15 PM
To: user@flink.apache.org<ma...@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
Posted by Hequn Cheng <ch...@gmail.com>.
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 <es...@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:twalthr@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
Posted by Esa Heikkinen <es...@student.tut.fi>.
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:twalthr@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
Posted by Timo Walther <tw...@apache.org>.
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
>