问题描述
基本上,我试图通过连接器将 CDC JSON 数据从 Kafka 主题发送到 Ignite Cache。出于转换目的,我想在 Ignite 的表视图中查找此 JSON 数据。如何映射这些 JSON 字段以点燃 sqlline 表的列?
解决方法
如果我正确理解了您的问题,那应该很简单。
为此可以利用 Java 类。您可以 specify 一个与您的 JSON 结构相对应的结构。连同额外的缓存配置 (CacheConfiguration.setIndexedTypes(…)
) 属性,它将使其支持 SQL。