ignite使用sql查询的问题:在sparkstreaming中进行ignite的初始化。
final JavaIgniteContextcacheStaticJic = new JavaIgniteContext (jssc.sparkContext(), new IgniteOutClosure () { private static final long serialVersionUID = -6171027872639186886L; public IgniteConfiguration apply() { return new IgniteConfiguration().setCacheConfiguration(cacheCfg); } });
ignite的初始化可以是如下的方式:
final JavaIgniteRDDcacheRdd = jic.fromCache("Cache_Transaction");
但是如果下一步如果要使用sql查询,则必须配置CacheConfiguration
final CacheConfigurationcacheCfg = new CacheConfiguration<>("BIZSecurityStaticExtModel"); //Registering indexed/queryable types. cacheCfg.setIndexedTypes(String.class,BIZSecurityStaticExtModel.class);
然后把cachecfg传给fromcache进行初始化:
final JavaIgniteRDDcacheStatic = cacheStaticJic.fromCache(cacheCfg);
这里注意踩了个大坑:
cachecfg后面的名称必须和value.class一致,否则后面一直报没有打开index
查询的sql如下:
cacheStatic.sql("select adjFactor from BIZSecurityStaticExtModel where symbol = ? and dataDate = ? limit 1"
这里注意表名也就是cachename,否则也有问题。
注意以上的使用必须按照官方说明,初始化好BIZSecurityStaticExtModel,也就是在其中的字段,说明清楚:
@QuerySqlField(index = true)
private String symbol;