ddanielr commented on code in PR #3805:
URL: https://github.com/apache/accumulo/pull/3805#discussion_r1663001715
##########
server/gc/src/main/java/org/apache/accumulo/gc/GCRun.java:
##########
@@ -201,13 +202,16 @@ public Stream<Reference> getReferences() {
// combine all the entries read from file and scan columns in the
metadata table
Stream<StoredTabletFile> fileStream = tm.getFiles().stream();
+ // map the files to Reference objects
+ var stream = fileStream.map(f -> new ReferenceFile(tm.getTableId(),
f.getMetaUpdateDelete()));
+
// scans are normally empty, so only introduce a layer of indirection
when needed
final var tmScans = tm.getScans();
if (!tmScans.isEmpty()) {
- fileStream = Stream.concat(fileStream, tmScans.stream());
+ var scanStream =
+ tmScans.stream().map(s -> new ReferenceScan(tm.getTableId(),
s.getMetaUpdateDelete()));
Review Comment:
PR #4724 was created to close the loop
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
