io.druid.query.groupby.epinephelinae

Class LimitedTemporaryStorage

java.lang.Object

io.druid.query.groupby.epinephelinae.LimitedTemporaryStorage

All Implemented Interfaces:

Closeable, AutoCloseable

public class LimitedTemporaryStorage
extends Object
implements Closeable

An area for limited temporary storage on disk. Limits are checked when opening files and on all writes to those files. Thread-safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	LimitedTemporaryStorage.LimitedOutputStream

Constructor Summary

Constructors

Constructor and Description
LimitedTemporaryStorage(File storageDirectory, long maxBytesUsed)

Method Summary

Modifier and Type	Method and Description
void	close()
LimitedTemporaryStorage.LimitedOutputStream	createFile() Create a new temporary file.
void	delete(File file)
long	maxSize()

Methods inherited from class java.lang.Object

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

Constructor Detail

LimitedTemporaryStorage

public LimitedTemporaryStorage(File storageDirectory,
                               long maxBytesUsed)

Method Detail

createFile

public LimitedTemporaryStorage.LimitedOutputStream createFile()
                                                       throws IOException

Create a new temporary file. All methods of the returned output stream may throw TemporaryStorageFullException if the temporary storage area fills up.

Returns:

output stream to the file

Throws:

TemporaryStorageFullException - if the temporary storage area is full

IOException - if something goes wrong while creating the file

delete

public void delete(File file)

maxSize

public long maxSize()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable