alluxio.underfs

Class ObjectUnderFileSystem.OperationBuffer<T>

java.lang.Object

alluxio.underfs.ObjectUnderFileSystem.OperationBuffer<T>

Direct Known Subclasses:

ObjectUnderFileSystem.DeleteBuffer, ObjectUnderFileSystem.RenameBuffer

Enclosing class:

ObjectUnderFileSystem

protected abstract class ObjectUnderFileSystem.OperationBuffer<T>
extends Object

Operations added to this buffer are performed concurrently.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ObjectUnderFileSystem.OperationBuffer.OperationThread Thread class to operate on a batch of objects.

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) Add a new input to be operated on.
protected abstract int	getBatchSize() Get the batch size.
List<T>	getResult() Get 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()

Get 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

Add 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

Get the combined result from all batches.

Returns:

a list of inputs for successful operations

Throws:

IOException - if a non-Alluxio error occurs