@Override
    public void insertLocator(Locator locator) throws IOException {
        Session session = DatastaxIO.getSession();

        Timer.Context timer = Instrumentation.getWriteTimerContext(CassandraModel.CF_METRICS_LOCATOR_NAME);
        try {
            // bound values and execute
            BoundStatement bs = getBoundStatementForLocator(locator);
            session.execute(bs);
        } finally {
            timer.stop();
        }
    }
@ Override public void insertLocator ( Locator locator ) throws IOException { Session session = DatastaxIO . getSession ( ) ; Timer . Context timer = Instrumentation . getWriteTimerContext ( CassandraModel . CF_METRICS_LOCATOR_NAME ) ; try { BoundStatement bs = getBoundStatementForLocator ( locator ) ; session . execute ( bs ) ; } finally { timer . stop ( ) ; } }
Insert a locator with key = shard long value calculated using Util.getShard()
@param locator
@throws IOException