Package org.apache.hadoop.hdfs.server.datanode.erasurecode

Class StripedBlockChecksumCompositeCrcReconstructor

java.lang.Object

org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedBlockChecksumReconstructor

org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedBlockChecksumCompositeCrcReconstructor

All Implemented Interfaces:

Closeable, AutoCloseable

@Private
public class StripedBlockChecksumCompositeCrcReconstructor
extends StripedBlockChecksumReconstructor

Computes striped composite CRCs over reconstructed chunk CRCs.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
StripedBlockChecksumCompositeCrcReconstructor(ErasureCodingWorker worker, StripedReconstructionInfo stripedReconInfo, org.apache.hadoop.io.DataOutputBuffer checksumWriter, long requestedBlockLength)

Method Summary

Modifier and Type	Method	Description
long	getBytesRead()
long	getBytesWritten()
org.apache.hadoop.util.DataChecksum	getChecksum()
Object	getDigestObject()	Should return a representation of a completed/reconstructed digest which is suitable for debug printing.
ErasureCodingWorker	getErasureCodingWorker()
long	getRemoteBytesRead()
void	incrBytesRead(boolean local, long delta)
void	incrBytesWritten(long delta)
protected void	initDecoderIfNecessary()
protected void	initDecodingValidatorIfNecessary()
protected static void	markBuffers(ByteBuffer[] buffers)
protected static void	resetBuffers(ByteBuffer[] buffers)

Methods inherited from class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedBlockChecksumReconstructor

close, getChecksumDataLen, getChecksumWriter, reconstruct

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

Constructor Details

StripedBlockChecksumCompositeCrcReconstructor

public StripedBlockChecksumCompositeCrcReconstructor(ErasureCodingWorker worker,
 StripedReconstructionInfo stripedReconInfo,
 org.apache.hadoop.io.DataOutputBuffer checksumWriter,
 long requestedBlockLength)
                                              throws IOException

Throws:

IOException

Method Details

getDigestObject

public Object getDigestObject()

Description copied from class: StripedBlockChecksumReconstructor

Should return a representation of a completed/reconstructed digest which is suitable for debug printing.

Specified by:

getDigestObject in class StripedBlockChecksumReconstructor

incrBytesRead

public void incrBytesRead(boolean local,
 long delta)

incrBytesWritten

public void incrBytesWritten(long delta)

getBytesRead

public long getBytesRead()

getRemoteBytesRead

public long getRemoteBytesRead()

getBytesWritten

public long getBytesWritten()

initDecoderIfNecessary

protected void initDecoderIfNecessary()

initDecodingValidatorIfNecessary

protected void initDecodingValidatorIfNecessary()

getChecksum

public org.apache.hadoop.util.DataChecksum getChecksum()

getErasureCodingWorker

public ErasureCodingWorker getErasureCodingWorker()

markBuffers

protected static void markBuffers(ByteBuffer[] buffers)

resetBuffers

protected static void resetBuffers(ByteBuffer[] buffers)