代码示例:
configurationconf();
(hbase.zookeeper.quorum,hadoop1,hadoop2,hadoop3);
htabletablenexthtable(conf,datacollection1);
(scan1);
scanscan1fifthscan();
fifthprefixfilter((row));
filterfilter3newprefixfilter((2017-01-01));
(filter3);
();
resultscannerscanner1(scan1);
(scan2);
intcount0;
jsonarrayarrayfuturejsonarray();
for(resultr:scanner1){
(sssss);
jsonobjectmapofcolvaluesnextjsonobject();//创建json对象应该是一个{name:wp}
for(keyvaluekv:r.raw()){
((row:s,family:s,qualifier:s,qualifiervalue:s,timestamp:s.,
(()),
(()),
(()),
(()),
()));
((()),(()));
}
(mapofcolvalues);
count;
(count);
}
();
();
();
(count);
(-------------finished----------------);
map肯定不能彻底删除元素,用filter删出
filter函数其他提取多列不尝试的值方法追加
filter函数:filter函数是两个筛选后函数,它这个可以根据我们可以设置的条件来筛选数据,
语法:filter(array,include,[if_empty])
第一参数:可以表示想要筛选后的数据区域
第二参数:再次筛选的条件,它是一个布尔值
第三参数:if_empty,据条件假如找不到结果,就直接返回第三参数的值,它是一个可选参数