Author: daijy Date: Fri Feb 12 19:52:38 2010 New Revision: 909582 URL: http://svn.apache.org/viewvc?rev=909582&view=rev Log: PIG-1231: Default DataBagIterator.hasNext() should be idempotent in all cases
Modified: hadoop/pig/branches/branch-0.6/src/org/apache/pig/data/DefaultDataBag.java Modified: hadoop/pig/branches/branch-0.6/src/org/apache/pig/data/DefaultDataBag.java URL: http://svn.apache.org/viewvc/hadoop/pig/branches/branch-0.6/src/org/apache/pig/data/DefaultDataBag.java?rev=909582&r1=909581&r2=909582&view=diff ============================================================================== --- hadoop/pig/branches/branch-0.6/src/org/apache/pig/data/DefaultDataBag.java (original) +++ hadoop/pig/branches/branch-0.6/src/org/apache/pig/data/DefaultDataBag.java Fri Feb 12 19:52:38 2010 @@ -49,8 +49,6 @@ private static final Log log = LogFactory.getLog(DefaultDataBag.class); - boolean hasCachedTuple = false; - public DefaultDataBag() { mContents = new ArrayList<Tuple>(); } @@ -75,7 +73,6 @@ } public Iterator<Tuple> iterator() { - hasCachedTuple = false; return new DefaultDataBagIterator(); } @@ -145,6 +142,7 @@ private int mFilePtr = 0; private DataInputStream mIn = null; private int mCntr = 0; + private boolean hasCachedTuple = false; DefaultDataBagIterator() { }