org.apache.flink.core.fs

Class RefCountedFileWithStream

java.lang.Object

org.apache.flink.core.fs.RefCountedFile

org.apache.flink.core.fs.RefCountedFileWithStream

All Implemented Interfaces:

RefCounted

@Internal
public class RefCountedFileWithStream
extends RefCountedFile

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

Field Summary

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

closed

Method Summary

Modifier and Type	Method and Description
long	getLength()
OffsetAwareOutputStream	getStream()
static RefCountedFileWithStream	newFile(File file, OutputStream currentOut)
static RefCountedFileWithStream	restoredFile(File file, OutputStream currentOut, long bytesInCurrentPart)
void	write(byte[] b, int off, int len)

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

getFile, getReferenceCounter, release, retain

Methods inherited from class java.lang.Object

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

Method Detail

getStream

public OffsetAwareOutputStream getStream()

getLength

public long getLength()

write

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

Throws:

IOException

newFile

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

Throws:

IOException

restoredFile

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