Package org.infinispan.stats.wrappers

Class ExtendedStatisticInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.BaseCustomAsyncInterceptor

org.infinispan.stats.wrappers.ExtendedStatisticInterceptor

All Implemented Interfaces:

org.infinispan.commands.Visitor, AsyncInterceptor

public class ExtendedStatisticInterceptor
extends BaseCustomAsyncInterceptor

Take the statistics about relevant visitable commands.

Since:

6.0

Author:

Roberto Palmieri, Sebastiano Peluso, Diego Didona, Pedro Ruivo

Field Summary

Fields inherited from class org.infinispan.interceptors.BaseCustomAsyncInterceptor

cache, embeddedCacheManager

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
ExtendedStatisticInterceptor()

Method Summary

Modifier and Type	Method	Description
String	dumpStatistics()
void	dumpStatisticsToSystemOut()
void	dumpStatisticToFile(String filePath)
double	getAbortRate()
double	getAttribute(ExtendedStatistic statistic)
String	getAvailableExtendedStatistics()
double	getAvgAbortedWriteTxDuration()
double	getAvgClusteredGetCommandSize()
double	getAvgCommitCommandSize()
double	getAvgCommitRtt()
double	getAvgCommitTime()
double	getAvgCompleteNotificationAsync()
double	getAvgGetsPerROTransaction()
double	getAvgGetsPerWrTransaction()
double	getAvgLocalCommitTime()
double	getAvgLocalGetTime()
double	getAvgLocalLockHoldTime()
double	getAvgLocalPrepareTime()
double	getAvgLocalRollbackTime()
double	getAvgLockHoldTime()
double	getAvgLockWaitingTime()
double	getAvgNumNodesCommit()
double	getAvgNumNodesCompleteNotification()
double	getAvgNumNodesPrepare()
double	getAvgNumNodesRemoteGet()
double	getAvgNumNodesRollback()
double	getAvgNumOfLockLocalTx()
double	getAvgNumOfLockRemoteTx()
double	getAvgNumOfLockSuccessLocalTx()
double	getAvgPrepareCommandSize()
double	getAvgPrepareRtt()
double	getAvgPutsPerWrTransaction()
double	getAvgReadOnlyTxDuration()
double	getAvgRemoteCommitTime()
double	getAvgRemoteGetRtt()
double	getAvgRemoteGetsPerROTransaction()
double	getAvgRemoteGetsPerWrTransaction()
double	getAvgRemoteLockHoldTime()
double	getAvgRemotePrepareTime()
double	getAvgRemotePutsPerWrTransaction()
double	getAvgRemoteRollbackTime()
double	getAvgResponseTime()
double	getAvgRollbackRtt()
double	getAvgRollbackTime()
double	getAvgTxArrivalRate()
double	getAvgWriteTxDuration()
CacheStatisticManager	getCacheStatisticManager()
double	getLocalActiveTransactions()
double	getLocalExecutionTimeWithoutLock()
double	getNumAbortedTxDueDeadlock()
double	getNumAbortedTxDueTimeout()
double	getNumberOfCommits()
double	getNumberOfGets()
double	getNumberOfLocalCommits()
double	getNumberOfPuts()
double	getNumberOfRemoteGets()
double	getNumberOfRemotePuts()
double	getNumNodes()
double	getPercentageSuccessWriteTransactions()
double	getPercentageWriteTransactions()
double	getPercentileLocalReadOnlyTransaction(int percentile)
double	getPercentileLocalRWriteTransaction(int percentile)
double	getPercentileRemoteReadOnlyTransaction(int percentile)
double	getPercentileRemoteWriteTransaction(int percentile)
double	getRemoteGetExecutionTime()
double	getRemotePutExecutionTime()
double	getReplicationDegree()
double	getStatisticValue(String statName)
double	getThroughput()
double	getWriteSkewProbability()
void	resetStatistics()
protected void	start()
Object	visitCommitCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.CommitCommand command)
Object	visitComputeCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeCommand command)
Object	visitComputeIfAbsentCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeIfAbsentCommand command)
Object	visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
Object	visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.PrepareCommand command)
Object	visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
Object	visitReadWriteKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyCommand command)
Object	visitRemoveCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
Object	visitReplaceCommand(InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)
Object	visitRollbackCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.RollbackCommand command)

Methods inherited from class org.infinispan.interceptors.BaseCustomAsyncInterceptor

stop

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitClearCommand, visitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.Visitor

visitApplyDeltaCommand, visitRemoveExpiredCommand

Constructor Detail

ExtendedStatisticInterceptor

public ExtendedStatisticInterceptor()

Method Detail

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                                      org.infinispan.commands.write.PutKeyValueCommand command)
                               throws Throwable

Specified by:

