@Test public void initiallyAcceptsAdditionalBatches() { assertThat(accumulator.shouldAcceptAdditionalBatch()).isTrue(); }
boolean shouldAcceptAdditionalBatch() { return accumulatedWrites.size() < SweepQueueUtils.SWEEP_BATCH_SIZE && nextBatchAvailable && progressTimestamp < (sweepTimestamp - 1); }
SweepBatchAccumulator { boolean shouldAcceptAdditionalBatch() { return accumulatedWrites.size() < SweepQueueUtils.SWEEP_BATCH_SIZE && nextBatchAvailable && progressTimestamp < (sweepTimestamp - 1); } }
SweepBatchAccumulator { boolean shouldAcceptAdditionalBatch() { return accumulatedWrites.size() < SweepQueueUtils.SWEEP_BATCH_SIZE && nextBatchAvailable && progressTimestamp < (sweepTimestamp - 1); } SweepBatchAccumulator(long sweepTimestamp, long progressTimestamp); }
SweepBatchAccumulator { boolean shouldAcceptAdditionalBatch() { return accumulatedWrites.size() < SweepQueueUtils.SWEEP_BATCH_SIZE && nextBatchAvailable && progressTimestamp < (sweepTimestamp - 1); } SweepBatchAccumulator(long sweepTimestamp, long progressTimestamp);  }
SweepBatchAccumulator { boolean shouldAcceptAdditionalBatch() { return accumulatedWrites.size() < SweepQueueUtils.SWEEP_BATCH_SIZE && nextBatchAvailable && progressTimestamp < (sweepTimestamp - 1); } SweepBatchAccumulator(long sweepTimestamp, long progressTimestamp);   }