ExtendedStatisticInterceptor (Infinispan Distribution 7.0.0.Alpha2 API)

java.lang.Object
- org.infinispan.commands.AbstractVisitor
- - org.infinispan.interceptors.base.CommandInterceptor
  - - org.infinispan.interceptors.base.BaseCustomInterceptor
    - - org.infinispan.stats.wrappers.ExtendedStatisticInterceptor

All Implemented Interfaces:

Visitor
```
public class ExtendedStatisticInterceptor
extends BaseCustomInterceptor
```
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.base.BaseCustomInterceptor
  cache, embeddedCacheManager
- Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor
  cacheConfiguration

Constructor Summary

Constructors
Constructor and Description

ExtendedStatisticInterceptor()

Constructors
Constructor and Description
`ExtendedStatisticInterceptor()`

Method Summary

Methods
Modifier and Type	Method and Description
`String`	`dumpStatistics()`
`void`	`dumpStatisticsToSystemOut()`
`void`	`dumpStatisticToFile(String filePath)`
`double`	`getAbortRate()`
`double`	`getAttribute(ExtendedStatistic statistic)`
`String`	`getAvailableExtendedStatistics()`
`double`	`getAvgAbortedWriteTxDuration()`
`double`	`getAvgClusteredGetCommandSize()`
`double`	`getAvgCommitAsync()`
`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`	`getAvgPrepareAsync()`
`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`	`getAvgRollbackAsync()`
`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(TxInvocationContext ctx, CommitCommand command)`
`Object`	`visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command)`
`Object`	`visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command)`
`Object`	`visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command)`
`Object`	`visitRemoveCommand(InvocationContext ctx, RemoveCommand command)`
`Object`	`visitReplaceCommand(InvocationContext ctx, ReplaceCommand command)`
`Object`	`visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command)`

Methods inherited from class org.infinispan.interceptors.base.BaseCustomInterceptor
stop

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor
getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor
visitApplyDeltaCommand, visitClearCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPutMapCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- ExtendedStatisticInterceptor
```
public ExtendedStatisticInterceptor()
```

Method Detail

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                             PutKeyValueCommand command)
                               throws Throwable

Specified by:: visitPutKeyValueCommand in interface Visitor
Overrides:: visitPutKeyValueCommand in class AbstractVisitor
Throws:: Throwable

visitRemoveCommand

public Object visitRemoveCommand(InvocationContext ctx,
                        RemoveCommand command)
                          throws Throwable

Specified by:: visitRemoveCommand in interface Visitor
Overrides:: visitRemoveCommand in class AbstractVisitor
Throws:: Throwable

visitReplaceCommand

public Object visitReplaceCommand(InvocationContext ctx,
                         ReplaceCommand command)
                           throws Throwable

Specified by:: visitReplaceCommand in interface Visitor
Overrides:: visitReplaceCommand in class AbstractVisitor
Throws:: Throwable

visitGetKeyValueCommand

public Object visitGetKeyValueCommand(InvocationContext ctx,
                             GetKeyValueCommand command)
                               throws Throwable

Specified by:: visitGetKeyValueCommand in interface Visitor
Overrides:: visitGetKeyValueCommand in class AbstractVisitor
Throws:: Throwable

visitPrepareCommand

public Object visitPrepareCommand(TxInvocationContext ctx,
                         PrepareCommand command)
                           throws Throwable

Specified by:: visitPrepareCommand in interface Visitor
Overrides:: visitPrepareCommand in class AbstractVisitor
Throws:: Throwable

visitCommitCommand

public Object visitCommitCommand(TxInvocationContext ctx,
                        CommitCommand command)
                          throws Throwable

Specified by:: visitCommitCommand in interface Visitor
Overrides:: visitCommitCommand in class AbstractVisitor
Throws:: Throwable

visitRollbackCommand

public Object visitRollbackCommand(TxInvocationContext ctx,
                          RollbackCommand command)
                            throws Throwable

Specified by:: visitRollbackCommand in interface Visitor
Overrides:: visitRollbackCommand in class AbstractVisitor
Throws:: Throwable

getAvgPrepareRtt
```
public double getAvgPrepareRtt()
```

getAvgCommitRtt
```
public double getAvgCommitRtt()
```

getAvgRemoteGetRtt
```
public double getAvgRemoteGetRtt()
```

getAvgRollbackRtt
```
public double getAvgRollbackRtt()
```

getAvgPrepareAsync
```
public double getAvgPrepareAsync()
```

getAvgCommitAsync
```
public double getAvgCommitAsync()
```

getAvgCompleteNotificationAsync

public double getAvgCompleteNotificationAsync()

getAvgRollbackAsync
```
public double getAvgRollbackAsync()
```

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 BaseCustomInterceptor

Class ExtendedStatisticInterceptor

Field Summary

Fields inherited from class org.infinispan.interceptors.base.BaseCustomInterceptor

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

Constructor Summary

Method Summary

Methods inherited from class org.infinispan.interceptors.base.BaseCustomInterceptor

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor

Methods inherited from class org.infinispan.commands.AbstractVisitor

Methods inherited from class java.lang.Object

Constructor Detail

ExtendedStatisticInterceptor

Method Detail

visitPutKeyValueCommand

visitRemoveCommand

visitReplaceCommand

visitGetKeyValueCommand

visitPrepareCommand

visitCommitCommand

visitRollbackCommand

getAvgPrepareRtt

getAvgCommitRtt

getAvgRemoteGetRtt

getAvgRollbackRtt

getAvgPrepareAsync

getAvgCommitAsync

getAvgCompleteNotificationAsync

getAvgRollbackAsync

getAvgNumNodesCommit

getAvgNumNodesCompleteNotification

getAvgNumNodesRemoteGet

getAvgNumNodesPrepare

getAvgNumNodesRollback

getLocalExecutionTimeWithoutLock

getAvgLockHoldTime

getAvgLocalLockHoldTime

getAvgRemoteLockHoldTime

getAvgCommitTime

getAvgRollbackTime

getAvgPrepareCommandSize

getAvgCommitCommandSize

getAvgClusteredGetCommandSize

getAvgLockWaitingTime

getAvgTxArrivalRate

getPercentageWriteTransactions

getPercentageSuccessWriteTransactions

getNumAbortedTxDueTimeout

getNumAbortedTxDueDeadlock

getAvgReadOnlyTxDuration

getAvgWriteTxDuration

getAvgAbortedWriteTxDuration

getAvgNumOfLockLocalTx

getAvgNumOfLockRemoteTx

getAvgNumOfLockSuccessLocalTx

getAvgLocalPrepareTime

getAvgRemotePrepareTime

getAvgLocalCommitTime

getAvgRemoteCommitTime

getAvgLocalRollbackTime

getAvgRemoteRollbackTime

getAbortRate

getThroughput

getAvgGetsPerROTransaction

getAvgGetsPerWrTransaction

getAvgRemoteGetsPerWrTransaction

getAvgRemoteGetsPerROTransaction

getRemoteGetExecutionTime

getAvgPutsPerWrTransaction

getAvgRemotePutsPerWrTransaction

getRemotePutExecutionTime

getNumberOfGets

getNumberOfRemoteGets

getNumberOfPuts

getNumberOfRemotePuts

getNumberOfCommits

getNumberOfLocalCommits

getWriteSkewProbability

getPercentileLocalReadOnlyTransaction

getPercentileRemoteReadOnlyTransaction

getPercentileLocalRWriteTransaction