Package org.apache.hadoop.ozone.container.common.helpers

Class ContainerMetrics

java.lang.Object
org.apache.hadoop.ozone.container.common.helpers.ContainerMetrics
All Implemented Interfaces:
Closeable, AutoCloseable
@Private @Metrics(about="Storage Container DataNode Metrics", context="dfs") public class ContainerMetrics extends Object implements Closeable
This class is for maintaining the various Storage Container DataNode statistics and publishing them through the metrics interfaces. This also registers the JMX MBean for RPC.

This class has a number of metrics variables that are publicly accessible; these variables (objects) have methods to update their values; for example:

numOps.inc()

  • Field Details

  • Constructor Details

    • ContainerMetrics

      public ContainerMetrics(int[] intervals)

  • Method Details

    • create

      public static ContainerMetrics create(org.apache.hadoop.hdds.conf.ConfigurationSource conf)

    • remove

      public static void remove()

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • incContainerOpsMetrics

      public void incContainerOpsMetrics(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.Type type)

    • incContainerOpsLatencies

      public void incContainerOpsLatencies(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.Type type, long latencyNs)

    • incContainerBytesStats

      public void incContainerBytesStats(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.Type type, long bytes)

    • incClosedContainerBytesStats

      public void incClosedContainerBytesStats(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.Type type, long bytes)

    • incContainerDeleteFailedBlockCountNotZero

      public void incContainerDeleteFailedBlockCountNotZero()

    • incContainerDeleteFailedNonEmpty

      public void incContainerDeleteFailedNonEmpty()

    • incContainersForceDelete

      public void incContainersForceDelete()

    • getContainerDeleteFailedNonEmpty

      public long getContainerDeleteFailedNonEmpty()

    • getContainerDeleteFailedBlockCountNotZero

      public long getContainerDeleteFailedBlockCountNotZero()

    • getContainerForceDelete

      public long getContainerForceDelete()

    • incNumReadStateMachine

      public void incNumReadStateMachine()

    • getNumReadStateMachine

      public long getNumReadStateMachine()

    • incBytesReadStateMachine

      public void incBytesReadStateMachine(long bytes)

    • getBytesReadStateMachine

      public long getBytesReadStateMachine()

    • incContainerReconciledWithoutChanges

      public void incContainerReconciledWithoutChanges()

    • incContainerReconciledWithChanges

      public void incContainerReconciledWithChanges()