alluxio.underfs

Class ObjectUnderFileSystem.RenameBuffer

java.lang.Object

alluxio.underfs.ObjectUnderFileSystem.OperationBuffer<Pair<String,String>>

alluxio.underfs.ObjectUnderFileSystem.RenameBuffer

Enclosing class:

ObjectUnderFileSystem

@ThreadSafe
protected class ObjectUnderFileSystem.RenameBuffer
extends ObjectUnderFileSystem.OperationBuffer<Pair<String,String>>

File paths added to a ObjectUnderFileSystem.RenameBuffer will be renamed concurrently.

Field Summary

Fields inherited from class alluxio.underfs.ObjectUnderFileSystem.OperationBuffer

mEntriesAdded

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected int	getBatchSize() Gets the batch size.
protected List<Pair<String,String>>	operate(List<Pair<String,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

RenameBuffer

public RenameBuffer(ObjectUnderFileSystem.DeleteBuffer deleteBuffer)

Construct a new ObjectUnderFileSystem.RenameBuffer instance.

Parameters:

deleteBuffer - delete object buffer

Method Detail

getBatchSize

protected int getBatchSize()

Description copied from class: ObjectUnderFileSystem.OperationBuffer

Gets the batch size.

Specified by:

getBatchSize in class ObjectUnderFileSystem.OperationBuffer<Pair<String,String>>

Returns:

a positive integer denoting the batch size

operate

protected List<Pair<String,String>> operate(List<Pair<String,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<Pair<String,String>>

Parameters:

paths - the list of input type T to operate on

Returns:

list of inputs for successful operations

Throws:

IOException