cascading.tuple.hadoop.collect
Class HadoopSpillableTupleMap
java.lang.Object
java.util.AbstractMap<K,V>
java.util.HashMap<Tuple,Collection<Tuple>>
cascading.tuple.collect.SpillableTupleMap
cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
- All Implemented Interfaces:
- Spillable, Serializable, Cloneable, Map<Tuple,Collection<Tuple>>
public class HadoopSpillableTupleMap
- extends SpillableTupleMap
HadoopSpillableTupleMap is responsible for spilling values to disk if the map threshold is reached.
- See Also:
SpillableTupleMap
,
SpillableTupleList
,
Serialized Form
Methods inherited from class cascading.tuple.collect.SpillableTupleMap |
get, getGrouping, getInitListThreshold, getMapCapacity, getMapLoadFactor, getMapThreshold, getMapThreshold, getSpillListener, setGrouping, setSpillListener, setSpillStrategy, spillCount |
Methods inherited from class java.util.HashMap |
clear, clone, containsKey, containsValue, entrySet, isEmpty, keySet, put, putAll, remove, size, values |
HadoopSpillableTupleMap
public HadoopSpillableTupleMap(int initialCapacity,
float loadFactor,
int mapThreshold,
int listThreshold,
FlowProcess<JobConf> flowProcess)
createTupleCollection
protected Collection<Tuple> createTupleCollection(Tuple tuple)
- Specified by:
createTupleCollection
in class SpillableTupleMap
getSpillStrategy
protected Spillable.SpillStrategy getSpillStrategy()
- Method getSpillStrategy returns a SpillStrategy instance that is passed to the underlying Spillable
tuple collection.
- Returns:
- of type Spillable#SpillStrategy
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.