alluxio.worker.block.annotator

Interface BlockAnnotator<T extends BlockSortedField>

Type Parameters:

T - sorted-field type for the annotator

All Known Implementing Classes:

LRFUAnnotator, LRUAnnotator

@PublicApi
public interface BlockAnnotator<T extends BlockSortedField>

Interface for providers that annotates blocks for sorting.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	BlockAnnotator.Factory Factory for BlockAnnotator.

Method Summary

Modifier and Type	Method and Description
boolean	isOnlineSorter() Used to report whether the block annotator is an online sorter.
BlockSortedField	updateSortedField(long blockId, T oldValue) Used to get a new sorted-field for the given block at the current logical time.
void	updateSortedFields(List<Pair<Long,T>> blockList) Updates sorted-field values for all {block-id, sorted-field} pairs at the same logical time.

Method Detail

updateSortedField

BlockSortedField updateSortedField(long blockId,
                                   T oldValue)

Used to get a new sorted-field for the given block at the current logical time.

Parameters:

blockId - block Id

oldValue - old sorted-field value

Returns:

the new sorted-field value

updateSortedFields

void updateSortedFields(List<Pair<Long,T>> blockList)

Updates sorted-field values for all {block-id, sorted-field} pairs at the same logical time. Note: Currently not required for online schemes, so not called.

Parameters:

blockList - list of {block-id, sorted-field} pairs

isOnlineSorter

boolean isOnlineSorter()

Used to report whether the block annotator is an online sorter. For offline sorters, updateSortedFields(List) will be called before acquiring an iterator for a particular location.

Returns:

true if an online sorter