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 <tejasub1...@gmail.com> 写道：
>
> 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/
