You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2010/02/12 20:52:39 UTC
svn commit: r909582 -
/hadoop/pig/branches/branch-0.6/src/org/apache/pig/data/DefaultDataBag.java
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() {
}