@Test public void noBatchesMeansEverythingSweptUpToTheSweepTimestamp() { SweepBatchWithPartitionInfo batchWithPartitionInfo = accumulator.toSweepBatch(); assertThat(batchWithPartitionInfo.sweepBatch()).satisfies(batch -> { assertThat(batch.writes()).isEmpty(); assertThat(batch.dedicatedRows()).isEqualTo(NO_DEDICATED_ROWS); assertThat(batch.lastSweptTimestamp()).isEqualTo(SWEEP_TIMESTAMP - 1); }); assertThat(batchWithPartitionInfo.finePartitions()).isEmpty(); }
SweepBatchWithPartitionInfo toSweepBatch() { SweepBatch sweepBatch = SweepBatch.of( getLatestWritesByCellReference(), DedicatedRows.of(accumulatedDedicatedRows), getLastSweptTimestamp(), nextBatchAvailable, entriesRead); return SweepBatchWithPartitionInfo.of(sweepBatch, finePartitions); }
SweepBatchAccumulator { SweepBatchWithPartitionInfo toSweepBatch() { SweepBatch sweepBatch = SweepBatch.of( getLatestWritesByCellReference(), DedicatedRows.of(accumulatedDedicatedRows), getLastSweptTimestamp(), nextBatchAvailable, entriesRead); return SweepBatchWithPartitionInfo.of(sweepBatch, finePartitions); } }
SweepBatchAccumulator { SweepBatchWithPartitionInfo toSweepBatch() { SweepBatch sweepBatch = SweepBatch.of( getLatestWritesByCellReference(), DedicatedRows.of(accumulatedDedicatedRows), getLastSweptTimestamp(), nextBatchAvailable, entriesRead); return SweepBatchWithPartitionInfo.of(sweepBatch, finePartitions); } SweepBatchAccumulator(long sweepTimestamp, long progressTimestamp); }
SweepBatchAccumulator { SweepBatchWithPartitionInfo toSweepBatch() { SweepBatch sweepBatch = SweepBatch.of( getLatestWritesByCellReference(), DedicatedRows.of(accumulatedDedicatedRows), getLastSweptTimestamp(), nextBatchAvailable, entriesRead); return SweepBatchWithPartitionInfo.of(sweepBatch, finePartitions); } SweepBatchAccumulator(long sweepTimestamp, long progressTimestamp);  }
SweepBatchAccumulator { SweepBatchWithPartitionInfo toSweepBatch() { SweepBatch sweepBatch = SweepBatch.of( getLatestWritesByCellReference(), DedicatedRows.of(accumulatedDedicatedRows), getLastSweptTimestamp(), nextBatchAvailable, entriesRead); return SweepBatchWithPartitionInfo.of(sweepBatch, finePartitions); } SweepBatchAccumulator(long sweepTimestamp, long progressTimestamp);   }