blueflood-core/src/main/java/com/rackspacecloud/blueflood/io/datastax/DAbstractMetricIO.java
public ResultSetFuture putAsync(Locator locator, long collectionTime, Rollup rollup, Granularity granularity, int ttl) {

        Session session = DatastaxIO.getSession();

        // we use batch statement here in case sub classes
        // override the addRollupToBatch() and provide
        // multiple statements
        BatchStatement batch = new BatchStatement();
        addRollupToBatch(batch, locator, rollup, collectionTime, granularity, ttl);

        Collection<Statement> statements = batch.getStatements();
        if ( statements.size() == 1 ) {
            Statement oneStatement = statements.iterator().next();
            return session.executeAsync(oneStatement);
        } else {
            LOG.debug(String.format("Using BatchStatement for %d statements", statements.size()));
            return session.executeAsync(batch);
        }
    }
public ResultSetFuture putAsync(Locator locator, long collectionTime, Rollup rollup, Granularity granularity, int ttl) {

        Session session = DatastaxIO.getSession();

        // we use batch statement here in case sub classes
        // override the addRollupToBatch() and provide
        // multiple statements
        BatchStatement batch = new BatchStatement();
        addRollupToBatch(batch, locator, rollup, collectionTime, granularity, ttl);

        Collection<Statement> statements = batch.getStatements();
        if ( statements.size() == 1 ) {
            Statement oneStatement = statements.iterator().next();
            return session.executeAsync(oneStatement);
        } else {
            LOG.debug(String.format("Using BatchStatement for %d statements", statements.size()));
            return session.executeAsync(batch);
        }
    }
public ResultSetFuture putAsync ( Locator locator , long collectionTime , Rollup rollup , Granularity granularity , int ttl ) { Session session = DatastaxIO . getSession ( ) ; // we use batch statement here in case sub classes // override the addRollupToBatch() and provide // multiple statements BatchStatement batch = new BatchStatement ( ) ; addRollupToBatch ( batch , locator , rollup , collectionTime , granularity , ttl ) ; Collection < Statement > statements = batch . getStatements ( ) ; if ( statements . size ( ) == 1 ) { Statement oneStatement = statements . iterator ( ) . next ( ) ; return session . executeAsync ( oneStatement ) ; } else { LOG . debug ( String . format ( "Using BatchStatement for %d statements" , statements . size ( ) ) ) ; return session . executeAsync ( batch ) ; } }
Asynchronously insert a rolled up metric to the appropriate column family
for a particular granularity

@param locator
@param collectionTime
@param rollup
@param granularity
@return
Asynchronously insert a rolled up metric to the appropriate column family for a particular granularity