org.apache.flink.fs.s3.common.utils

Class RefCountedFSOutputStream

java.lang.Object

java.io.OutputStream

org.apache.flink.core.fs.FSDataOutputStream

org.apache.flink.fs.s3.common.utils.RefCountedFSOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, RefCounted

Direct Known Subclasses:

RefCountedBufferingFileStream

@Internal
public abstract class RefCountedFSOutputStream
extends org.apache.flink.core.fs.FSDataOutputStream
implements RefCounted

A FSDataOutputStream with the RefCounted functionality.

Constructor Summary

Constructors

Constructor and Description
RefCountedFSOutputStream()

Method Summary

Modifier and Type	Method and Description
abstract File	getInputFile() Gets the underlying File that allows to read the contents of the file.
abstract boolean	isClosed() Checks if the file is closed for writes.

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

close, flush, getPos, sync

Methods inherited from class java.io.OutputStream

write, write, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.fs.s3.common.utils.RefCounted

release, retain

Constructor Detail

RefCountedFSOutputStream

public RefCountedFSOutputStream()

Method Detail

getInputFile

public abstract File getInputFile()

Gets the underlying File that allows to read the contents of the file.

Returns:

A handle to the File object.

isClosed

public abstract boolean isClosed()
                          throws IOException

Checks if the file is closed for writes.

Returns:

true if the file is closed, false otherwise.

Throws:

IOException