RichInputFormat 是不是无法获得 sql中对应的查询参数,比如 select ip,status,count(statusct) as ct 
from ipstatus where ip='123.0.0.1' group by ip,status
这个里面的'123.0.0.1' 

RichInputFormat 
是在StreamTableSourceFactory中的createStreamTableSource的getInputFormat中new 出来的

回复