src/java/org/apache/cassandra/streaming/StreamIn.java
/**
     * Request ranges to be transferred from specific CFs
     */
Request ranges to be transferred from specific CFs
Request ranges to be transferred from specific CFs
public static void requestRanges(InetAddress source, String tableName, Collection<ColumnFamilyStore> columnFamilies, Collection<Range<Token>> ranges, Runnable callback, OperationType type)
    {
        assert ranges.size() > 0;
        if (logger.isDebugEnabled())
            logger.debug("Requesting from {} ranges {}", source, StringUtils.join(ranges, ", "));
        StreamInSession session = StreamInSession.create(source, callback);
        StreamRequestMessage srm = new StreamRequestMessage(FBUtilities.getBroadcastAddress(),
                                                            ranges,
                                                            tableName,
                                                            columnFamilies,
                                                            session.getSessionId(),
                                                            type);
        Message message = srm.getMessage(Gossiper.instance.getVersion(source));
        MessagingService.instance().sendOneWay(message, source);
    }
public static void requestRanges ( InetAddress source , String tableName , Collection < ColumnFamilyStore > columnFamilies , Collection < Range < Token > > ranges , Runnable callback , OperationType type ) { assert ranges . size ( ) > 0 ; if ( logger . isDebugEnabled ( ) ) logger . debug ( "Requesting from {} ranges {}" , source , StringUtils . join ( ranges , ", " ) ) ; StreamInSession session = StreamInSession . create ( source , callback ) ; StreamRequestMessage srm = new StreamRequestMessage ( FBUtilities . getBroadcastAddress ( ) , ranges , tableName , columnFamilies , session . getSessionId ( ) , type ) ; Message message = srm . getMessage ( Gossiper . instance . getVersion ( source ) ) ; MessagingService . instance ( ) . sendOneWay ( message , source ) ; }
Request ranges to be transferred from specific CFs
Request ranges to be transferred from specific CFs