Repository: cassandra Updated Branches: refs/heads/trunk d019136ee -> 3bf8bdceb
avoid map lookups in doubly nested loops Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/3bf8bdce Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3bf8bdce Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3bf8bdce Branch: refs/heads/trunk Commit: 3bf8bdceb8ad15de5711da383f1ec3e39ecba2e7 Parents: d019136 Author: Dave Brosius <[email protected]> Authored: Thu Jul 7 23:31:45 2016 -0400 Committer: Dave Brosius <[email protected]> Committed: Thu Jul 7 23:31:45 2016 -0400 ---------------------------------------------------------------------- src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/3bf8bdce/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java index daba701..5dba3e2 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java @@ -324,9 +324,9 @@ public class CqlInputFormat extends org.apache.hadoop.mapreduce.InputFormat<Long boolean partitionerIsOpp = partitioner instanceof OrderPreservingPartitioner || partitioner instanceof ByteOrderedPartitioner; - for (TokenRange subSplit : subSplits.keySet()) + for (Map.Entry<TokenRange, Long> subSplitEntry : subSplits.entrySet()) { - List<TokenRange> ranges = subSplit.unwrap(); + List<TokenRange> ranges = subSplitEntry.getKey().unwrap(); for (TokenRange subrange : ranges) { ColumnFamilySplit split = @@ -335,7 +335,7 @@ public class CqlInputFormat extends org.apache.hadoop.mapreduce.InputFormat<Long subrange.getStart().toString().substring(2) : subrange.getStart().toString(), partitionerIsOpp ? subrange.getEnd().toString().substring(2) : subrange.getEnd().toString(), - subSplits.get(subSplit), + subSplitEntry.getValue(), endpoints); logger.trace("adding {}", split);
