110111112113114115116117118119120
tracer = tracerFactory.newTracer(getOperationType(), cf); } else { tracer = tracerFactory.newTracer(getOperationType()); } tracer.start(); Statement query = getQuery(); if (LOG.isDebugEnabled()) { LOG.debug("Query: " + query); }
137138139140141142143144145146147
} @Override public ListenableFuture<OperationResult<R>> executeAsync() throws ConnectionException { final CassandraOperationTracer tracer = tracerFactory.newTracer(getOperationType()); tracer.start(); Statement query = getQuery(); if (LOG.isDebugEnabled()) { LOG.debug("Query: " + query);