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

Class ContainerData.Statistics

java.lang.Object

org.apache.hadoop.ozone.container.common.impl.ContainerData.Statistics

Enclosing class:

ContainerData

public static class ContainerData.Statistics
extends Object

Read/write/block statistics of a container. This class is thread-safe -- all methods are synchronized.

Constructor Summary

Constructors

Constructor	Description
Statistics()

Method Summary

Modifier and Type	Method	Description
void	addBlockPendingDeletion(long count)
void	assertBlock(long expectedBytes, long expectedCount, long expectedPendingDeletion)
void	assertRead(long expectedBytes, long expectedCount)
void	assertWrite(long expectedBytes, long expectedCount)
ContainerData.BlockByteAndCounts	getBlockByteAndCounts()
long	getBlockBytes()
long	getBlockPendingDeletion()
long	getWriteBytes()
void	incrementBlockCount()
void	resetBlockPendingDeletion()
void	setBlockBytesForTesting(long bytes)
void	setBlockCountForTesting(long count)
org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerDataProto.Builder	setContainerDataProto(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerDataProto.Builder b)
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReplicaProto.Builder	setContainerReplicaProto(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReplicaProto.Builder b)
String	toString()
void	updateBlocks(long bytes, long count, long pendingDeletionIncrement)
void	updateDeletion(long deletedBytes, long deletedBlockCount, long processedBlockCount)
void	updateRead(long length)	Update for reading a block with the given length.
void	updateWrite(long length, boolean overwrite)	Update for writing a block with the given length.

Methods inherited from class java.lang.Object

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

Constructor Details

Statistics

public Statistics()

Method Details

getWriteBytes

public long getWriteBytes()

getBlockBytes

public long getBlockBytes()

getBlockByteAndCounts

public ContainerData.BlockByteAndCounts getBlockByteAndCounts()

getBlockPendingDeletion

public long getBlockPendingDeletion()

incrementBlockCount

public void incrementBlockCount()

updateRead

public void updateRead(long length)

Update for reading a block with the given length.

updateWrite

public void updateWrite(long length,
 boolean overwrite)

Update for writing a block with the given length.

updateDeletion

public void updateDeletion(long deletedBytes,
 long deletedBlockCount,
 long processedBlockCount)

updateBlocks

public void updateBlocks(long bytes,
 long count,
 long pendingDeletionIncrement)

setContainerDataProto

public org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerDataProto.Builder setContainerDataProto(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerDataProto.Builder b)

setContainerReplicaProto

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReplicaProto.Builder setContainerReplicaProto(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReplicaProto.Builder b)

addBlockPendingDeletion

public void addBlockPendingDeletion(long count)

resetBlockPendingDeletion

public void resetBlockPendingDeletion()

assertRead

public void assertRead(long expectedBytes,
 long expectedCount)

assertWrite

public void assertWrite(long expectedBytes,
 long expectedCount)

assertBlock

public void assertBlock(long expectedBytes,
 long expectedCount,
 long expectedPendingDeletion)

setBlockCountForTesting

public void setBlockCountForTesting(long count)

setBlockBytesForTesting

public void setBlockBytesForTesting(long bytes)

toString

public String toString()

Overrides:

toString in class Object