cascading.tuple.hadoop.collect
Class HadoopSpillableTupleMap
java.lang.Object
java.util.AbstractMap<K,V>
java.util.HashMap<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>>
cascading.tuple.collect.SpillableTupleMap
cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
- All Implemented Interfaces:
- cascading.tuple.collect.Spillable, Serializable, Cloneable, Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>>
public class HadoopSpillableTupleMap
- extends cascading.tuple.collect.SpillableTupleMap
HadoopSpillableTupleMap is responsible for spilling values to disk if the map threshold is reached.
- See Also:
SpillableTupleMap
,
SpillableTupleList
,
Serialized Form
Nested classes/interfaces inherited from interface cascading.tuple.collect.Spillable |
cascading.tuple.collect.Spillable.SpillListener, cascading.tuple.collect.Spillable.SpillStrategy |
Fields inherited from class cascading.tuple.collect.SpillableTupleMap |
MAP_CAPACITY, MAP_LOADFACTOR, MAP_THRESHOLD |
Constructor Summary |
HadoopSpillableTupleMap(int initialCapacity,
float loadFactor,
int mapThreshold,
int listThreshold,
cascading.flow.FlowProcess<JobConf> flowProcess)
|
Method Summary |
protected Collection<cascading.tuple.Tuple> |
createTupleCollection(cascading.tuple.Tuple tuple)
|
protected cascading.tuple.collect.Spillable.SpillStrategy |
getSpillStrategy()
Method getSpillStrategy returns a SpillStrategy instance that is passed to the underlying Spillable
tuple collection. |
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,
cascading.flow.FlowProcess<JobConf> flowProcess)
createTupleCollection
protected Collection<cascading.tuple.Tuple> createTupleCollection(cascading.tuple.Tuple tuple)
- Specified by:
createTupleCollection
in class cascading.tuple.collect.SpillableTupleMap
getSpillStrategy
protected cascading.tuple.collect.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-2013 Concurrent, Inc. All Rights Reserved.