Package org.apache.druid.query.groupby.epinephelinae

Class LimitedTemporaryStorage

java.lang.Object

org.apache.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	Description
class	LimitedTemporaryStorage.LimitedOutputStream

Constructor Summary

Constructors

Constructor	Description
LimitedTemporaryStorage(File storageDirectory, long maxBytesUsed, int maxFileCount, GroupByStatsProvider.PerQueryStats perQueryStatsContainer)

Method Summary

Modifier and Type	Method	Description
void	close()
LimitedTemporaryStorage.LimitedOutputStream	createFile()	Create a new temporary file.
long	currentSize()
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 Details

LimitedTemporaryStorage

public LimitedTemporaryStorage(File storageDirectory,
 long maxBytesUsed,
 int maxFileCount,
 GroupByStatsProvider.PerQueryStats perQueryStatsContainer)

Method Details

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. This method may also throw TemporaryStorageFileLimitException if the number of files in the temporary storage exceeds the configured limit.

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()

currentSize

public long currentSize()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable