alluxio.underfs

Class ObjectUnderFileSystem.DeleteBuffer

java.lang.Object

alluxio.underfs.ObjectUnderFileSystem.DeleteBuffer

Enclosing class:

ObjectUnderFileSystem

@NotThreadSafe
protected class ObjectUnderFileSystem.DeleteBuffer
extends Object

Objects added to a ObjectUnderFileSystem.DeleteBuffer will be deleted in batches. Multiple batches are processed in parallel.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ObjectUnderFileSystem.DeleteBuffer.DeleteThread Thread class to delete a batch of objects.

Constructor Summary

Constructors

Constructor and Description
DeleteBuffer() Construct a new ObjectUnderFileSystem.DeleteBuffer instance.

Method Summary

Modifier and Type	Method and Description
void	add(String path) Add a new object to be deleted.
List<String>	getResult() Get the combined result from all batches.

Methods inherited from class java.lang.Object

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

Constructor Detail

DeleteBuffer

public DeleteBuffer()

Construct a new ObjectUnderFileSystem.DeleteBuffer instance.

Method Detail

add

public void add(String path)
         throws IOException

Add a new object to be deleted.

Parameters:

path - of object

Throws:

IOException - if a non-Alluxio error occurs

getResult

public List<String> getResult()
                       throws IOException

Get the combined result from all batches.

Returns:

a list of successfully deleted objects

Throws:

IOException - if a non-Alluxio error occurs