|
@ -1,5 +1,6 @@
|
|
|
package com.yihu.wlyy.figure.label.storage;
|
|
|
|
|
|
import com.yihu.base.hbase.HBaseAdmin;
|
|
|
import com.yihu.base.hbase.HBaseHelper;
|
|
|
import com.yihu.base.hbase.TableBundle;
|
|
|
import com.yihu.wlyy.figure.label.model.SaveModel;
|
|
@ -26,12 +27,22 @@ public class Store2Hbase implements Storager {
|
|
|
@Autowired
|
|
|
private HBaseHelper hBaseHelper;
|
|
|
|
|
|
@Autowired
|
|
|
private HBaseAdmin hBaseAdmin;
|
|
|
|
|
|
@Override
|
|
|
public void save(List<SaveModel> modelList) {
|
|
|
if(CollectionUtils.isEmpty(modelList)){
|
|
|
return;
|
|
|
}
|
|
|
String[] fieldName = BeanUtil.getFiledName(modelList.get(0));
|
|
|
try {
|
|
|
if(!hBaseAdmin.isTableExists(ConstantUtil.figure_label_hbase_table)){
|
|
|
hBaseAdmin.createTable(ConstantUtil.figure_label_hbase_table,fieldName);
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
logger.error("invalid hbase table:" + ConstantUtil.figure_label_hbase_table);
|
|
|
}
|
|
|
TableBundle tableBundle = new TableBundle();
|
|
|
for (SaveModel saveModel : modelList) {
|
|
|
tableBundle.addFamily(saveModel.getId(), ConstantUtil.figure_label_familyA);
|