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