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

Class RefCountedFile

java.lang.Object

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

All Implemented Interfaces:

RefCounted

@Internal
public class RefCountedFile
extends Object
implements RefCounted

A reference counted file which is deleted as soon as no caller holds a reference to the wrapped File.

Method Summary

Modifier and Type	Method and Description
void	closeStream()
void	flush()
File	getFile()
long	getLength()
OffsetAwareOutputStream	getStream()
static RefCountedFile	newFile(File file, OutputStream currentOut)
boolean	release() Decreases the reference counter.
static RefCountedFile	restoredFile(File file, OutputStream currentOut, long bytesInCurrentPart)
void	retain() Increases the reference counter.
void	write(byte[] b, int off, int len)

Methods inherited from class java.lang.Object

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

Method Detail

getFile

public File getFile()

getStream

public OffsetAwareOutputStream getStream()

getLength

public long getLength()

write

public void write(byte[] b,
                  int off,
                  int len)
           throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

closeStream

public void closeStream()

retain

public void retain()

Description copied from interface: RefCounted

Increases the reference counter.

Specified by:

retain in interface RefCounted

release

public boolean release()

Description copied from interface: RefCounted

Decreases the reference counter.

Specified by:

release in interface RefCounted

Returns:

true if the reference counter reached 0, false otherwise.

newFile

public static RefCountedFile newFile(File file,
                                     OutputStream currentOut)
                              throws IOException

Throws:

IOException

restoredFile

public static RefCountedFile restoredFile(File file,
                                          OutputStream currentOut,
                                          long bytesInCurrentPart)