开发者社区> 问答> 正文

如何优雅的开发Flink SQL作业

大佬们好,现在业务需求多,生产作业开始变得繁重,请教3个生产业务场景,主要是想看下各位有什么优雅的思路

1.kakfa table和group_ID应该怎么去维护呢?一个业务一张表吗? 2.如何做到复用表的效果? 3.如果新增一个业务需求,用到之前的一张kafka table,似乎要在一个程序里。执行多次 executeSql("sql 1")才不会乱序,但是这样的话,程序的耦合度会很高,请问该怎么优雅的处理这些场景呢?*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-08 11:21:29 672 0
1 条回答
写回答
取消 提交回答
  • 1 kafka table和group id是啥意思。group id随意写一个就可以了。 2 本身就可以复用。 3 听不懂表达啥。*来自志愿者整理的flink邮件归档

    2021-12-08 16:22:06
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
SQL Server在电子商务中的应用与实践 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载