FixedFrequencyFlushSignal implements FlushSignal { @Override public void reset() { minTime = Long.MAX_VALUE; maxTime = Long.MIN_VALUE; LOG.debug("Flush counters reset"); } FixedFrequencyFlushSignal(long flushFrequencyMillis); @Override void reset(); @Override void update(long timestamp); @Override boolean isTimeToFlush(); @Override long currentTimeMillis();  }
@Test public void testReset() { FixedFrequencyFlushSignal signal = new FixedFrequencyFlushSignal(4000); signal.update(1000); signal.update(6000); assertTrue(signal.isTimeToFlush()); signal.reset(); assertFalse(signal.isTimeToFlush()); }