Job job = executor.newJob(plan);
final UUID jobId = job.id();
if (jobId != null) {
statsTables.jobStarted(jobId, request.stmt());
}
List<ListenableFuture<TaskResult>> resultFutureList = executor.execute(job);
Futures.addCallback(Futures.allAsList(resultFutureList), new FutureCallback<List<TaskResult>>() {
@Override
public void onSuccess(@Nullable List<TaskResult> result) {
TResponse response;