org.apache.hadoop.io

类 IOUtils

java.lang.Object

org.apache.hadoop.io.IOUtils

public class IOUtils
extends Object

An utility class for I/O related functionality.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	IOUtils.NullOutputStream /dev/null of OutputStreams.

构造器概要

构造器

构造器和说明
IOUtils()

方法概要

方法

限定符和类型	方法和说明
static void	cleanup(org.apache.commons.logging.Log log, Closeable... closeables) Close the Closeable objects and ignore any IOException or null pointers.
static void	closeSocket(Socket sock) Closes the socket ignoring IOException
static void	closeStream(Closeable stream) Closes the stream ignoring IOException.
static void	copyBytes(InputStream in, OutputStream out, Configuration conf) Copies from one stream to another.
static void	copyBytes(InputStream in, OutputStream out, Configuration conf, boolean close) Copies from one stream to another.
static void	copyBytes(InputStream in, OutputStream out, int buffSize) Copies from one stream to another.
static void	copyBytes(InputStream in, OutputStream out, int buffSize, boolean close) Copies from one stream to another.
static void	copyBytes(InputStream in, OutputStream out, long length, int bufferSize, boolean close) Copies the specified length of bytes from in to out.
static void	readFileChannelFully(FileChannel fileChannel, byte[] buf, int off, int len) Reads len bytes in a loop using the channel of the stream
static void	readFully(InputStream in, byte[] buf, int off, int len) Reads len bytes in a loop.
static void	skipFully(InputStream in, long len) Similar to readFully().
static int	wrappedReadForCompressedData(InputStream is, byte[] buf, int off, int len) Utility wrapper for reading from InputStream.

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

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

构造器详细资料

IOUtils

public IOUtils()

方法详细资料

copyBytes

public static void copyBytes(InputStream in,
             OutputStream out,
             int buffSize,
             boolean close)
                      throws IOException

Copies from one stream to another.

参数:

in - InputStrem to read from

out - OutputStream to write to

buffSize - the size of the buffer

close - whether or not close the InputStream and OutputStream at the end. The streams are closed in the finally clause.

抛出:

IOException

copyBytes

public static void copyBytes(InputStream in,
             OutputStream out,
             int buffSize)
                      throws IOException

Copies from one stream to another.

参数:

in - InputStrem to read from

out - OutputStream to write to

buffSize - the size of the buffer

抛出:

IOException

copyBytes

public static void copyBytes(InputStream in,
             OutputStream out,
             Configuration conf)
                      throws IOException

Copies from one stream to another. closes the input and output streams at the end.

参数:

in - InputStrem to read from

out - OutputStream to write to

conf - the Configuration object

抛出:

IOException

copyBytes

public static void copyBytes(InputStream in,
             OutputStream out,
             Configuration conf,
             boolean close)
                      throws IOException

Copies from one stream to another.

参数:

in - InputStrem to read from

out - OutputStream to write to

conf - the Configuration object

close - whether or not close the InputStream and OutputStream at the end. The streams are closed in the finally clause.

抛出:

IOException

copyBytes

public static void copyBytes(InputStream in,
             OutputStream out,
             long length,
             int bufferSize,
             boolean close)
                      throws IOException

Copies the specified length of bytes from in to out.

参数:

in - InputStream to read from

out - OutputStream to write to

length - number of bytes to copy

bufferSize - the size of the buffer

close - whether to close the streams

抛出:

IOException - if bytes can not be read or written

wrappedReadForCompressedData

public static int wrappedReadForCompressedData(InputStream is,
                               byte[] buf,
                               int off,
                               int len)
                                        throws IOException

Utility wrapper for reading from InputStream. It catches any errors thrown by the underlying stream (either IO or decompression-related), and re-throws as an IOException.

参数:

is - - InputStream to be read from

buf - - buffer the data is read into

off - - offset within buf

len - - amount of data to be read

返回:

number of bytes read

抛出:

IOException

readFully

public static void readFully(InputStream in,
             byte[] buf,
             int off,
             int len)
                      throws IOException

Reads len bytes in a loop.

参数:

in - The InputStream to read from

buf - The buffer to fill

off - offset from the buffer

len - the length of bytes to read

抛出:

IOException - if it could not read requested number of bytes for any reason (including EOF)

readFileChannelFully

public static void readFileChannelFully(FileChannel fileChannel,
                        byte[] buf,
                        int off,
                        int len)
                                 throws IOException

Reads len bytes in a loop using the channel of the stream

参数:

fileChannel - a FileChannel to read len bytes into buf

buf - The buffer to fill

off - offset from the buffer

len - the length of bytes to read

抛出:

IOException - if it could not read requested number of bytes for any reason (including EOF)

skipFully

public static void skipFully(InputStream in,
             long len)
                      throws IOException

Similar to readFully(). Skips bytes in a loop.

参数:

in - The InputStream to skip bytes from

len - number of bytes to skip.

抛出:

IOException - if it could not skip requested number of bytes for any reason (including EOF)

cleanup

public static void cleanup(org.apache.commons.logging.Log log,
           Closeable... closeables)

Close the Closeable objects and ignore any IOException or null pointers. Must only be used for cleanup in exception handlers.

参数:

log - the log to record problems to at debug level. Can be null.

closeables - the objects to close

closeStream

public static void closeStream(Closeable stream)

Closes the stream ignoring IOException. Must only be called in cleaning up from exception handlers.

参数:

stream - the Stream to close

closeSocket

public static void closeSocket(Socket sock)

Closes the socket ignoring IOException

参数:

sock - the Socket to close