thanks for your help，Timo，it is very helpful
在 2021年2月8日星期一，Timo Walther 写道：
> Hi Yongsong,
>
> in newer Flink versions we introduced the concept of statament sets, which
> are available via `TableEnvironment.createStatementSet()`. They allow you
> to opimized a branching pipeline as a whole wit
Hi Yongsong,
in newer Flink versions we introduced the concept of statament sets,
which are available via `TableEnvironment.createStatementSet()`. They
allow you to opimized a branching pipeline as a whole with reusing subplans.
In older Flink versions, you can convert the Table to a DataStre
Hi experts,
I want to cache a temporary table for reuse it
Flink version 1.10.1
the table is consumer from kafka, struct like:
create table a (
field1 string,
field2 string,
field3 string,
field4 string
)
the sample code looks like:
val settings =
EnvironmentSettings.newInstance().inStreamingM
