alluxio.underfs

Class ObjectUnderFileSystem.RenameBuffer

java.lang.Object

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

alluxio.underfs.ObjectUnderFileSystem.RenameBuffer

Enclosing class:

ObjectUnderFileSystem

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

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

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
RenameBuffer() Construct a new ObjectUnderFileSystem.RenameBuffer instance.

Method Summary

Modifier and Type	Method and Description
protected int	getBatchSize() Get 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()

Construct a new ObjectUnderFileSystem.RenameBuffer instance.

Method Detail

getBatchSize

protected int getBatchSize()

Description copied from class: ObjectUnderFileSystem.OperationBuffer

Get 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