alluxio.worker.block.annotator

Class SortedBlockSet<T extends BlockSortedField>

java.lang.Object

alluxio.worker.block.annotator.SortedBlockSet<T>

Type Parameters:

T - Field type used for sorting block Ids

public class SortedBlockSet<T extends BlockSortedField>
extends Object

Concurrent set implementation for storing block Ids in sorted form.

Constructor Summary

Constructors

Constructor and Description
SortedBlockSet() Creates a new sorted block set.

Method Summary

Modifier and Type	Method and Description
Iterator<Pair<Long,T>>	getAscendingIterator()
Iterator<Pair<Long,T>>	getDescendingIterator()
T	getSortField(long blockId) Used to get the current sort field for a block Id.
void	put(long blockId, T sortedField) Updates or inserts the collection with new block Id.
void	remove(long blockId) Removes a block id from the collection.
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

SortedBlockSet

public SortedBlockSet()

Creates a new sorted block set.

Method Detail

getSortField

public T getSortField(long blockId)

Used to get the current sort field for a block Id.

Parameters:

blockId - block Id

Returns:

the current sort field

put

public void put(long blockId,
                T sortedField)

Updates or inserts the collection with new block Id.

Parameters:

blockId - block id

sortedField - sorted field for the block id

remove

public void remove(long blockId)

Removes a block id from the collection.

Parameters:

blockId - block id

size

public int size()

Returns:

the size of the collection

getAscendingIterator

public Iterator<Pair<Long,T>> getAscendingIterator()

Returns:

an ascending iterator of "" pairs

getDescendingIterator

public Iterator<Pair<Long,T>> getDescendingIterator()

Returns:

a descending iterator of "" pairs