import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
public OnDiskAtomIterator getSSTableColumnIterator(SSTableReader sstable, DecoratedKey key)
{
    return new SSTableSliceIterator(sstable, key, slices, reversed);
}
 

import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
@Override
public void build()
{
    for (Map.Entry<SSTableReader, Map<ByteBuffer, ColumnIndex>> e : sstables.entrySet())
    {
        SSTableReader sstable = e.getKey();
        Map<ByteBuffer, ColumnIndex> indexes = e.getValue();

        if (!sstable.acquireReference())
        {
            bytesProcessed += getPrimaryIndexLength(sstable);
            continue;
        }

        try
        {
            PerSSTableIndexWriter indexWriter = newWriter(sstable.descriptor.asTemporary(true), indexes, Source.COMPACTION);

            long previousKeyPosition = 0;
            try (KeyIterator keys = new KeyIterator(sstable.descriptor))
            {
                while (keys.hasNext())
                {
                    if (isStopRequested())
                        throw new CompactionInterruptedException(getCompactionInfo());

                    final DecoratedKey key = keys.next();
                    final long keyPosition = keys.getKeyPosition();

                    indexWriter.startRow(key, keyPosition);
                    try (SSTableSliceIterator row = new SSTableSliceIterator(sstable, key, ColumnSlice.ALL_COLUMNS_ARRAY, false))
                    {
                        while (row.hasNext())
                        {
                            OnDiskAtom atom = row.next();
                            if (atom != null && atom instanceof Column)
                                indexWriter.nextColumn((Column) atom);
                        }
                    }
                    catch (IOException ex)
                    {
                        throw new FSReadError(ex, sstable.getFilename());
                    }

                    bytesProcessed += keyPosition - previousKeyPosition;
                    previousKeyPosition = keyPosition;
                }

                completeSSTable(indexWriter, sstable, indexes.values());
            }
        }
        finally
        {
            sstable.releaseReference();
        }
    }
}
 

import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
public ISSTableColumnIterator getSSTableColumnIterator(SSTableReader sstable, DecoratedKey key)
{
    return new SSTableSliceIterator(sstable, key, slices, reversed);
}
 

import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
public IColumnIterator getSSTableColumnIterator(SSTableReader sstable, DecoratedKey key)
{
    return new SSTableSliceIterator(sstable, key, start, finish, reversed);
}