Re: Table name for table created fromDataStream

Posted by Leonard Xu on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Table-name-for-table-created-fromDataStream-tp43535p43537.html

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 <[hidden email]> 写道：
>
> 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 :
> /StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
>    Table eventsTable =
>        tableEnv.fromDataStream(
>            eventStream,
>            $("id"),
>            $("orgId"));/
> Now if I want to run some sql query on this, using tableEnv.sqlQuery() where
> the SQL is the rule that I want to run on the events, so the SQL is read
> from the external source, I would need the table name for this table to be
> fixed so that the query writers can use that.
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/