有例子吗?


王双利
 
发件人: Jark Wu
发送时间: 2020-04-26 14:28
收件人: user-zh
主题: Re: RichInputFormat 无法得到 查询参数
是的。无法拿到。因为 RichInputFormat 是 DataStream 层的 runtime function,不感知 SQL 层的东西。
你的这个需求可以通过 TableSource 实现 FilterableTableSource 来拿到这个下推的 filter 信息。
 
Best,
Jark
 
On Sun, 26 Apr 2020 at 13:52, 王双利 <[email protected]> wrote:
 
> 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 出来的
>

回复