我正在使用CacheConfiguration与setIndexedTypes(Long.class, StructType.class) StructType是Spark的对象,并使用igniteRDD.saveValues(df.rdd())来推送值。但是,当我试图查询该缓存获得"使用setIndexedTypes或setTypeMetadata方法对CacheConfiguration启用"。我知道在POJO上用querysqlfields注释字段,但这里的值是Spark对象,我们如何做到这一点。
这不起作用,因为StructType
类不知道任何关于Ignite SQL。您应该创建自己的键和值类,并在加载期间将每个StructType
实例转换为键-值对(使用savePairs
方法)。之后,您将能够按照以下描述配置SQL: https://apacheignite.readme.io/docs/sql-queries