RedisSimulationSeriesSource extends NonVersionedRedisHistoricalTimeSeriesSource implements SimulationSeriesSource { public void setCurrentSimulationExecutionDate(LocalDate currentSimulationExecutionDate) { _currentSimulationExecutionDate = currentSimulationExecutionDate; } RedisSimulationSeriesSource(JedisPool jedisPool);  RedisSimulationSeriesSource(JedisPool jedisPool, String redisPrefix); @Override RedisSimulationSeriesSource withSimulationDate(LocalDate date); @Override LocalDate getCurrentSimulationExecutionDate(); void setCurrentSimulationExecutionDate(LocalDate currentSimulationExecutionDate); @Override void updateTimeSeriesPoint(UniqueId uniqueId, LocalDate simulationExecutionDate, LocalDate valueDate, double value); @Override void updateTimeSeries(UniqueId uniqueId, LocalDate simulationExecutionDate, LocalDateDoubleTimeSeries timeseries); @Override void replaceTimeSeries(UniqueId uniqueId, LocalDate simulationExecutionDate, LocalDateDoubleTimeSeries timeSeries); @Override void clearExecutionDate(LocalDate simulationExecutionDate); @Override boolean equals(Object o); @Override int hashCode();  }
@Test(enabled=false) public void largePerformanceTest() { RedisSimulationSeriesSource simulationSource = new RedisSimulationSeriesSource(getJedisPool()); LocalDate simulationSeriesDate = LocalDate.now(); int numDaysHistory = 20; for (int i = 0; i < numDaysHistory; i++) { writeOneSimulationSeriesDate(simulationSource, simulationSeriesDate, (20*10)); simulationSeriesDate = simulationSeriesDate.minusDays(1); } OperationTimer timer = new OperationTimer(s_logger, "Loading TS"); Random random = new Random(); for (int i = 0; i < 1000; i++) { LocalDate seriesDate = simulationSeriesDate.minusDays(random.nextInt(numDaysHistory)); UniqueId id = generateId(random.nextInt(1260)); simulationSource.setCurrentSimulationExecutionDate(seriesDate); simulationSource.getHistoricalTimeSeries(id, null, false, null, false); } System.out.println("Loading 1000 TS took " + timer.finished()); }