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().inStreamingMode().useBlinkPlanner().build()
val tableEnv = StreamTableEnvironment.create(env, settings)
val temptable = tableEnv.sqlQuery(s"select * from a where ${condition}")
temptable.where(condition1) ... then do something
temptable.where(condition2) ... then do otherthing
I want to reuse temptable for higher performance, what operators need or it
already cached in flink sql plan ?
Any help would be appreciated :)
