@Test public void testAccessFileNotInNamespace() throws Exception { AccessCountTableManager manager = initTestEnvironment(); List<FileAccessEvent> accessEvents = new ArrayList<>(); accessEvents.add(new FileAccessEvent("file1", 0)); accessEvents.add(new FileAccessEvent("file2", 1)); accessEvents.add(new FileAccessEvent("file2", 2)); accessEvents.add(new FileAccessEvent("file3", 2)); accessEvents.add(new FileAccessEvent("file3", 3)); accessEvents.add(new FileAccessEvent("file3", 4)); accessEvents.add(new FileAccessEvent("file4", 5)); accessEvents.add(new FileAccessEvent("file3", 5000)); accessEvents.add(new FileAccessEvent("file3", 10000)); manager.onAccessEventsArrived(accessEvents); assertTableEquals(new AccessCountTable(0L, 5000L).getTableName(), "expect1"); assertTableEquals(new AccessCountTable(5000L, 10000L).getTableName(), "expect2"); accessEvents.clear(); accessEvents.add(new FileAccessEvent("file4", 10001)); accessEvents.add(new FileAccessEvent("file4", 10002)); accessEvents.add(new FileAccessEvent("file3", 15000)); accessEvents.add(new FileAccessEvent("file4", 15001)); accessEvents.add(new FileAccessEvent("file3", 20000)); manager.onAccessEventsArrived(accessEvents); assertTableEquals(new AccessCountTable(10000L, 15000L).getTableName(), "expect2"); assertTableEquals(new AccessCountTable(15000L, 20000L).getTableName(), "expect2"); insertNewFile(new MetaStore(druidPool), "file4", 4L); accessEvents.clear(); accessEvents.add(new FileAccessEvent("file4", 25000)); manager.onAccessEventsArrived(accessEvents); assertTableEquals(new AccessCountTable(20000L, 25000L).getTableName(), "expect3"); }
public void onAccessEventsArrived(List<FileAccessEvent> accessEvents) { this.accessEventAggregator.addAccessEvents(accessEvents); }
AccessCountTableManager { public void onAccessEventsArrived(List<FileAccessEvent> accessEvents) { this.accessEventAggregator.addAccessEvents(accessEvents); } }
AccessCountTableManager { public void onAccessEventsArrived(List<FileAccessEvent> accessEvents) { this.accessEventAggregator.addAccessEvents(accessEvents); } AccessCountTableManager(MetaStore adapter);  AccessCountTableManager(MetaStore adapter, ExecutorService service); }
AccessCountTableManager { public void onAccessEventsArrived(List<FileAccessEvent> accessEvents) { this.accessEventAggregator.addAccessEvents(accessEvents); } AccessCountTableManager(MetaStore adapter);  AccessCountTableManager(MetaStore adapter, ExecutorService service); void addTable(AccessCountTable accessCountTable); void onAccessEventsArrived(List<FileAccessEvent> accessEvents); List<AccessCountTable> getTables(long lengthInMillis); static List<AccessCountTable> getTables(
      Map<TimeGranularity, AccessCountTableDeque> tableDeques,
      MetaStore metaStore,
      long lengthInMillis); }
AccessCountTableManager { public void onAccessEventsArrived(List<FileAccessEvent> accessEvents) { this.accessEventAggregator.addAccessEvents(accessEvents); } AccessCountTableManager(MetaStore adapter);  AccessCountTableManager(MetaStore adapter, ExecutorService service); void addTable(AccessCountTable accessCountTable); void onAccessEventsArrived(List<FileAccessEvent> accessEvents); List<AccessCountTable> getTables(long lengthInMillis); static List<AccessCountTable> getTables(
      Map<TimeGranularity, AccessCountTableDeque> tableDeques,
      MetaStore metaStore,
      long lengthInMillis); static final Logger LOG; }