请问下,flink sql 创建后,源库删除,目标不删除,这个操作有好的解决方法没呀?
与所有 SQL 引擎一样,Flink 查询操作是在表上进行。与传统数据库不同,Flink 不在本地管理静态数据;相反,它的查询在外部表上连续运行。
Flink 数据处理流水线开始于 source 表。source 表产生在查询执行期间可以被操作的行;它们是查询时 FROM 子句中引用的表。这些表可能是 Kafka 的 topics,数据库,文件系统,或者任何其它 Flink 知道如何消费的系统。 具体可以参考 apache的官方网站
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 表中,而不是将结果加载到系统内存中。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。