org.apache.flink.core.fs

Class RefCountedTmpFileCreator

java.lang.Object

org.apache.flink.core.fs.RefCountedTmpFileCreator

All Implemented Interfaces:

FunctionWithException<File,RefCountedFileWithStream,IOException>

@Internal
public class RefCountedTmpFileCreator
extends Object
implements FunctionWithException<File,RefCountedFileWithStream,IOException>

A utility class that creates local reference counted files that serve as temporary files.

Method Summary

Modifier and Type	Method and Description
RefCountedFileWithStream	apply(File file) Gets the next temp file and stream to temp file.
static RefCountedTmpFileCreator	inDirectories(File... tmpDirectories)

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.function.FunctionWithException

unchecked

Method Detail

apply

public RefCountedFileWithStream apply(File file)
                               throws IOException

Gets the next temp file and stream to temp file. This creates the temp file atomically, making sure no previous file is overwritten.

This method is safe against concurrent use.

Specified by:

apply in interface FunctionWithException<File,RefCountedFileWithStream,IOException>

Parameters:

file - The argument to the function.

Returns:

A pair of temp file and output stream to that temp file.

Throws:

IOException - Thrown, if the stream to the temp file could not be opened.

inDirectories

public static RefCountedTmpFileCreator inDirectories(File... tmpDirectories)