public class HadoopSpillableTupleMap extends cascading.tuple.collect.SpillableTupleMap
SpillableTupleMap
,
SpillableTupleList
,
Serialized FormConstructor and Description |
---|
HadoopSpillableTupleMap(int initialCapacity,
float loadFactor,
int mapThreshold,
int listThreshold,
cascading.flow.FlowProcess<? extends Configuration> flowProcess) |
Modifier and Type | Method and Description |
---|---|
protected java.util.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.
|
get, getGrouping, getInitListThreshold, getMapCapacity, getMapLoadFactor, getMapThreshold, getMapThreshold, getSpillListener, setGrouping, setSpillListener, setSpillStrategy, spillCount
clear, clone, containsKey, containsValue, entrySet, isEmpty, keySet, put, putAll, remove, size, values
public HadoopSpillableTupleMap(int initialCapacity, float loadFactor, int mapThreshold, int listThreshold, cascading.flow.FlowProcess<? extends Configuration> flowProcess)
protected java.util.Collection<cascading.tuple.Tuple> createTupleCollection(cascading.tuple.Tuple tuple)
createTupleCollection
in class cascading.tuple.collect.SpillableTupleMap
protected cascading.tuple.collect.Spillable.SpillStrategy getSpillStrategy()
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.