cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject git commit: remove more boxing histrionics
Date Tue, 23 Jul 2013 04:27:04 GMT
Updated Branches:
  refs/heads/trunk 5e469ea79 -> 27056ece4


remove more boxing histrionics


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

Branch: refs/heads/trunk
Commit: 27056ece48981ae98a223a216dbc3c91b21eca88
Parents: 5e469ea
Author: Dave Brosius <dbrosius@apache.org>
Authored: Tue Jul 23 00:26:29 2013 -0400
Committer: Dave Brosius <dbrosius@apache.org>
Committed: Tue Jul 23 00:26:29 2013 -0400

----------------------------------------------------------------------
 .../org/apache/cassandra/hadoop/pig/CassandraStorage.java    | 8 ++++----
 src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java     | 2 +-
 src/java/org/apache/cassandra/net/IncomingTcpConnection.java | 2 +-
 .../apache/cassandra/utils/BackgroundActivityMonitor.java    | 2 +-
 4 files changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/27056ece/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 89fec49..573992c 100644
--- a/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
+++ b/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
@@ -297,14 +297,14 @@ public class CassandraStorage extends AbstractCassandraStorage
             ConfigHelper.setInputSlicePredicate(conf, predicate);
         }
         if (System.getenv(PIG_WIDEROW_INPUT) != null)
-            widerows = Boolean.valueOf(System.getenv(PIG_WIDEROW_INPUT));
+            widerows = Boolean.parseBoolean(System.getenv(PIG_WIDEROW_INPUT));
         if (System.getenv(PIG_USE_SECONDARY) != null)
-            usePartitionFilter = Boolean.valueOf(System.getenv(PIG_USE_SECONDARY));
+            usePartitionFilter = Boolean.parseBoolean(System.getenv(PIG_USE_SECONDARY));
         if (System.getenv(PIG_INPUT_SPLIT_SIZE) != null)
         {
             try
             {
-                ConfigHelper.setInputSplitSize(conf, Integer.valueOf(System.getenv(PIG_INPUT_SPLIT_SIZE)));
+                ConfigHelper.setInputSplitSize(conf, Integer.parseInt(System.getenv(PIG_INPUT_SPLIT_SIZE)));
             }
             catch (NumberFormatException e)
             {
@@ -365,7 +365,7 @@ public class CassandraStorage extends AbstractCassandraStorage
 
         // we have to do this again here for the check in writeColumnsFromTuple
         if (System.getenv(PIG_USE_SECONDARY) != null)
-            usePartitionFilter = Boolean.valueOf(System.getenv(PIG_USE_SECONDARY));
+            usePartitionFilter = Boolean.parseBoolean(System.getenv(PIG_USE_SECONDARY));
 
         initSchema(storeSignature);
     }

http://git-wip-us.apache.org/repos/asf/cassandra/blob/27056ece/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java b/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
index d5b8fed..acc7925 100644
--- a/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
+++ b/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
@@ -144,7 +144,7 @@ public class CqlStorage extends AbstractCassandraStorage
         {
             try
             {
-                ConfigHelper.setInputSplitSize(conf, Integer.valueOf(System.getenv(PIG_INPUT_SPLIT_SIZE)));
+                ConfigHelper.setInputSplitSize(conf, Integer.parseInt(System.getenv(PIG_INPUT_SPLIT_SIZE)));
             }
             catch (NumberFormatException e)
             {

http://git-wip-us.apache.org/repos/asf/cassandra/blob/27056ece/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/net/IncomingTcpConnection.java b/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
index 4130006..52de099 100644
--- a/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
+++ b/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
@@ -135,7 +135,7 @@ public class IncomingTcpConnection extends Thread
     {
         int id;
         if (version < MessagingService.VERSION_20)
-            id = Integer.valueOf(input.readUTF());
+            id = Integer.parseInt(input.readUTF());
         else
             id = input.readInt();
 

http://git-wip-us.apache.org/repos/asf/cassandra/blob/27056ece/src/java/org/apache/cassandra/utils/BackgroundActivityMonitor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/utils/BackgroundActivityMonitor.java b/src/java/org/apache/cassandra/utils/BackgroundActivityMonitor.java
index a487e39..7a8431e 100644
--- a/src/java/org/apache/cassandra/utils/BackgroundActivityMonitor.java
+++ b/src/java/org/apache/cassandra/utils/BackgroundActivityMonitor.java
@@ -91,7 +91,7 @@ public class BackgroundActivityMonitor
         assert name.equalsIgnoreCase("cpu");
         long[] returned = new long[tokenizer.countTokens()];
         for (int i = 0; i < tokenizer.countTokens(); i++)
-            returned[i] = Long.valueOf(tokenizer.nextToken());
+            returned[i] = Long.parseLong(tokenizer.nextToken());
         return returned;
     }
 


Mime
View raw message