@Test public void testIndexEvent() { prepareDataToMemoryStore(50000); assertEquals(50000, memoryStore.getRowCount()); }
public int getRowCount() { return rowCount.get(); }
SegmentMemoryStore implements IStreamingGTSearcher { public int getRowCount() { return rowCount.get(); } }
SegmentMemoryStore implements IStreamingGTSearcher { public int getRowCount() { return rowCount.get(); } SegmentMemoryStore(ParsedStreamingCubeInfo parsedStreamingCubeInfo, String segmentName); }
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); }
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);  }