blueflood-core/src/main/java/com/rackspacecloud/blueflood/io/astyanax/AstyanaxWriter.java
private void insertLocatorIfDelayed(IMetric metric, MutationBatch mutationBatch, Clock clock) {
        Locator locator = metric.getLocator();

        long delay = clock.now().getMillis() - metric.getCollectionTime();
        if (delay > MAX_AGE_ALLOWED) {

            //track locator for configured granularity level. to re-roll only the delayed locator's for that slot
            int slot = DELAYED_METRICS_STORAGE_GRANULARITY.slot(metric.getCollectionTime());
            if (!LocatorCache.getInstance().isDelayedLocatorForASlotCurrent(slot, locator)) {
                insertDelayedLocator(DELAYED_METRICS_STORAGE_GRANULARITY, slot, locator, mutationBatch);
                LocatorCache.getInstance().setDelayedLocatorForASlotCurrent(slot, locator);
            }
        }
    }
private void insertLocatorIfDelayed(IMetric metric, MutationBatch mutationBatch, Clock clock) {
        Locator locator = metric.getLocator();

        long delay = clock.now().getMillis() - metric.getCollectionTime();
        if (delay > MAX_AGE_ALLOWED) {

            //track locator for configured granularity level. to re-roll only the delayed locator's for that slot
            int slot = DELAYED_METRICS_STORAGE_GRANULARITY.slot(metric.getCollectionTime());
            if (!LocatorCache.getInstance().isDelayedLocatorForASlotCurrent(slot, locator)) {
                insertDelayedLocator(DELAYED_METRICS_STORAGE_GRANULARITY, slot, locator, mutationBatch);
                LocatorCache.getInstance().setDelayedLocatorForASlotCurrent(slot, locator);
            }
        }
    }
private void insertLocatorIfDelayed ( IMetric metric , MutationBatch mutationBatch , Clock clock ) { Locator locator = metric . getLocator ( ) ; long delay = clock . now ( ) . getMillis ( ) - metric . getCollectionTime ( ) ; if ( delay > MAX_AGE_ALLOWED ) { //track locator for configured granularity level. to re-roll only the delayed locator's for that slot int slot = DELAYED_METRICS_STORAGE_GRANULARITY . slot ( metric . getCollectionTime ( ) ) ; if ( ! LocatorCache . getInstance ( ) . isDelayedLocatorForASlotCurrent ( slot , locator ) ) { insertDelayedLocator ( DELAYED_METRICS_STORAGE_GRANULARITY , slot , locator , mutationBatch ) ; LocatorCache . getInstance ( ) . setDelayedLocatorForASlotCurrent ( slot , locator ) ; } } }
This method inserts the locator into the metric_delayed_locator column family, if the metric is delayed.

@param metric
@param mutationBatch
@param clock
This method inserts the locator into the metric_delayed_locator column family if the metric is delayed .