Package org.apache.flink.core.fs

Class ClosingFSDataInputStream

java.lang.Object

java.io.InputStream

org.apache.flink.core.fs.FSDataInputStream

org.apache.flink.core.fs.FSDataInputStreamWrapper

org.apache.flink.core.fs.ClosingFSDataInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, WrappingProxyCloseable<FSDataInputStream>, WrappingProxy<FSDataInputStream>

Direct Known Subclasses:

ByteBufferReadableClosingFSDataInputStream

@Internal
public class ClosingFSDataInputStream
extends FSDataInputStreamWrapper
implements WrappingProxyCloseable<FSDataInputStream>

This class is a WrappingProxy for FSDataInputStream that is used to implement a safety net against unclosed streams.

See SafetyNetCloseableRegistry for more details on how this is utilized.

Field Summary

Fields inherited from class org.apache.flink.core.fs.FSDataInputStreamWrapper

inputStream

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ClosingFSDataInputStream(FSDataInputStream delegate, SafetyNetCloseableRegistry registry, String debugInfo)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	equals(Object obj)
int	hashCode()
boolean	isClosed()
String	toString()
static ClosingFSDataInputStream	wrapSafe(FSDataInputStream delegate, SafetyNetCloseableRegistry registry)
static ClosingFSDataInputStream	wrapSafe(FSDataInputStream delegate, SafetyNetCloseableRegistry registry, String debugInfo)

Methods inherited from class org.apache.flink.core.fs.FSDataInputStreamWrapper

available, getPos, getWrappedDelegate, mark, markSupported, read, read, read, reset, seek, skip

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, transferTo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.util.WrappingProxy

getWrappedDelegate

Constructor Detail

ClosingFSDataInputStream

protected ClosingFSDataInputStream(FSDataInputStream delegate,
                                   SafetyNetCloseableRegistry registry,
                                   String debugInfo)
                            throws IOException

Throws:

IOException

Method Detail

isClosed

public boolean isClosed()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class FSDataInputStreamWrapper

Throws:

IOException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

wrapSafe

public static ClosingFSDataInputStream wrapSafe(FSDataInputStream delegate,
                                                SafetyNetCloseableRegistry registry)
                                         throws IOException

Throws:

IOException

wrapSafe

public static ClosingFSDataInputStream wrapSafe(FSDataInputStream delegate,
                                                SafetyNetCloseableRegistry registry,
                                                String debugInfo)
                                         throws IOException

Throws:

IOException