频道栏目
首页 > 资讯 > 云计算 > 正文

ignite使用sql查询的问题

17-04-04        来源:[db:作者]  
收藏   我要投稿

ignite使用sql查询的问题:在sparkstreaming中进行ignite的初始化。

final JavaIgniteContext cacheStaticJic = 
                new JavaIgniteContext(jssc.sparkContext(), new IgniteOutClosure() {
                    private static final long serialVersionUID = -6171027872639186886L;

                    public IgniteConfiguration apply() {
                        return new IgniteConfiguration().setCacheConfiguration(cacheCfg);
                    }
        });

ignite的初始化可以是如下的方式:

final JavaIgniteRDD cacheRdd = jic.fromCache("Cache_Transaction");

但是如果下一步如果要使用sql查询,则必须配置CacheConfiguration

        final CacheConfiguration cacheCfg = new CacheConfiguration<>("BIZSecurityStaticExtModel");
        //Registering indexed/queryable types.
        cacheCfg.setIndexedTypes(String.class,BIZSecurityStaticExtModel.class);

然后把cachecfg传给fromcache进行初始化:

final JavaIgniteRDD cacheStatic = 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;

相关TAG标签
上一篇:解决方法Table'performance_schema.session_variables'doesn'texist
下一篇:Spark2.1集群环境搭建小结(1)
相关文章
图文推荐

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站