public class HadoopSpillableTupleMap extends SpillableTupleMap
SpillableTupleMap
,
SpillableTupleList
,
Serialized Formjava.util.AbstractMap.SimpleEntry<K,V>, java.util.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 java.util.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, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, forEach, getOrDefault, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values
public HadoopSpillableTupleMap(int initialCapacity, float loadFactor, int mapThreshold, int listThreshold, FlowProcess<? extends Configuration> flowProcess)
protected java.util.Collection<Tuple> createTupleCollection(Tuple tuple)
createTupleCollection
in class SpillableTupleMap
protected Spillable.SpillStrategy getSpillStrategy()
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.