请问下,flink sql 创建后,源库删除,目标不删除,这个操作有好的解决方法没呀?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
与所有 SQL 引擎一样,Flink 查询操作是在表上进行。与传统数据库不同,Flink 不在本地管理静态数据;相反,它的查询在外部表上连续运行。
Flink 数据处理流水线开始于 source 表。source 表产生在查询执行期间可以被操作的行;它们是查询时 FROM 子句中引用的表。这些表可能是 Kafka 的 topics,数据库,文件系统,或者任何其它 Flink 知道如何消费的系统。 具体可以参考 apache的官方网站
评论
全部评论 (0)
SQL客户端是一个交互式的客户端,用于向Flink提交SQL查询并将结果可视化。
与所有SQL引擎一样,Flink查询操作是在表上进行。 与传统数据库不同,Flink不在本地管理静态数据;相反,它的查询在外部表上连续运行。
可以通过SQL客户端或使用环境配置文件来定义表。 SQL客户端支持类似于传统的SQL DDL命令, 用于创建,修改,删除表。 Flink支持不同的连接器和格式相结合以定义表。
Flink SQL与传统数据库查询的不同之处在于,Flink SQL持续消费到达的行并对其结果进行更新。 一个连续查询永远不会终止,并会产生一个动态表作为结果。 动态表是Flink中Table API和SQL对流数据支持的核心概念。
Sink表 当运行此查询时,SQL客户端实时但是以只读方式提供输出。 存储结果,作为报表或仪表板的数据来源,需要写到另一个表。 这可以使用INSERT INTO语句来实现。 INSERT INTO语句将作为一个独立查询被提交到Flink集群中。
提交后,它将运行并将结果直接存储到sink 表中,而不是将结果加载到系统内存中。
评论
全部评论 (0)
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。
评论
全部评论 (0)