SegmentMemoryStore implements IStreamingGTSearcher { public int getRowCount() { return rowCount.get(); } SegmentMemoryStore(ParsedStreamingCubeInfo parsedStreamingCubeInfo, String segmentName); void setDictionaryMap(Map<TblColRef, Dictionary<String>> dictionaryMap); int index(StreamingMessage event); int getRowCount(); int getOriginRowCount(); ConcurrentSkipListMap<String[], MeasureAggregator[]> getBasicCuboidData(); Map<CuboidInfo, ConcurrentSkipListMap<String[], MeasureAggregator[]>> getAdditionalCuboidsData(); ConcurrentSkipListMap<String[], MeasureAggregator[]> getCuboidData(long cuboidID); long getMinEventTime(); long getMaxEventTime(); @Override void search(StreamingSearchContext searchContext, ResultCollector collector);  }
@Test public void testIndexEvent() { prepareDataToMemoryStore(50000); assertEquals(50000, memoryStore.getRowCount()); }
@Test public void testIndexEventForMultipleCuboids() { setBuildAdditionalCuboids(); int eventCnt = 50000; prepareDataToMemoryStore(eventCnt); int expectedCnt = eventCnt + eventCnt + 10; assertEquals(expectedCnt, memoryStore.getRowCount()); }