Class SelfSpillBag

  extended by
      extended by
All Implemented Interfaces:
Serializable, Comparable, Iterable<Tuple>,,, DataBag, Spillable
Direct Known Subclasses:
InternalCachedBag, SortedSpillBag

public abstract class SelfSpillBag
extends DefaultAbstractBag

Class to hold code common to self spilling bags such as InternalCachedBag

See Also:
Serialized Form

Nested Class Summary
static class SelfSpillBag.MemoryLimits
          This class helps to compute the number of entries that should be held in memory so that memory consumption is limited.
Nested classes/interfaces inherited from class
DefaultAbstractBag.BagDelimiterTuple, DefaultAbstractBag.EndBag, DefaultAbstractBag.StartBag
Field Summary
protected  SelfSpillBag.MemoryLimits memLimit
Fields inherited from class
endBag, MAX_SPILL_FILES, mContents, mLastContentsSize, mMemSize, mSize, mSpillFiles, sedes, startBag
Constructor Summary
SelfSpillBag(int bagCount)
SelfSpillBag(int bagCount, float percent)
Method Summary
Methods inherited from class
add, addAll, addAll, clear, compareTo, equals, getMemorySize, getSpillFile, hashCode, incSpillCount, incSpillCount, markStale, readFields, reportProgress, size, toString, warn, write
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Methods inherited from interface
isDistinct, isSorted, iterator
Methods inherited from interface org.apache.pig.impl.util.Spillable

Field Detail


protected SelfSpillBag.MemoryLimits memLimit
Constructor Detail


public SelfSpillBag(int bagCount)


public SelfSpillBag(int bagCount,
                    float percent)

Copyright © 2007-2012 The Apache Software Foundation