com.datastax.driver.core

Class QueryLogger.ConstantThresholdQueryLogger

java.lang.Object

com.datastax.driver.core.QueryLogger

com.datastax.driver.core.QueryLogger.ConstantThresholdQueryLogger

All Implemented Interfaces:

LatencyTracker, LifecycleAwareLatencyTracker

Enclosing class:

QueryLogger

public static class QueryLogger.ConstantThresholdQueryLogger
extends QueryLogger

A QueryLogger that uses a constant threshold in milliseconds to track slow queries. This implementation is the default and should be preferred to QueryLogger.DynamicThresholdQueryLogger which is still in beta state.

Nested Class Summary

Nested classes/interfaces inherited from class com.datastax.driver.core.QueryLogger

QueryLogger.Builder, QueryLogger.ConstantThresholdQueryLogger, QueryLogger.DynamicThresholdQueryLogger

Field Summary

Fields inherited from class com.datastax.driver.core.QueryLogger

cluster, DEFAULT_MAX_LOGGED_PARAMETERS, DEFAULT_MAX_PARAMETER_VALUE_LENGTH, DEFAULT_MAX_QUERY_STRING_LENGTH, DEFAULT_SLOW_QUERY_THRESHOLD_MS, DEFAULT_SLOW_QUERY_THRESHOLD_PERCENTILE, ERROR_LOGGER, maxLoggedParameters, maxParameterValueLength, maxQueryStringLength, NORMAL_LOGGER, SLOW_LOGGER

Method Summary

Modifier and Type	Method and Description
long	getSlowQueryLatencyThresholdMillis() Return the threshold in milliseconds beyond which queries are considered 'slow' and logged as such by the driver.
protected void	maybeLogNormalOrSlowQuery(Host host, Statement statement, long latencyMs)
protected void	maybeLogSlowQuery(Host host, Statement statement, long latencyMs)
void	onRegister(Cluster cluster) Gets invoked when the tracker is registered with a cluster, or at cluster startup if the tracker was registered at initialization with Cluster.register(LatencyTracker).
void	onUnregister(Cluster cluster) Gets invoked when the tracker is unregistered from a cluster, or at cluster shutdown if the tracker was not unregistered.
void	setSlowQueryLatencyThresholdMillis(long slowQueryLatencyThresholdMillis) Set the threshold in milliseconds beyond which queries are considered 'slow' and logged as such by the driver.

Methods inherited from class com.datastax.driver.core.QueryLogger

append, append, appendParameters, appendParameters, builder, countBoundValues, getMaxLoggedParameters, getMaxParameterValueLength, getMaxQueryStringLength, logQuery, maybeLogErrorQuery, maybeLogNormalQuery, parameterValueAsString, parameterValueAsString, setMaxLoggedParameters, setMaxParameterValueLength, setMaxQueryStringLength, statementAsString, update

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getSlowQueryLatencyThresholdMillis

public long getSlowQueryLatencyThresholdMillis()

Return the threshold in milliseconds beyond which queries are considered 'slow' and logged as such by the driver. The default value is QueryLogger.DEFAULT_SLOW_QUERY_THRESHOLD_MS.

Returns:

The threshold in milliseconds beyond which queries are considered 'slow' and logged as such by the driver.

setSlowQueryLatencyThresholdMillis

public void setSlowQueryLatencyThresholdMillis(long slowQueryLatencyThresholdMillis)

Set the threshold in milliseconds beyond which queries are considered 'slow' and logged as such by the driver.

Parameters:

slowQueryLatencyThresholdMillis - Slow queries threshold in milliseconds. It must be strictly positive.

Throws:

IllegalArgumentException - if slowQueryLatencyThresholdMillis <= 0.

maybeLogNormalOrSlowQuery

protected void maybeLogNormalOrSlowQuery(Host host,
                                         Statement statement,
                                         long latencyMs)

Specified by:

maybeLogNormalOrSlowQuery in class QueryLogger

maybeLogSlowQuery

protected void maybeLogSlowQuery(Host host,
                                 Statement statement,
                                 long latencyMs)

onRegister

public void onRegister(Cluster cluster)

Description copied from interface: LifecycleAwareLatencyTracker

Gets invoked when the tracker is registered with a cluster, or at cluster startup if the tracker was registered at initialization with Cluster.register(LatencyTracker).

Parameters:

cluster - the cluster that this tracker is registered with.

onUnregister

public void onUnregister(Cluster cluster)

Description copied from interface: LifecycleAwareLatencyTracker

Gets invoked when the tracker is unregistered from a cluster, or at cluster shutdown if the tracker was not unregistered.

Parameters:

cluster - the cluster that this tracker was registered with.