in src/main/java/com/aliyun/openservices/paifeaturestore/dao/FeatureViewFeatureDBDao.java [822:844]
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;
}