Hi All,
        var praiseAggr = tableEnv.sqlQuery(s"SELECT article_id FROM praise 
GROUP BY HOP(updated_time, INTERVAL '1' SECOND,INTERVAL '3' MINUTE) , 
article_id" )
        tableEnv.registerTable("praiseAggr", praiseAggr)
    var finalTable = tableEnv.sqlQuery(s”SELECT 1 FROM article a join 
praiseAggr p on a.article_id=p.article_id" )
    tableEnv.registerTable("finalTable", finalTable)
         I know that praiseAggr, if written to sink, is append mode , so if a 
table joins praiseAggr, what the table “see”, is a table contains the latest 
value, or a table that grows larger and larger? If it is the later, will it 
introduce performance problem?
         Thanks a lot.


Best, 
Henry

Reply via email to