RE: "select as" in Flink SQL

2016-08-31 Thread Davran Muzafarov
o Am 30/08/16 um 21:49 schrieb Davran Muzafarov: I am try to execute simple sql like this: DataSet dataSet0 = env.fromCollection( infos0 ); tableEnv.registerDataSet( "table0", dataSet0 ); Table table = tableEnv.sql( "select assetClass as \”asset class

"select as" in Flink SQL

2016-08-30 Thread Davran Muzafarov
I am try to execute simple sql like this: DataSet dataSet0 = env.fromCollection( infos0 ); tableEnv.registerDataSet( "table0", dataSet0 ); Table table = tableEnv.sql( "select assetClass as \"asset class\" from tabel0" ); I am getting: org.apache.calcite.sql.parser.SqlParseExcept

Is java.sql.Timestamp fully suported in Flink SQL?

2016-08-11 Thread Davran Muzafarov
I have two tables created from data sets: List infos0 = . List infos1 = . DataSet dataSet0 = env.fromCollection( infos0 ); DataSet dataSet1 = env.fromCollection( infos1 ); tableEnv.registerDataSet( "table0", dataSet0 ); tableEnv.registerDataSet( "table1", dataSet1

Flink and SQL

2016-07-29 Thread Davran Muzafarov
Hi, I could not find the way to reuse table names. tableEnv = TableEnvironment.getTableEnvironment(env); . Table table = tableEnv.registerTable( "table1", table ); Table table = tableEnv.sql( "select * from table1" ); . . Is it possible to "unregister" table or re