src/java/org/apache/cassandra/streaming/StreamOut.java
/**
     * Stream the given ranges to the target endpoint from each of the given CFs.
    */
Stream the given ranges to the target endpoint from each of the given CFs.
Stream the given ranges to the target endpoint from each of the given CFs .
public static void transferRanges(StreamOutSession session, Iterable<ColumnFamilyStore> cfses, Collection<Range<Token>> ranges, OperationType type)
    {
        assert ranges.size() > 0;
        logger.info("Beginning transfer to {}", session.getHost());
        logger.debug("Ranges are {}", StringUtils.join(ranges, ","));
        try
        {
            flushSSTables(cfses);
            Iterable<SSTableReader> sstables = Collections.emptyList();
            for (ColumnFamilyStore cfStore : cfses)
                sstables = Iterables.concat(sstables, cfStore.markCurrentSSTablesReferenced());
            transferSSTables(session, sstables, ranges, type);
        }
        catch (IOException e)
        {
            throw new IOError(e);
        }
    }
public static void transferRanges ( StreamOutSession session , Iterable < ColumnFamilyStore > cfses , Collection < Range < Token > > ranges , OperationType type ) { assert ranges . size ( ) > 0 ; logger . info ( "Beginning transfer to {}" , session . getHost ( ) ) ; logger . debug ( "Ranges are {}" , StringUtils . join ( ranges , "," ) ) ; try { flushSSTables ( cfses ) ; Iterable < SSTableReader > sstables = Collections . emptyList ( ) ; for ( ColumnFamilyStore cfStore : cfses ) sstables = Iterables . concat ( sstables , cfStore . markCurrentSSTablesReferenced ( ) ) ; transferSSTables ( session , sstables , ranges , type ) ; } catch ( IOException e ) { throw new IOError ( e ) ; } }
Stream the given ranges to the target endpoint from each of the given CFs.
Stream the given ranges to the target endpoint from each of the given CFs .