com.aliyun.odps.storage.internal.io

Class DiskSpillingInputStream

java.lang.Object

java.io.InputStream

com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

com.aliyun.odps.storage.internal.io.DiskSpillingInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class DiskSpillingInputStream
extends RepeatableFileInputStream

一个将输入流缓存到临时磁盘文件的可重复读流。

它在构造时将一个源输入流的全部内容写入一个临时文件。 然后，所有读取操作都从这个临时文件进行。 最重要的是，当这个流被 close() 时，它会自动删除底层的临时文件。

这个实现兼容 Java 8。

Method Summary

Modifier and Type	Method and Description
void	close() 关闭流并删除底层的临时文件。
static DiskSpillingInputStream	create(InputStream source) 工厂方法，用于创建一个 DiskSpillingInputStream。

Methods inherited from class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

available, getFile, getWrappedInputStream, mark, markSupported, read, read, reset, skip

Methods inherited from class java.io.InputStream

read

Methods inherited from class java.lang.Object

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

Method Detail

create

public static DiskSpillingInputStream create(InputStream source)
                                      throws IOException

工厂方法，用于创建一个 DiskSpillingInputStream。

Parameters:

source - 原始的、不可重置的输入流。

Returns:

一个新的、基于磁盘缓存的可重置流。

Throws:

IOException - 如果创建临时文件或写入时发生错误。

close

public void close()
           throws IOException

关闭流并删除底层的临时文件。

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class RepeatableFileInputStream

Throws:

IOException