org.apache.flink.core.fs

Class RefCountedFile

java.lang.Object

org.apache.flink.core.fs.RefCountedFile

All Implemented Interfaces:

RefCounted

Direct Known Subclasses:

RefCountedFileWithStream

@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.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closed

Constructor Summary

Constructors

Constructor and Description
RefCountedFile(File file)

Method Summary

Modifier and Type	Method and Description
File	getFile()
int	getReferenceCounter()
boolean	release() Decreases the reference counter.
void	retain() Increases the reference counter.

Methods inherited from class java.lang.Object

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

Field Detail

closed

protected boolean closed

Constructor Detail

RefCountedFile

public RefCountedFile(File file)

Method Detail

getFile

public File getFile()

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.

getReferenceCounter

@VisibleForTesting
public int getReferenceCounter()