alluxio.underfs

Class ObjectUnderFileSystem.OperationBuffer<T>

java.lang.Object

alluxio.underfs.ObjectUnderFileSystem.OperationBuffer<T>

Type Parameters:

T - input type for operation

Direct Known Subclasses:

ObjectUnderFileSystem.DeleteBuffer, ObjectUnderFileSystem.RenameBuffer

Enclosing class:

ObjectUnderFileSystem

@ThreadSafe
protected abstract class ObjectUnderFileSystem.OperationBuffer<T>
extends Object

Operations added to this buffer are performed concurrently. Note that getResult() method blocks add(Object) method.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	mEntriesAdded Total number of inputs to be operated on across batches.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OperationBuffer() Construct a new ObjectUnderFileSystem.OperationBuffer instance.

Method Summary

Modifier and Type	Method and Description
void	add(T input) Adds a new input to be operated on.
protected abstract int	getBatchSize() Gets the batch size.
List<T>	getResult() Gets the combined result from all batches.
protected abstract List<T>	operate(List<T> paths) Operate on a list of input type T.

Methods inherited from class java.lang.Object

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

Field Detail

mEntriesAdded

protected int mEntriesAdded

Total number of inputs to be operated on across batches.

Constructor Detail

OperationBuffer

protected OperationBuffer()

Construct a new ObjectUnderFileSystem.OperationBuffer instance.

Method Detail

getBatchSize

protected abstract int getBatchSize()

Gets the batch size.

Returns:

a positive integer denoting the batch size

operate

protected abstract List<T> operate(List<T> paths)
                            throws IOException

Operate on a list of input type T.

Parameters:

paths - the list of input type T to operate on

Returns:

list of inputs for successful operations

Throws:

IOException

add

public void add(T input)
         throws IOException

Adds a new input to be operated on.

Parameters:

input - the input to operate on

Throws:

IOException - if a non-Alluxio error occurs

getResult

public List<T> getResult()
                  throws IOException

Gets the combined result from all batches.

Returns:

a list of inputs for successful operations

Throws:

IOException - if a non-Alluxio error occurs