blueflood-core/src/main/java/com/rackspacecloud/blueflood/io/datastax/DAbstractMetricIO.java
protected Map<Locator, List<ResultSetFuture>> selectForLocatorListAndRange(String columnFamilyName,
                                                                               List<Locator> locators,
                                                                               Range range) {
        Map<Locator, List<ResultSetFuture>> locatorFuturesMap = new HashMap<Locator, List<ResultSetFuture>>();
        for (Locator locator : locators) {
            List<ResultSetFuture> existing = locatorFuturesMap.get(locator);
            if ( existing == null ) {
                existing = new ArrayList<ResultSetFuture>();
                locatorFuturesMap.put(locator, existing);
            }
            existing.addAll(selectForLocatorAndRange(columnFamilyName, locator, range));
        }
        return locatorFuturesMap;
    }
protected Map<Locator, List<ResultSetFuture>> selectForLocatorListAndRange(String columnFamilyName,
                                                                               List<Locator> locators,
                                                                               Range range) {
        Map<Locator, List<ResultSetFuture>> locatorFuturesMap = new HashMap<Locator, List<ResultSetFuture>>();
        for (Locator locator : locators) {
            List<ResultSetFuture> existing = locatorFuturesMap.get(locator);
            if ( existing == null ) {
                existing = new ArrayList<ResultSetFuture>();
                locatorFuturesMap.put(locator, existing);
            }
            existing.addAll(selectForLocatorAndRange(columnFamilyName, locator, range));
        }
        return locatorFuturesMap;
    }
protected Map < Locator , List < ResultSetFuture > > selectForLocatorListAndRange ( String columnFamilyName , List < Locator > locators , Range range ) { Map < Locator , List < ResultSetFuture > > locatorFuturesMap = new HashMap < Locator , List < ResultSetFuture > > ( ) ; for ( Locator locator : locators ) { List < ResultSetFuture > existing = locatorFuturesMap . get ( locator ) ; if ( existing == null ) { existing = new ArrayList < ResultSetFuture > ( ) ; locatorFuturesMap . put ( locator , existing ) ; } existing . addAll ( selectForLocatorAndRange ( columnFamilyName , locator , range ) ) ; } return locatorFuturesMap ; }
Asynchronously execute select statements against the specified
column family for a specific list of
{@link com.rackspacecloud.blueflood.types.Locator} and
{@link com.rackspacecloud.blueflood.types.Range}

@param locators
@param range
@return a map of Locator -> a list of ResultSetFuture
Asynchronously execute select statements against the specified column family for a specific list of { @link com . rackspacecloud . blueflood . types . Locator } and { @link com . rackspacecloud . blueflood . types . Range }