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() {
}