DataBuffer implements DataArchive, DataProvider { @Override public LOS getLOS() { return this.currentParition.getBufferEnv().getLOS(); } @SuppressWarnings("unchecked")  DataBuffer(DataBufferEnv env, DataBufferHelper partitionBufferFactory); @Override boolean isFullyWithinTimeSpan(String feedID, long startTime, TimeUnit timeUnit); @Override Map<String, SortedMap<Long, Map<String, String>>> getData(Set<String> feedIDs, long startTime, long endTime,
            TimeUnit timeUnit); @Override Map<String, List<Map<String, String>>> getData(Set<String> feedIDs, TimeUnit timeUnit, long startTime,
            long endTime); @Override void putData(String feedID, TimeUnit timeUnit, Map<Long, Map<String, String>> entries); @Override void putData(Map<String, Map<Long, Map<String, String>>> value, TimeUnit timeUnit,
                    Runnable callback); @Override void putData(String feedID, TimeUnit timeUnit, long time, Map<String, String> value); int getConcurrencyDegree(); int getBufferWriteThreadPoolSize(); @Override void reset(); void closeBuffer(); boolean isDataBufferClose(); boolean isAllDataBuffersClose(); void prepareForNextPartition(); void moveToNextPartition(); @Override LOS getLOS();  }
@Test public void fastLOSTest() { Assert.assertEquals(dataBuffer.getLOS(), LOS.medium); }