CsvTableSource Types.TIMESTAMP

[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

[Timo Walther]

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

[Esa Heikkinen]

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

 

[Hequn Cheng]

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

 

[Esa Heikkinen]

Hi

 

It works now. It was because of the missing “import”. Thank you.

 

Best, Esa

 

From: Hequn Cheng [mailto:[hidden email]]
Sent: Wednesday, March 7, 2018 3:00 PM
To: Esa Heikkinen <[hidden email]>
Cc: Timo Walther <[hidden email]>; [hidden email]
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 <[hidden email]> 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:[hidden email]]
Sent: Monday, March 5, 2018 3:15 PM
To: [hidden email]
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