/*does nothing if you aren't there*/at(you,key),retract(at(youLine 291:3 would refer to main.retractall(at(_,_)), /* clean up from previous runs */
retract(
我正在为用户提供一个Flink SQL接口,所以我不能真正使用Table或Java/Scala接口。所有内容都需要在SQL中指定。不过,我可以解析SQL文件中的注释,并添加指定的特殊低级API指令。此附加表单可以具有以下模式: flag BOOLEAN <-- indicating an accumulate or retract