截至目前(2021年6月),Apache Flink还没有原生支持Iceberg作为维表的功能。Apache Flink目前主要支持的维表存储包括Apache Hive、Apache HBase、Apache Cassandra、Apache Kafka等。
不过,您可以通过自定义维表的实现来使用Iceberg作为维表。具体来说,您可以编写Flink的自定义维表函数(TableFunction)来读取和查询Iceberg表,并将其集成到Flink的查询中。可以使用Iceberg提供的Java API来访问Iceberg表的数据。这样您就能在Flink中使用Iceberg作为维表。
另外,Apache Flink社区也在不断发展和改进,未来可能会添加对Iceberg的原生支持。所以,建议您关注Flink的最新版本和社区动态,以获取最新的支持和功能更新。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。