Class 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
    • Constructor Detail

      • ExtendedStatisticInterceptor

        public ExtendedStatisticInterceptor()
    • Method Detail

      • visitPutKeyValueCommand

        public java.lang.Object visitPutKeyValueCommand​(InvocationContext ctx,
                                                        org.infinispan.commands.write.PutKeyValueCommand command)
                                                 throws java.lang.Throwable
        Specified by:
        visitPutKeyValueCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitPutKeyValueCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitRemoveCommand

        public java.lang.Object visitRemoveCommand​(InvocationContext ctx,
                                                   org.infinispan.commands.write.RemoveCommand command)
                                            throws java.lang.Throwable
        Specified by:
        visitRemoveCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitRemoveCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReplaceCommand

        public java.lang.Object visitReplaceCommand​(InvocationContext ctx,
                                                    org.infinispan.commands.write.ReplaceCommand command)
                                             throws java.lang.Throwable
        Specified by:
        visitReplaceCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReplaceCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitComputeCommand

        public java.lang.Object visitComputeCommand​(InvocationContext ctx,
                                                    org.infinispan.commands.write.ComputeCommand command)
                                             throws java.lang.Throwable
        Specified by:
        visitComputeCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitComputeCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitComputeIfAbsentCommand

        public java.lang.Object visitComputeIfAbsentCommand​(InvocationContext ctx,
                                                            org.infinispan.commands.write.ComputeIfAbsentCommand command)
                                                     throws java.lang.Throwable
        Specified by:
        visitComputeIfAbsentCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitComputeIfAbsentCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReadWriteKeyCommand

        public java.lang.Object visitReadWriteKeyCommand​(InvocationContext ctx,
                                                         org.infinispan.commands.functional.ReadWriteKeyCommand command)
                                                  throws java.lang.Throwable
        Specified by:
        visitReadWriteKeyCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReadWriteKeyCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitGetKeyValueCommand

        public java.lang.Object visitGetKeyValueCommand​(InvocationContext ctx,
                                                        org.infinispan.commands.read.GetKeyValueCommand command)
                                                 throws java.lang.Throwable
        Specified by:
        visitGetKeyValueCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitGetKeyValueCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitGetAllCommand

        public java.lang.Object visitGetAllCommand​(InvocationContext ctx,
                                                   org.infinispan.commands.read.GetAllCommand command)
                                            throws java.lang.Throwable
        Specified by:
        visitGetAllCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitGetAllCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitPrepareCommand

        public java.lang.Object visitPrepareCommand​(org.infinispan.context.impl.TxInvocationContext ctx,
                                                    org.infinispan.commands.tx.PrepareCommand command)
                                             throws java.lang.Throwable
        Specified by:
        visitPrepareCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitPrepareCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitCommitCommand

        public java.lang.Object visitCommitCommand​(org.infinispan.context.impl.TxInvocationContext ctx,
                                                   org.infinispan.commands.tx.CommitCommand command)
                                            throws java.lang.Throwable
        Specified by:
        visitCommitCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitCommitCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitRollbackCommand

        public java.lang.Object visitRollbackCommand​(org.infinispan.context.impl.TxInvocationContext ctx,
                                                     org.infinispan.commands.tx.RollbackCommand command)
                                              throws java.lang.Throwable
        Specified by:
        visitRollbackCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitRollbackCommand in class DDAsyncInterceptor
        Throws:
        java.lang.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​(java.lang.String statName)
      • getAvailableExtendedStatistics

        public final java.lang.String getAvailableExtendedStatistics()
      • dumpStatistics

        public final java.lang.String dumpStatistics()
      • dumpStatisticsToSystemOut

        public final void dumpStatisticsToSystemOut()
      • dumpStatisticToFile

        public final void dumpStatisticToFile​(java.lang.String filePath)
                                       throws java.io.IOException
        Throws:
        java.io.IOException