code: private Iterator<Map.Entry<DeltaClusteringKey, Compaction>> decodeCompactionsFromCql(final Iterator<Row> iter) {
          return new AbstractIterator<Map.Entry<DeltaClusteringKey, Compaction>>() {
              @Override
              protected Map.Entry<DeltaClusteringKey, Compaction> computeNext() {
                  while (iter.hasNext()) {
                      Row row = iter.next();
                      Compaction compaction = _changeEncoder.decodeCompaction(getValue(row));
                      if (compaction != null) {
                          return Maps.immutableEntry(new DeltaClusteringKey(getChangeId(row), _daoUtils.getNumDeltaBlocks(getValue(row))), compaction);
                      }
                  }
                  return endOfData();
              }
          };
      }
docs: Like {@link #decodeChangesFromCql(java.util.Iterator)} except filtered to only include compactions.