Monitor inFlight queries of DataStax Java driver

gistfile1.java

static void reportInFlightQueries(Session session) {
    Session.State state = session.getState();
    System.out.printf("State of %s:%n", session);
    for (Host host : state.getConnectedHosts()) {
        int connections = state.getOpenConnections(host);
        int inFlight = state.getInFlightQueries(host);
        System.out.printf("\t%s:\tconnections=%2s\tinFlight=%4s\tmean=%4s%n",
            host,
            connections,
            inFlight,
            inFlight / connections);
    }
}

// Example of scheduling it at regular intervals:
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
executor.scheduleWithFixedDelay(new Runnable() {
    @Override public void run() {
        reportInFlightQueries(session);
    }
}, 60, 60, TimeUnit.SECONDS);