in src/main/java/com/aliyun/openservices/paifeaturestore/dao/FeatureViewHologresDao.java [402:424]
public List<SequenceInfo> MergeOnOfflineSeq(List<SequenceInfo> offlineSequence, List<SequenceInfo> onlineSequence,FeatureViewSeqConfig config,String event){
if (offlineSequence.isEmpty()) {
return onlineSequence;
} else if(onlineSequence.isEmpty()) {
return offlineSequence;
} else {
int index=0;
for (;index<onlineSequence.size();) {
if (Long.valueOf(onlineSequence.get(index).getTimestampField()) < Long.valueOf(offlineSequence.get(0).getTimestampField())) {
break;
}
index++;
}
onlineSequence=onlineSequence.subList(0,index);
onlineSequence.addAll(offlineSequence);
if (onlineSequence.size() > config.getSeqLenOnline()) {
onlineSequence.subList(0,config.getSeqLenOnline());
}
}
return onlineSequence;
}