alluxio.underfs

Class ObjectUnderFileSystem.DeleteBuffer

java.lang.Object

alluxio.underfs.ObjectUnderFileSystem.OperationBuffer<String>

alluxio.underfs.ObjectUnderFileSystem.DeleteBuffer

Enclosing class:

ObjectUnderFileSystem

@NotThreadSafe
protected class ObjectUnderFileSystem.DeleteBuffer
extends ObjectUnderFileSystem.OperationBuffer<String>

Object keys added to a ObjectUnderFileSystem.DeleteBuffer will be deleted in batches.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.underfs.ObjectUnderFileSystem.OperationBuffer

ObjectUnderFileSystem.OperationBuffer.OperationThread

Field Summary

Fields inherited from class alluxio.underfs.ObjectUnderFileSystem.OperationBuffer

mEntriesAdded

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected int	getBatchSize() Get the batch size.
protected List<String>	operate(List<String> paths) Operate on a list of input type T.

Methods inherited from class alluxio.underfs.ObjectUnderFileSystem.OperationBuffer

add, getResult

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

getBatchSize

protected int getBatchSize()

Description copied from class: ObjectUnderFileSystem.OperationBuffer

Get the batch size.

Specified by:

getBatchSize in class ObjectUnderFileSystem.OperationBuffer<String>

Returns:

a positive integer denoting the batch size

operate

protected List<String> operate(List<String> paths)
                        throws IOException

Description copied from class: ObjectUnderFileSystem.OperationBuffer

Operate on a list of input type T.

Specified by:

operate in class ObjectUnderFileSystem.OperationBuffer<String>

Parameters:

paths - the list of input type T to operate on

Returns:

list of inputs for successful operations

Throws:

IOException