keith-turner commented on a change in pull request #2096:
URL: https://github.com/apache/accumulo/pull/2096#discussion_r632748893
##########
File path:
server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableImpl.java
##########
@@ -539,54 +766,58 @@ public boolean isCompactionEnabled() {
}
}
- @Override
- public void compact(CompactionServiceId service, CompactionJob job,
RateLimiter readLimiter,
- RateLimiter writeLimiter, long queuedTime) {
-
- Set<StoredTabletFile> jobFiles = job.getFiles().stream()
- .map(cf -> ((CompactableFileImpl)
cf).getStoredTabletFile()).collect(Collectors.toSet());
-
- Long compactionId = null;
+ private static class CompactionInfo {
+ Set<StoredTabletFile> jobFiles;
Long checkCompactionId = null;
boolean propogateDeletes = true;
CompactionHelper localHelper;
List<IteratorSetting> iters = List.of();
CompactionConfig localCompactionCfg;
+ boolean selectedAll;
+ Set<StoredTabletFile> selectedFiles;
+ }
+
+ private CompactionInfo reserveFilesForCompaction(CompactionServiceId
service, CompactionJob job) {
Review comment:
Added a comment and used optional
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
