Re: Table Cache Problem

2021-02-08 Thread Yongsong He
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

Re: Table Cache Problem

2021-02-08 Thread 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 with reusing subplans. In older Flink versions, you can convert the Table to a

Table Cache Problem

2021-02-07 Thread Yongsong He
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 =