public class HadoopSpillableTupleMap extends SpillableTupleMap
SpillableTupleMap
,
SpillableTupleList
,
Serialized FormAbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>
Spillable.SpillListener, Spillable.SpillStrategy
Constructor and Description |
---|
HadoopSpillableTupleMap(int initialCapacity,
float loadFactor,
int mapThreshold,
int listThreshold,
FlowProcess<? extends Configuration> flowProcess) |
Modifier and Type | Method and Description |
---|---|
protected Collection<Tuple> |
createTupleCollection(Tuple tuple) |
protected Spillable.SpillStrategy |
getSpillStrategy()
Method getSpillStrategy returns a SpillStrategy instance that is passed to the underlying Spillable
tuple collection.
|
get, getGrouping, getInitListThreshold, getMapCapacity, getMapLoadFactor, getMapThreshold, getMapThreshold, getSpillListener, setGrouping, setSpillListener, setSpillStrategy, spillCount
clear, clone, containsKey, containsValue, entrySet, isEmpty, keySet, put, putAll, remove, size, values
equals, hashCode, toString
public HadoopSpillableTupleMap(int initialCapacity, float loadFactor, int mapThreshold, int listThreshold, FlowProcess<? extends Configuration> flowProcess)
protected Collection<Tuple> createTupleCollection(Tuple tuple)
createTupleCollection
in class SpillableTupleMap
protected Spillable.SpillStrategy getSpillStrategy()
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.