blueflood-core/src/main/java/com/rackspacecloud/blueflood/io/datastax/DAbstractMetricsRW.java
protected Map<Locator, MetricData> resultSetsToMetricData(Map<Locator, List<ResultSetFuture>> resultSets,
                                                              Map<Locator, DAbstractMetricIO> locatorIO,
                                                              String columnFamily,
                                                              Range range) {

        MetadataCache metadataCache = MetadataCache.getInstance();

        // iterate through all ResultSetFuture
        Map<Locator, MetricData> locatorMetricDataMap = new HashMap<Locator, MetricData>();
        for (Map.Entry<Locator, List<ResultSetFuture>> entry : resultSets.entrySet() ) {
            Locator locator = entry.getKey();
            List<ResultSetFuture> futures = entry.getValue();

            DAbstractMetricIO io = locatorIO.get(locator);

            // get ResultSets to a Table of locator, timestamp, rollup
            Table<Locator, Long, Object> locatorTimestampRollup = io.toLocatorTimestampValue(futures, locator, columnFamily, range);

            Map<Long, Object> tsRollupMap = locatorTimestampRollup.row( locator );

            // convert to Points and MetricData
            Points points = convertToPoints( tsRollupMap );

            // create MetricData
            MetricData metricData = new MetricData( points, metadataCache.getUnitString( locator ) );
            locatorMetricDataMap.put( locator, metricData );
        }
        return locatorMetricDataMap;
    }
protected Map<Locator, MetricData> resultSetsToMetricData(Map<Locator, List<ResultSetFuture>> resultSets,
                                                              Map<Locator, DAbstractMetricIO> locatorIO,
                                                              String columnFamily,
                                                              Range range) {

        MetadataCache metadataCache = MetadataCache.getInstance();

        // iterate through all ResultSetFuture
        Map<Locator, MetricData> locatorMetricDataMap = new HashMap<Locator, MetricData>();
        for (Map.Entry<Locator, List<ResultSetFuture>> entry : resultSets.entrySet() ) {
            Locator locator = entry.getKey();
            List<ResultSetFuture> futures = entry.getValue();

            DAbstractMetricIO io = locatorIO.get(locator);

            // get ResultSets to a Table of locator, timestamp, rollup
            Table<Locator, Long, Object> locatorTimestampRollup = io.toLocatorTimestampValue(futures, locator, columnFamily, range);

            Map<Long, Object> tsRollupMap = locatorTimestampRollup.row( locator );

            // convert to Points and MetricData
            Points points = convertToPoints( tsRollupMap );

            // create MetricData
            MetricData metricData = new MetricData( points, metadataCache.getUnitString( locator ) );
            locatorMetricDataMap.put( locator, metricData );
        }
        return locatorMetricDataMap;
    }
protected Map < Locator , MetricData > resultSetsToMetricData ( Map < Locator , List < ResultSetFuture > > resultSets , Map < Locator , DAbstractMetricIO > locatorIO , String columnFamily , Range range ) { MetadataCache metadataCache = MetadataCache . getInstance ( ) ; // iterate through all ResultSetFuture Map < Locator , MetricData > locatorMetricDataMap = new HashMap < Locator , MetricData > ( ) ; for ( Map . Entry < Locator , List < ResultSetFuture > > entry : resultSets . entrySet ( ) ) { Locator locator = entry . getKey ( ) ; List < ResultSetFuture > futures = entry . getValue ( ) ; DAbstractMetricIO io = locatorIO . get ( locator ) ; // get ResultSets to a Table of locator, timestamp, rollup Table < Locator , Long , Object > locatorTimestampRollup = io . toLocatorTimestampValue ( futures , locator , columnFamily , range ) ; Map < Long , Object > tsRollupMap = locatorTimestampRollup . row ( locator ) ; // convert to Points and MetricData Points points = convertToPoints ( tsRollupMap ) ; // create MetricData MetricData metricData = new MetricData ( points , metadataCache . getUnitString ( locator ) ) ; locatorMetricDataMap . put ( locator , metricData ) ; } return locatorMetricDataMap ; }
Converts a list of {@link com.datastax.driver.core.ResultSetFuture} for each
{@link com.rackspacecloud.blueflood.types.Locator} to
{@link com.rackspacecloud.blueflood.outputs.formats.MetricData} object.

@param resultSets
@param locatorIO
@param columnFamily
@return
Converts a list of { @link com . datastax . driver . core . ResultSetFuture } for each { @link com . rackspacecloud . blueflood . types . Locator } to { @link com . rackspacecloud . blueflood . outputs . formats . MetricData } object .