我有以下Job类,表示作业的运行。我在Job类中有开始时间和结束时间的列表,因为可以重新运行相同的Job。
public class Job {
private final List<Timestamp> jobStartTimes = new SortedList<>();
private final List<Timestamp> jobEndTimes = new SortedList<>();
private String jobName;
private String jobKey;
private String host;
....
....
}
我有此地图用于查询给定工作关键字的工作。
public class JobMap {
/**
* Here value of 'String' key is jobKey
*/
private final Map<String, Job> jobCache;
}
我还创建了以下哈希表层次结构,用于在Map中存储(starttime,jobKey)和(endtime,jobkey)条目,以便可以更快地检索作业记录。这是必需的,因为我的查询基于时间戳,例如:返回在x和y时间戳之间运行的所有作业。
public class YearCache<T> {
/**
* Here value of 'Integer' key is month number (0, 11)
*/
private final Map<Integer, MonthCache> monthCache;
}
public class MonthCache {
/**
* Here value of 'Integer' key is week number in a month(0, 4)
*/
private final Map<Integer, WeekCache> weekCache;
}
public class WeekCache {
/**
* Here value of 'Integer' key is day number in a week (0, 6)
*/
private final Map<Integer, DayCache> dayCache;
}
private class DayCache
{
/**
* Here value of 'Integer' key is hour value in a day (0, 23)
* T is of type String representing jobKey
*/
private final NavigableMap<Integer, NavigableMap<Timestamp, Set<T>>> hourCache;
}
我想摆脱此Java哈希图,并转到Redis Cache。如何在Redis缓存中对此层次结构建模?
这是必需的,因为我的查询基于时间戳,例如:返回在x和y时间戳之间运行的所有作业。
看一下Redis时间序列模式中的排序时间序列模式] >>。可以找到详细信息here。您可能需要对示例进行一些微调以适合您的需要。摘录自文档:
+---------------+-------------+ | Timestamp | Temperature | +---------------+-------------+ | 1511533205001 | 21 | +---------------+-------------+ | 1511533206001 | 22 | +---------------+-------------+
您可以这样查询:
> ZADD temperature 1511533205001 21 (integer) 1 > ZADD temperature 1511533206001 22 (integer) 1 > ZRANGEBYSCORE temperature -inf +inf WITHSCORES 1) "22" 2) "1511533206001" 3) "21" 4) "1511533207001"
这是一个简单的示例。该链接讨论了此方法的扩展,以处理特定的极端情况。
对于您的情况,假设您有jobStartTime
和jobEndTime
,则可能必须对以开始/结束作业的时间戳为键的jobStarts
和jobEnds
使用单独的集。然后:
让x
代表工作的开始,y
代表工作的结束
x
集中查询在jobStarts
之后开始的所有作业y
集中查询在x
之前完成但在jobsEnds
之后开始的所有作业x
之后开始并在y
之前结束的作业在您的代码中:
public class Job { private final List<Timestamp> jobStartTimes = new SortedList<>(); private final List<Timestamp> jobEndTimes = new SortedList<>(); .... private String jobKey; .... }
您将所有跑步存储为工作的一部分。最好将作业运行与作业分开,以便可以将作业详细信息分别缓存在名为
jobs
的集合中。然后,集jobStarts
和jobEnds
的值可以是jobKey,您可以使用它们从jobs
集中查找详细信息,该集单独存储作业详细信息。