org.apache.hadoop.util

类 DataChecksum

java.lang.Object

org.apache.hadoop.util.DataChecksum

所有已实现的接口:

Checksum

public class DataChecksum
extends Object
implements Checksum

This class provides inteface and utilities for processing checksums for DFS data transfers.

字段概要

字段

限定符和类型	字段和说明
static int	CHECKSUM_CRC32
static int	CHECKSUM_NULL
static int	HEADER_LEN
static int	SIZE_OF_INTEGER

方法概要

方法

限定符和类型	方法和说明
boolean	compare(byte[] buf, int offset) Compares the checksum located at buf[offset] with the current checksum.
int	getBytesPerChecksum()
static int	getChecksumHeaderSize()
int	getChecksumSize()
int	getChecksumType()
byte[]	getHeader()
int	getNumBytesInSum()
long	getValue()
static DataChecksum	newDataChecksum(byte[] bytes, int offset) Creates a DataChecksum from HEADER_LEN bytes from arr[offset].
static DataChecksum	newDataChecksum(DataInputStream in) This constructucts a DataChecksum by reading HEADER_LEN bytes from input stream in
static DataChecksum	newDataChecksum(int type, int bytesPerChecksum)
void	reset()
void	update(byte[] b, int off, int len)
void	update(int b)
void	writeHeader(DataOutputStream out) Writes the checksum header to the output stream out.
int	writeValue(byte[] buf, int offset, boolean reset) Writes the current checksum to a buffer.
int	writeValue(DataOutputStream out, boolean reset) Writes the current checksum to the stream.

从类继承的方法 java.lang.Object

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

字段详细资料

HEADER_LEN

public static final int HEADER_LEN

另请参阅:

常量字段值

CHECKSUM_NULL

public static final int CHECKSUM_NULL

另请参阅:

常量字段值

CHECKSUM_CRC32

public static final int CHECKSUM_CRC32

另请参阅:

常量字段值

SIZE_OF_INTEGER

public static final int SIZE_OF_INTEGER

另请参阅:

常量字段值

方法详细资料

newDataChecksum

public static DataChecksum newDataChecksum(int type,
                           int bytesPerChecksum)

newDataChecksum

public static DataChecksum newDataChecksum(byte[] bytes,
                           int offset)

Creates a DataChecksum from HEADER_LEN bytes from arr[offset].

返回:

DataChecksum of the type in the array or null in case of an error.

newDataChecksum

public static DataChecksum newDataChecksum(DataInputStream in)
                                    throws IOException

This constructucts a DataChecksum by reading HEADER_LEN bytes from input stream in

抛出:

IOException

writeHeader

public void writeHeader(DataOutputStream out)
                 throws IOException

Writes the checksum header to the output stream out.

抛出:

IOException

getHeader

public byte[] getHeader()

writeValue

public int writeValue(DataOutputStream out,
             boolean reset)
               throws IOException

Writes the current checksum to the stream. If reset is true, then resets the checksum.

返回:

number of bytes written. Will be equal to getChecksumSize();

抛出:

IOException

writeValue

public int writeValue(byte[] buf,
             int offset,
             boolean reset)
               throws IOException

Writes the current checksum to a buffer. If reset is true, then resets the checksum.

返回:

number of bytes written. Will be equal to getChecksumSize();

抛出:

IOException

compare

public boolean compare(byte[] buf,
              int offset)

Compares the checksum located at buf[offset] with the current checksum.

返回:

true if the checksum matches and false otherwise.

getChecksumType

public int getChecksumType()

getChecksumSize

public int getChecksumSize()

getBytesPerChecksum

public int getBytesPerChecksum()

getNumBytesInSum

public int getNumBytesInSum()

getChecksumHeaderSize

public static int getChecksumHeaderSize()

getValue

public long getValue()

指定者:

getValue 在接口中 Checksum

reset

public void reset()

指定者:

reset 在接口中 Checksum

update

public void update(byte[] b,
          int off,
          int len)

指定者:

update 在接口中 Checksum

update

public void update(int b)

指定者:

update 在接口中 Checksum