RefCountedFSOutputStream (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- java.io.OutputStream
- - org.apache.flink.core.fs.FSDataOutputStream
  - - org.apache.flink.core.fs.RefCountedFSOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, RefCounted

Direct Known Subclasses:

RefCountedBufferingFileStream
```
@Internal
public abstract class RefCountedFSOutputStream
extends FSDataOutputStream
implements RefCounted
```
A FSDataOutputStream with the RefCounted functionality.

Constructor Summary

Constructors
Constructor Description

RefCountedFSOutputStream()

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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
nullOutputStream, 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.util.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:
    
    {@link true} if the file is closed, {@link false} otherwise.
    
    Throws:
    
    IOException