visitPutKeyValueCommand in interface org.infinispan.commands.Visitor

Overrides:

visitPutKeyValueCommand in class DDAsyncInterceptor

Throws:

Throwable

visitRemoveCommand

public Object visitRemoveCommand(InvocationContext ctx,
                                 org.infinispan.commands.write.RemoveCommand command)
                          throws Throwable

Specified by:

visitRemoveCommand in interface org.infinispan.commands.Visitor

Overrides:

visitRemoveCommand in class DDAsyncInterceptor

Throws:

Throwable

visitReplaceCommand

public Object visitReplaceCommand(InvocationContext ctx,
                                  org.infinispan.commands.write.ReplaceCommand command)
                           throws Throwable

Specified by:

visitReplaceCommand in interface org.infinispan.commands.Visitor

Overrides:

visitReplaceCommand in class DDAsyncInterceptor

Throws:

Throwable

visitComputeCommand

public Object visitComputeCommand(InvocationContext ctx,
                                  org.infinispan.commands.write.ComputeCommand command)
                           throws Throwable

Specified by:

visitComputeCommand in interface org.infinispan.commands.Visitor

Overrides:

visitComputeCommand in class DDAsyncInterceptor

Throws:

Throwable

visitComputeIfAbsentCommand

public Object visitComputeIfAbsentCommand(InvocationContext ctx,
                                          org.infinispan.commands.write.ComputeIfAbsentCommand command)
                                   throws Throwable

Specified by:

visitComputeIfAbsentCommand in interface org.infinispan.commands.Visitor

Overrides:

visitComputeIfAbsentCommand in class DDAsyncInterceptor

Throws:

Throwable

visitReadWriteKeyCommand

public Object visitReadWriteKeyCommand(InvocationContext ctx,
                                       org.infinispan.commands.functional.ReadWriteKeyCommand command)
                                throws Throwable

Specified by:

visitReadWriteKeyCommand in interface org.infinispan.commands.Visitor

Overrides:

visitReadWriteKeyCommand in class DDAsyncInterceptor

Throws:

Throwable

visitGetKeyValueCommand

public Object visitGetKeyValueCommand(InvocationContext ctx,
                                      org.infinispan.commands.read.GetKeyValueCommand command)
                               throws Throwable

Specified by:

visitGetKeyValueCommand in interface org.infinispan.commands.Visitor

Overrides:

visitGetKeyValueCommand in class DDAsyncInterceptor

Throws:

Throwable

visitGetAllCommand

public Object visitGetAllCommand(InvocationContext ctx,
                                 org.infinispan.commands.read.GetAllCommand command)
                          throws Throwable

Specified by:

visitGetAllCommand in interface org.infinispan.commands.Visitor

Overrides:

visitGetAllCommand in class DDAsyncInterceptor

Throws:

Throwable

visitPrepareCommand

public Object visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx,
                                  org.infinispan.commands.tx.PrepareCommand command)
                           throws Throwable

Specified by:

visitPrepareCommand in interface org.infinispan.commands.Visitor

Overrides:

visitPrepareCommand in class DDAsyncInterceptor

Throws:

Throwable

visitCommitCommand

public Object visitCommitCommand(org.infinispan.context.impl.TxInvocationContext ctx,
                                 org.infinispan.commands.tx.CommitCommand command)
                          throws Throwable

Specified by:

visitCommitCommand in interface org.infinispan.commands.Visitor

Overrides:

visitCommitCommand in class DDAsyncInterceptor

Throws:

Throwable

visitRollbackCommand

public Object visitRollbackCommand(org.infinispan.context.impl.TxInvocationContext ctx,
                                   org.infinispan.commands.tx.RollbackCommand command)
                            throws Throwable

Specified by:

visitRollbackCommand in interface org.infinispan.commands.Visitor

Overrides:

visitRollbackCommand in class DDAsyncInterceptor

Throws:

Throwable

getAvgPrepareRtt

public double getAvgPrepareRtt()

getAvgCommitRtt

public double getAvgCommitRtt()

getAvgRemoteGetRtt

public double getAvgRemoteGetRtt()

getAvgRollbackRtt

public double getAvgRollbackRtt()

getAvgCompleteNotificationAsync

public double getAvgCompleteNotificationAsync()

getAvgNumNodesCommit

public double getAvgNumNodesCommit()

getAvgNumNodesCompleteNotification

public double getAvgNumNodesCompleteNotification()

getAvgNumNodesRemoteGet

public double getAvgNumNodesRemoteGet()

getAvgNumNodesPrepare

public double getAvgNumNodesPrepare()

getAvgNumNodesRollback

public double getAvgNumNodesRollback()

getLocalExecutionTimeWithoutLock

public double getLocalExecutionTimeWithoutLock()

getAvgLockHoldTime

