@Test public void sweepTableFromStartRowWithBatchConfigWithExactlyOneNonNullBatchConfigShouldBeSuccessful() { sweeperService.sweepTable(TABLE_REF.getQualifiedName(), Optional.of(encodeStartRow(new byte[] {1, 2, 3})), Optional.empty(), Optional.of(10), Optional.empty(), Optional.empty()); }
@Override public SweepTableResponse sweepTable( String tableName, Optional<String> startRow, Optional<Boolean> fullSweep, Optional<Integer> maxCellTsPairsToExamine, Optional<Integer> candidateBatchSize, Optional<Integer> deleteBatchSize) { TableReference tableRef = getTableRef(tableName); checkTableExists(tableName, tableRef); byte[] decodedStartRow = startRow.map(PtBytes::decodeHexString).orElse(PtBytes.EMPTY_BYTE_ARRAY); SweepBatchConfig config = buildConfigWithOverrides(maxCellTsPairsToExamine, candidateBatchSize, deleteBatchSize); return SweepTableResponse.from(runSweep(fullSweep, tableRef, decodedStartRow, config)); }
SweeperServiceImpl implements SweeperService { @Override public SweepTableResponse sweepTable( String tableName, Optional<String> startRow, Optional<Boolean> fullSweep, Optional<Integer> maxCellTsPairsToExamine, Optional<Integer> candidateBatchSize, Optional<Integer> deleteBatchSize) { TableReference tableRef = getTableRef(tableName); checkTableExists(tableName, tableRef); byte[] decodedStartRow = startRow.map(PtBytes::decodeHexString).orElse(PtBytes.EMPTY_BYTE_ARRAY); SweepBatchConfig config = buildConfigWithOverrides(maxCellTsPairsToExamine, candidateBatchSize, deleteBatchSize); return SweepTableResponse.from(runSweep(fullSweep, tableRef, decodedStartRow, config)); } }
SweeperServiceImpl implements SweeperService { @Override public SweepTableResponse sweepTable( String tableName, Optional<String> startRow, Optional<Boolean> fullSweep, Optional<Integer> maxCellTsPairsToExamine, Optional<Integer> candidateBatchSize, Optional<Integer> deleteBatchSize) { TableReference tableRef = getTableRef(tableName); checkTableExists(tableName, tableRef); byte[] decodedStartRow = startRow.map(PtBytes::decodeHexString).orElse(PtBytes.EMPTY_BYTE_ARRAY); SweepBatchConfig config = buildConfigWithOverrides(maxCellTsPairsToExamine, candidateBatchSize, deleteBatchSize); return SweepTableResponse.from(runSweep(fullSweep, tableRef, decodedStartRow, config)); } SweeperServiceImpl(SpecificTableSweeper specificTableSweeper,
            AdjustableSweepBatchConfigSource sweepBatchConfigSource); }
SweeperServiceImpl implements SweeperService { @Override public SweepTableResponse sweepTable( String tableName, Optional<String> startRow, Optional<Boolean> fullSweep, Optional<Integer> maxCellTsPairsToExamine, Optional<Integer> candidateBatchSize, Optional<Integer> deleteBatchSize) { TableReference tableRef = getTableRef(tableName); checkTableExists(tableName, tableRef); byte[] decodedStartRow = startRow.map(PtBytes::decodeHexString).orElse(PtBytes.EMPTY_BYTE_ARRAY); SweepBatchConfig config = buildConfigWithOverrides(maxCellTsPairsToExamine, candidateBatchSize, deleteBatchSize); return SweepTableResponse.from(runSweep(fullSweep, tableRef, decodedStartRow, config)); } SweeperServiceImpl(SpecificTableSweeper specificTableSweeper,
            AdjustableSweepBatchConfigSource sweepBatchConfigSource); @Override SweepTableResponse sweepTable(
            String tableName,
            Optional<String> startRow,
            Optional<Boolean> fullSweep,
            Optional<Integer> maxCellTsPairsToExamine,
            Optional<Integer> candidateBatchSize,
            Optional<Integer> deleteBatchSize); }
SweeperServiceImpl implements SweeperService { @Override public SweepTableResponse sweepTable( String tableName, Optional<String> startRow, Optional<Boolean> fullSweep, Optional<Integer> maxCellTsPairsToExamine, Optional<Integer> candidateBatchSize, Optional<Integer> deleteBatchSize) { TableReference tableRef = getTableRef(tableName); checkTableExists(tableName, tableRef); byte[] decodedStartRow = startRow.map(PtBytes::decodeHexString).orElse(PtBytes.EMPTY_BYTE_ARRAY); SweepBatchConfig config = buildConfigWithOverrides(maxCellTsPairsToExamine, candidateBatchSize, deleteBatchSize); return SweepTableResponse.from(runSweep(fullSweep, tableRef, decodedStartRow, config)); } SweeperServiceImpl(SpecificTableSweeper specificTableSweeper,
            AdjustableSweepBatchConfigSource sweepBatchConfigSource); @Override SweepTableResponse sweepTable(
            String tableName,
            Optional<String> startRow,
            Optional<Boolean> fullSweep,
            Optional<Integer> maxCellTsPairsToExamine,
            Optional<Integer> candidateBatchSize,
            Optional<Integer> deleteBatchSize);  }