@Override
    public void insertLocator(Locator locator) throws IOException {
        Timer.Context timer = Instrumentation.getWriteTimerContext(CassandraModel.CF_METRICS_LOCATOR_NAME);
        try {
            MutationBatch mutationBatch = AstyanaxIO.getKeyspace().prepareMutationBatch();
            AstyanaxWriter.getInstance().insertLocator(locator, mutationBatch);
            mutationBatch.execute();
        } catch (Exception e) {
            throw new IOException(e);
        } finally {
            timer.stop();
        }
    }
@Override
    public void insertLocator(Locator locator) throws IOException {
        Timer.Context timer = Instrumentation.getWriteTimerContext(CassandraModel.CF_METRICS_LOCATOR_NAME);
        try {
            MutationBatch mutationBatch = AstyanaxIO.getKeyspace().prepareMutationBatch();
            AstyanaxWriter.getInstance().insertLocator(locator, mutationBatch);
            mutationBatch.execute();
        } catch (Exception e) {
            throw new IOException(e);
        } finally {
            timer.stop();
        }
    }
@ Override public void insertLocator ( Locator locator ) throws IOException { Timer . Context timer = Instrumentation . getWriteTimerContext ( CassandraModel . CF_METRICS_LOCATOR_NAME ) ; try { MutationBatch mutationBatch = AstyanaxIO . getKeyspace ( ) . prepareMutationBatch ( ) ; AstyanaxWriter . getInstance ( ) . insertLocator ( locator , mutationBatch ) ; mutationBatch . execute ( ) ; } catch ( Exception e ) { throw new IOException ( e ) ; } finally { timer . stop ( ) ; } }
Insert a locator with key = shard long value calculated using Util.getShard()
@param locator
@throws IOException
Insert a locator with key = shard long value calculated using Util . getShard ()