org.apache.hadoop.fs

类 FSOutputSummer

java.lang.Object

java.io.OutputStream

org.apache.hadoop.fs.FSOutputSummer

所有已实现的接口:

Closeable, Flushable, AutoCloseable

public abstract class FSOutputSummer
extends OutputStream

This is a generic output stream for generating checksums for data before it is written to the underlying stream

构造器概要

构造器

限定符	构造器和说明
protected	FSOutputSummer(Checksum sum, int maxChunkSize, int checksumSize)

方法概要

方法

限定符和类型	方法和说明
static byte[]	convertToByteStream(Checksum sum, int checksumSize) Converts a checksum integer value to a byte stream
protected void	flushBuffer()
protected void	flushBuffer(boolean keep)
protected void	resetChecksumChunk(int size) Resets existing buffer with a new one of the specified size.
void	write(byte[] b, int off, int len) Writes len bytes from the specified byte array starting at offset off and generate a checksum for each data chunk.
void	write(int b) Write one byte
protected abstract void	writeChunk(byte[] b, int offset, int len, byte[] checksum)

从类继承的方法 java.io.OutputStream

close, flush, write

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

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

构造器详细资料

FSOutputSummer

protected FSOutputSummer(Checksum sum,
              int maxChunkSize,
              int checksumSize)

方法详细资料

writeChunk

protected abstract void writeChunk(byte[] b,
              int offset,
              int len,
              byte[] checksum)
                            throws IOException

抛出:

IOException

write

public void write(int b)
           throws IOException

Write one byte

指定者:

write 在类中 OutputStream

抛出:

IOException

write

public void write(byte[] b,
         int off,
         int len)
           throws IOException

Writes len bytes from the specified byte array starting at offset off and generate a checksum for each data chunk.

This method stores bytes from the given array into this stream's buffer before it gets checksumed. The buffer gets checksumed and flushed to the underlying output stream when all data in a checksum chunk are in the buffer. If the buffer is empty and requested length is at least as large as the size of next checksum chunk size, this method will checksum and write the chunk directly to the underlying output stream. Thus it avoids uneccessary data copy.

覆盖:

write 在类中 OutputStream

参数:

b - the data.

off - the start offset in the data.

len - the number of bytes to write.

抛出:

IOException - if an I/O error occurs.

flushBuffer

protected void flushBuffer()
                    throws IOException

抛出:

IOException

flushBuffer

protected void flushBuffer(boolean keep)
                    throws IOException

抛出:

IOException

convertToByteStream

public static byte[] convertToByteStream(Checksum sum,
                         int checksumSize)

Converts a checksum integer value to a byte stream

resetChecksumChunk

protected void resetChecksumChunk(int size)

Resets existing buffer with a new one of the specified size.