liang 写道:
>
> 请问table api要重构是哪个FLIP,我想关注下
>
> 发件人: Shengkai Fang
> 日期: 星期四, 2020年8月13日 11:09
> 收件人: user-zh@flink.apache.org
> 主题: Re: 关于FlinkSQL的一些最佳实践咨询
> 针对(3)社区建议使用sql api, table api现在正准备重构。
>
> 靳亚洽 于2020年8月13日周四 上午11:00写道:
>
>> 针对2, 我们公司采用的是通过提交一
请问table api要重构是哪个FLIP,我想关注下
发件人: Shengkai Fang
日期: 星期四, 2020年8月13日 11:09
收件人: user-zh@flink.apache.org
主题: Re: 关于FlinkSQL的一些最佳实践咨询
针对(3)社区建议使用sql api, table api现在正准备重构。
靳亚洽 于2020年8月13日周四 上午11:00写道:
> 针对2, 我们公司采用的是通过提交一个解析flink sql的jar包,把sql作为jar包的参数来执行的。采用接口机将用户的udf
> jar包和平台提供的解析flin
的session,各个session独享自己的memory
> catalog,创建的表也类似于临时表的效果。
>
> 发件人: "Zhao,Yi(SEC)"
> 日期: 2020年8月12日 星期三 下午2:20
> 收件人: "user-zh@flink.apache.org"
> 主题: 关于FlinkSQL的一些最佳实践咨询
>
> 最近刚刚开始研究FlinkSQL,之前一直用的DataStream API,现在想尝试下FlinkSQL的玩法。
> 目前简单看下来,感觉相对来说相比DataStream
) 写道:
没有小伙伴帮忙看下这个问题吗。可以优先看下第2、3、4个问题。
其他问题,第1/5个问题,我自己大概感觉,直接使用memory
catalog就ok啦。我看了下FlinkSQL好像没有临时表的概念。10个SQL开10个sql-client的session,各个session独享自己的memory
catalog,创建的表也类似于临时表的效果。
发件人: "Zhao,Yi(SEC)"
日期: 2020年8月12日 星期三 下午2:20
收件人: "user-zh@flink.apache.org"
主题: 关于FlinkSQ
没有小伙伴帮忙看下这个问题吗。可以优先看下第2、3、4个问题。
其他问题,第1/5个问题,我自己大概感觉,直接使用memory
catalog就ok啦。我看了下FlinkSQL好像没有临时表的概念。10个SQL开10个sql-client的session,各个session独享自己的memory
catalog,创建的表也类似于临时表的效果。
发件人: "Zhao,Yi(SEC)"
日期: 2020年8月12日 星期三 下午2:20
收件人: "user-zh@flink.apache.org"
主题: 关于FlinkSQL的一些最佳实践
最近刚刚开始研究FlinkSQL,之前一直用的DataStream API,现在想尝试下FlinkSQL的玩法。
目前简单看下来,感觉相对来说相比DataStream API不够灵活,所以有一些实践疑问咨询下。
(1) 通常Kafka的动态表会通过临时表的方式写在程序开头声明定义呢?还是直接写在sql-client的配置文件中呢。
如果写在配置文件,好处是类似于一个固化的表定义一样,每次执行sql-client的cli之后可以马上查询相关数据。但是有个问题是这种情况下kafka设置读取earliest还是latest?貌似根据具体查询需求临时改配置好像也不是很方便。