public String map(LogEntity logEntity) throws Exception {
Action actionLastTime = state.value();
Action actionThisTime = new Action(logEntity.getAction(), logEntity.getTime().toString());
int times = 1;
// 如果用户没有操作 则为state创建值
if (actionLastTime == null) {
state.update(actionThisTime);
//actionLastTime = actionThisTime
saveToHBase(logEntity, 1);
}else{
times = getTimesByRule(actionLastTime, actionThisTime);
saveToHBase(logEntity, times);
}
//saveToHBase(logEntity, times);
if (actionThisTime.getType().equals("3")){
state.clear();
}
return null;
}