Re: 关于FlinkSQL的一些最佳实践咨询

2020-08-12 文章 Leonard Xu
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, 我们公司采用的是通过提交一

答复: 关于FlinkSQL的一些最佳实践咨询

2020-08-12 文章 zhao 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, 我们公司采用的是通过提交一个解析flink sql的jar包,把sql作为jar包的参数来执行的。采用接口机将用户的udf > jar包和平台提供的解析flin

Re: 关于FlinkSQL的一些最佳实践咨询

2020-08-12 文章 Shengkai Fang
的session,各个session独享自己的memory > catalog,创建的表也类似于临时表的效果。 > > 发件人: "Zhao,Yi(SEC)" > 日期: 2020年8月12日 星期三 下午2:20 > 收件人: "user-zh@flink.apache.org" > 主题: 关于FlinkSQL的一些最佳实践咨询 > > 最近刚刚开始研究FlinkSQL,之前一直用的DataStream API,现在想尝试下FlinkSQL的玩法。 > 目前简单看下来,感觉相对来说相比DataStream

回复: 关于FlinkSQL的一些最佳实践咨询

2020-08-12 文章 靳亚洽
) 写道: 没有小伙伴帮忙看下这个问题吗。可以优先看下第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

Re: 关于FlinkSQL的一些最佳实践咨询

2020-08-12 文章 Zhao,Yi(SEC)
没有小伙伴帮忙看下这个问题吗。可以优先看下第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的一些最佳实践咨询

2020-08-12 文章 Zhao,Yi(SEC)
最近刚刚开始研究FlinkSQL,之前一直用的DataStream API,现在想尝试下FlinkSQL的玩法。 目前简单看下来,感觉相对来说相比DataStream API不够灵活,所以有一些实践疑问咨询下。 (1) 通常Kafka的动态表会通过临时表的方式写在程序开头声明定义呢?还是直接写在sql-client的配置文件中呢。 如果写在配置文件,好处是类似于一个固化的表定义一样,每次执行sql-client的cli之后可以马上查询相关数据。但是有个问题是这种情况下kafka设置读取earliest还是latest?貌似根据具体查询需求临时改配置好像也不是很方便。