From 740e2670e81b4fb9047b73a3b0657a3725b589eb Mon Sep 17 00:00:00 2001 From: Mohammad Derakhshani Date: Fri, 20 Oct 2017 11:14:28 -0700 Subject: [PATCH] removed dead code --- .../azure/documentdb/bulkimport/DocumentBulkImporter.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/bulkimport/src/main/java/com/microsoft/azure/documentdb/bulkimport/DocumentBulkImporter.java b/bulkimport/src/main/java/com/microsoft/azure/documentdb/bulkimport/DocumentBulkImporter.java index a98990b..1c219cb 100644 --- a/bulkimport/src/main/java/com/microsoft/azure/documentdb/bulkimport/DocumentBulkImporter.java +++ b/bulkimport/src/main/java/com/microsoft/azure/documentdb/bulkimport/DocumentBulkImporter.java @@ -47,7 +47,6 @@ import org.slf4j.LoggerFactory; import com.google.common.base.Preconditions; import com.google.common.base.Stopwatch; -import com.google.common.collect.Iterators; import com.google.common.util.concurrent.AsyncCallable; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.Futures.FutureCombiner; @@ -508,10 +507,6 @@ public class DocumentBulkImporter implements AutoCloseable { } private CollectionRoutingMap getCollectionRoutingMap(DocumentClient client) { - Iterator rangeIterator = client.readPartitionKeyRanges(this.collection, null).getQueryIterator(); - List partitionKeyRanges = new ArrayList<>(); - Iterators.addAll(partitionKeyRanges, rangeIterator); - List> ranges = new ArrayList<>(); for (PartitionKeyRange range : client.readPartitionKeyRanges(this.collection, null).getQueryIterable()) { ranges.add(new ImmutablePair<>(range, true));