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 出来的
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 出来的