将缓存值中的JSON CDC数据映射到Ignite sqlline瘦客户端表

Question

基本上，我试图通过连接器将CDC JSON数据从Kafka主题发送到Ignite Cache。出于转换目的，我想在Ignite的表视图中查找这些JSON数据。如何将这些JSON字段映射到SQLline表的列中？

Answer 1

如果我正确理解了你的问题，它应该很简单。可以利用Java类来实现这一点。您可以指定一个与JSON结构相对应的结构。与附加的缓存配置(CacheConfiguration.setIndexedTypes(…​)(属性一起，它将使其启用SQL。