You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2015/05/06 19:23:38 UTC
cassandra git commit: simplify
Repository: cassandra
Updated Branches:
refs/heads/trunk a3e041848 -> c31aef689
simplify
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c31aef68
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c31aef68
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c31aef68
Branch: refs/heads/trunk
Commit: c31aef689f456533c6baf96514e2bb3445ecec07
Parents: a3e0418
Author: Dave Brosius <db...@mebigfatguy.com>
Authored: Wed May 6 13:23:04 2015 -0400
Committer: Dave Brosius <db...@mebigfatguy.com>
Committed: Wed May 6 13:23:04 2015 -0400
----------------------------------------------------------------------
src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/c31aef68/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
index 1d8436b..132273c 100644
--- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
@@ -507,9 +507,8 @@ class CqlRecordWriter extends RecordWriter<Map<String, ByteBuffer>, List<ByteBuf
public List<InetAddress> getEndpoints(TokenRange range)
{
Set<Host> hostSet = rangeMap.get(range);
- List<Host> hosts = Arrays.asList(rangeMap.get(range).toArray(new Host[rangeMap.get(range).size()]));
- List<InetAddress> addresses = new ArrayList<>(hosts.size());
- for (Host host: hosts)
+ List<InetAddress> addresses = new ArrayList<>(hostSet.size());
+ for (Host host: hostSet)
{
addresses.add(host.getAddress());
}