public double getAvgLockHoldTime()

getAvgLocalLockHoldTime

public double getAvgLocalLockHoldTime()

getAvgRemoteLockHoldTime

public double getAvgRemoteLockHoldTime()

getAvgCommitTime

public double getAvgCommitTime()

getAvgRollbackTime

public double getAvgRollbackTime()

getAvgPrepareCommandSize

public double getAvgPrepareCommandSize()

getAvgCommitCommandSize

public double getAvgCommitCommandSize()

getAvgClusteredGetCommandSize

public double getAvgClusteredGetCommandSize()

getAvgLockWaitingTime

public double getAvgLockWaitingTime()

getAvgTxArrivalRate

public double getAvgTxArrivalRate()

getPercentageWriteTransactions

public double getPercentageWriteTransactions()

getPercentageSuccessWriteTransactions

public double getPercentageSuccessWriteTransactions()

getNumAbortedTxDueTimeout

public double getNumAbortedTxDueTimeout()

getNumAbortedTxDueDeadlock

public double getNumAbortedTxDueDeadlock()

getAvgReadOnlyTxDuration

public double getAvgReadOnlyTxDuration()

getAvgWriteTxDuration

public double getAvgWriteTxDuration()

getAvgAbortedWriteTxDuration

public double getAvgAbortedWriteTxDuration()

getAvgNumOfLockLocalTx

public double getAvgNumOfLockLocalTx()

getAvgNumOfLockRemoteTx

public double getAvgNumOfLockRemoteTx()

getAvgNumOfLockSuccessLocalTx

public double getAvgNumOfLockSuccessLocalTx()

getAvgLocalPrepareTime

public double getAvgLocalPrepareTime()

getAvgRemotePrepareTime

public double getAvgRemotePrepareTime()

getAvgLocalCommitTime

public double getAvgLocalCommitTime()

getAvgRemoteCommitTime

public double getAvgRemoteCommitTime()

getAvgLocalRollbackTime

public double getAvgLocalRollbackTime()

getAvgRemoteRollbackTime

public double getAvgRemoteRollbackTime()

getAbortRate

public double getAbortRate()

getThroughput

public double getThroughput()

getAvgGetsPerROTransaction

public double getAvgGetsPerROTransaction()

getAvgGetsPerWrTransaction

public double getAvgGetsPerWrTransaction()

getAvgRemoteGetsPerWrTransaction

public double getAvgRemoteGetsPerWrTransaction()

getAvgRemoteGetsPerROTransaction

public double getAvgRemoteGetsPerROTransaction()

getRemoteGetExecutionTime

public double getRemoteGetExecutionTime()

getAvgPutsPerWrTransaction

public double getAvgPutsPerWrTransaction()

getAvgRemotePutsPerWrTransaction

public double getAvgRemotePutsPerWrTransaction()

getRemotePutExecutionTime

public double getRemotePutExecutionTime()

getNumberOfGets

public double getNumberOfGets()

getNumberOfRemoteGets

public double getNumberOfRemoteGets()

getNumberOfPuts

public double getNumberOfPuts()

getNumberOfRemotePuts

public double getNumberOfRemotePuts()

getNumberOfCommits

public double getNumberOfCommits()

getNumberOfLocalCommits

public double getNumberOfLocalCommits()

getWriteSkewProbability

public double getWriteSkewProbability()

getPercentileLocalReadOnlyTransaction

public double getPercentileLocalReadOnlyTransaction(int percentile)

getPercentileRemoteReadOnlyTransaction

public double getPercentileRemoteReadOnlyTransaction(int percentile)

getPercentileLocalRWriteTransaction

public double getPercentileLocalRWriteTransaction(int percentile)

getPercentileRemoteWriteTransaction

public double getPercentileRemoteWriteTransaction(int percentile)

resetStatistics

public void resetStatistics()

getAvgLocalGetTime

public double getAvgLocalGetTime()

getNumNodes

public double getNumNodes()

getReplicationDegree

public double getReplicationDegree()

getLocalActiveTransactions

public double getLocalActiveTransactions()

getAvgResponseTime

public double getAvgResponseTime()

getStatisticValue

public final double getStatisticValue(String statName)

getAvailableExtendedStatistics

public final String getAvailableExtendedStatistics()

dumpStatistics

public final String dumpStatistics()

dumpStatisticsToSystemOut

public final void dumpStatisticsToSystemOut()

dumpStatisticToFile

public final void dumpStatisticToFile(String filePath)
                               throws IOException

Throws:

IOException

getCacheStatisticManager

public final CacheStatisticManager getCacheStatisticManager()

getAttribute

public double getAttribute(ExtendedStatistic statistic)

start

protected void start()

Overrides:

start in class BaseCustomAsyncInterceptor