alluxio.stress

Class CachingBlockMasterClient.CachingBlockMapIterator

java.lang.Object

alluxio.worker.block.BlockMapIterator

alluxio.stress.CachingBlockMasterClient.CachingBlockMapIterator

All Implemented Interfaces:

Iterator<List<LocationBlockIdListEntry>>

Enclosing class:

CachingBlockMasterClient

public static class CachingBlockMasterClient.CachingBlockMapIterator
extends BlockMapIterator

Pre-generate the list so the RPC execution time does not include the conversion time.

Constructor Summary

Constructors

Constructor and Description
CachingBlockMapIterator(Map<BlockStoreLocation,List<Long>> blockLocationMap, AlluxioConfiguration conf) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
List<LocationBlockIdListEntry>	next()

Methods inherited from class alluxio.worker.block.BlockMapIterator

getBatchCount

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

CachingBlockMapIterator

public CachingBlockMapIterator(Map<BlockStoreLocation,List<Long>> blockLocationMap,
                               AlluxioConfiguration conf)

Constructor.

Parameters:

blockLocationMap - the block lists of each location

conf - configuration properties

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<List<LocationBlockIdListEntry>>

Overrides:

hasNext in class BlockMapIterator

next

public List<LocationBlockIdListEntry> next()

Specified by:

next in interface Iterator<List<LocationBlockIdListEntry>>

Overrides:

next in class BlockMapIterator