com.aliyun.odps.storage.internal.utils

Class IOUtils

java.lang.Object

com.aliyun.odps.storage.internal.utils.IOUtils

public class IOUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static InputStream	newRepeatableInputStream(InputStream original) 将一个输入流包装成可重复读的流，同时尽可能地优化性能。
static int	readFully(InputStream source, byte[] buffer, int offset, int length)
static long	readLittleEndianLong(InputStream in)
static byte[]	readNBytes(InputStream in, int len) 从输入流中精确读取 len 个字节。 这个方法会阻塞，直到 len 个字节被读取，或者流结束，或者发生 I/O 错误。
static void	transferTo(InputStream inputStream, OutputStream outputStream)

Methods inherited from class java.lang.Object

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

Method Detail

newRepeatableInputStream

public static InputStream newRepeatableInputStream(InputStream original)
                                            throws IOException

将一个输入流包装成可重复读的流，同时尽可能地优化性能。

该方法的行为遵循以下优先级：

1. 如果原始流已支持 mark/reset，直接返回。
2. 如果原始流是 FileInputStream，则使用高效的 RepeatableFileInputStream 包装。
3. 对于其他所有情况，将流的内容缓存到一个临时磁盘文件，并返回一个 DiskSpillingInputStream。 这确保了对任意大小、任意来源的流都提供绝对健壮的可重试性。

Parameters:

original - 原始输入流。

Returns:

一个保证可重复读的输入流。

Throws:

IOException - 如果在缓存到磁盘的过程中发生 I/O 错误。

transferTo

public static void transferTo(InputStream inputStream,
                              OutputStream outputStream)
                       throws IOException

Throws:

IOException

readNBytes

public static byte[] readNBytes(InputStream in,
                                int len)
                         throws IOException

从输入流中精确读取 len 个字节。 这个方法会阻塞，直到 len 个字节被读取，或者流结束，或者发生 I/O 错误。

Parameters:

in - 输入流

len - 要读取的字节数

Returns:

包含所读取字节的字节数组

Throws:

IOException - 如果发生 I/O 错误

EOFException - 如果在读取完 len 个字节之前到达流的末尾

readFully

public static int readFully(InputStream source,
                            byte[] buffer,
                            int offset,
                            int length)
                     throws IOException

Throws:

IOException

readLittleEndianLong

public static long readLittleEndianLong(InputStream in)
                                 throws IOException

Throws:

IOException