blueflood-core/src/main/java/com/rackspacecloud/blueflood/io/datastax/DAbstractMetricIO.java
protected <T extends Object> Table<Locator, Long, T> getValuesForLocators( final List<Locator> locators,
                                                                               String columnFamily,
                                                                               Range range ) {

        Table<Locator, Long, T> locatorTimestampRollup = HashBasedTable.create();

        Map<Locator, List<ResultSetFuture>> resultSetFuturesMap = selectForLocatorListAndRange(columnFamily, locators, range);

        for (Map.Entry<Locator, List<ResultSetFuture>> entry : resultSetFuturesMap.entrySet() ) {
            Locator locator = entry.getKey();
            List<ResultSetFuture> futures = entry.getValue();

            Table<Locator, Long, T> result = toLocatorTimestampValue(futures, locator,
                                                    columnFamily,
                                                    range);
            locatorTimestampRollup.putAll(result);
        }
        return locatorTimestampRollup;
    }
protected <T extends Object> Table<Locator, Long, T> getValuesForLocators( final List<Locator> locators,
                                                                               String columnFamily,
                                                                               Range range ) {

        Table<Locator, Long, T> locatorTimestampRollup = HashBasedTable.create();

        Map<Locator, List<ResultSetFuture>> resultSetFuturesMap = selectForLocatorListAndRange(columnFamily, locators, range);

        for (Map.Entry<Locator, List<ResultSetFuture>> entry : resultSetFuturesMap.entrySet() ) {
            Locator locator = entry.getKey();
            List<ResultSetFuture> futures = entry.getValue();

            Table<Locator, Long, T> result = toLocatorTimestampValue(futures, locator,
                                                    columnFamily,
                                                    range);
            locatorTimestampRollup.putAll(result);
        }
        return locatorTimestampRollup;
    }
protected < T extends Object > Table < Locator , Long , T > getValuesForLocators ( final List < Locator > locators , String columnFamily , Range range ) { Table < Locator , Long , T > locatorTimestampRollup = HashBasedTable . create ( ) ; Map < Locator , List < ResultSetFuture > > resultSetFuturesMap = selectForLocatorListAndRange ( columnFamily , locators , range ) ; for ( Map . Entry < Locator , List < ResultSetFuture > > entry : resultSetFuturesMap . entrySet ( ) ) { Locator locator = entry . getKey ( ) ; List < ResultSetFuture > futures = entry . getValue ( ) ; Table < Locator , Long , T > result = toLocatorTimestampValue ( futures , locator , columnFamily , range ) ; locatorTimestampRollup . putAll ( result ) ; } return locatorTimestampRollup ; }
Fetch values for a list of {@link com.rackspacecloud.blueflood.types.Locator}
from the specified column family and range.

This is a base behavior for most rollup types. IO subclasses can override
this behavior as they see fit.

@param locators
@param columnFamily
@param range
@return
Fetch values for a list of { @link com . rackspacecloud . blueflood . types . Locator } from the specified column family and range .