cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject cassandra git commit: move 'local only' field to a local variable
Date Mon, 25 May 2015 21:09:21 GMT
Repository: cassandra
Updated Branches:
  refs/heads/trunk 20257310b -> 7f383006f


move 'local only' field to a local variable


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7f383006
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7f383006
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7f383006

Branch: refs/heads/trunk
Commit: 7f383006f575577b64f61013d3bbee7570e0a7a0
Parents: 2025731
Author: Dave Brosius <dbrosius@mebigfatguy.com>
Authored: Mon May 25 17:09:05 2015 -0400
Committer: Dave Brosius <dbrosius@mebigfatguy.com>
Committed: Mon May 25 17:09:05 2015 -0400

----------------------------------------------------------------------
 src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/7f383006/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java b/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
index 670bee1..0635459 100644
--- a/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
+++ b/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
@@ -114,7 +114,6 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface,
Lo
     // wide row hacks
     private ByteBuffer lastKey;
     private Map<ByteBuffer, Cell> lastRow;
-    private boolean hasNext = true;
 
     public CassandraStorage()
     {
@@ -135,6 +134,7 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface,
Lo
         return limit;
     }
 
+    @Override
     public void prepareToRead(RecordReader reader, PigSplit split)
     {
         this.reader = reader;
@@ -151,7 +151,7 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface,
Lo
         {
             while(true)
             {
-                hasNext = reader.nextKeyValue();
+                boolean hasNext = reader.nextKeyValue();
                 if (!hasNext)
                 {
                     if (tuple == null)


Mime
View raw message