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 <dbros...@apache.org> Authored: Tue Jul 23 00:26:29 2013 -0400 Committer: Dave Brosius <dbros...@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; }
