介绍用于 Pulsar 和 PulsarCatalog 的 Flink SQL 连接器

张雨霏

英文演讲 2022-07-30 15:30 GMT+8  #streaming

基于新的Flink DataStream API Pulsar连接器,StreamNative团队为Pulsar和PulsarCatalog实现了Flink的表API连接器,以帮助用户通过Flink SQL轻松地与Pulsar集群进行交互。雨飞将通过SQL连接器的设计。他将介绍连接器如何转换脉冲星数据和管理模式演化。还将介绍Pulsar上下文中的SQL语义。最后,雨飞将介绍PulsarCatalog使用Pulsar作为元数据存储的两种不同模式,以及它如何让用户更容易地从Pulsar进行查询。

Speakers:


张雨霏: StreamNative, 软件工程师, 雨霏是StreamNative的软件工程师,专注于Pulsar与Flink生态系统的集成。他是Flink的贡献者和Pulsar的Flink DataStream API连接器的维护者。