如何查询点燃RDD



我正在使用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

相关内容

  • 没有找到相关文章