Re: Table name for table created fromDataStream

2021-05-07 Thread Leonard Xu
> 在 2021年5月8日,08:00,tbud 写道: > > Hi Leonard, > Yes that would be one solution. But why is it necessary to create a > temporaryView from already created table ? The name “Table” is quite misleading here, the table API object Table actually represents a relational query (e.g. Table table = m

Re: Table name for table created fromDataStream

2021-05-07 Thread tbud
Hi Leonard, Yes that would be one solution. But why is it necessary to create a temporaryView from already created table ? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Table name for table created fromDataStream

2021-05-06 Thread Leonard Xu
Hi, tbud You can register the Table API object as a temporary view and then run query on it: tableEnv.createTemporaryView(“MyTable”, eventsTable); tableEnv.executeSql(“SELECT * FROM MyTable“).print(); Best, Leonard > 在 2021年5月7日,03:17,tbud 写道: > > Does anybody know how to set the name for th

Table name for table created fromDataStream

2021-05-06 Thread tbud
Does anybody know how to set the name for the table created using fromDataStream() method ? Flink's documentation doesn't mention anything about this and when I went through the taskManager logs I saw some auto generated name like 'Unregistered_DataStream_5'. Here's my code : /StreamTableEnvironmen