Commits

Anonymous committed a89b219

remove unused compaction controller field from Unwrapper iterator

Comments (0)

Files changed (1)

src/java/org/apache/cassandra/db/compaction/ParallelCompactionIterable.java

         List<CloseableIterator<RowContainer>> sources = new ArrayList<CloseableIterator<RowContainer>>(scanners.size());
         for (ICompactionScanner scanner : scanners)
             sources.add(new Deserializer(scanner, maxInMemorySize));
-        return new Unwrapper(MergeIterator.get(sources, RowContainer.comparator, new Reducer()), controller);
+        return new Unwrapper(MergeIterator.get(sources, RowContainer.comparator, new Reducer()));
     }
 
     private static class Unwrapper extends AbstractIterator<AbstractCompactedRow> implements CloseableIterator<AbstractCompactedRow>
     {
         private final CloseableIterator<CompactedRowContainer> reducer;
-        private final CompactionController controller;
 
-        public Unwrapper(CloseableIterator<CompactedRowContainer> reducer, CompactionController controller)
+        public Unwrapper(CloseableIterator<CompactedRowContainer> reducer)
         {
             this.reducer = reducer;
-            this.controller = controller;
         }
 
         protected AbstractCompactedRow computeNext()