Merge pull request #9 from centic9/keep_routing_parameter

awislowski · awislowski · commit 248c4637a0a6 · 2015-12-10T17:06:14.000+01:00
Keep _routing fields if they are set in the source index
diff --git a/src/main/java/pl/allegro/tech/search/elasticsearch/tools/reindex/process/IndexingComponent.java b/src/main/java/pl/allegro/tech/search/elasticsearch/tools/reindex/process/IndexingComponent.java
@@ -36,6 +36,9 @@ public Optional<BulkResult> indexData(ElasticDataPointer targetDataPointer, Sear
       if (hit.getFields().get("_ttl") != null) {
         requestBuilder.setTTL(hit.getFields().get("_ttl").value());
       }
+      if (hit.getFields().get("_routing") != null) {
+        requestBuilder.setRouting(hit.getFields().get("_routing").value());
+      }
       requestBuilder.setSource(source);
       bulkRequest.add(requestBuilder);
     }

Original file line number	Diff line number	Diff line change
`@@ -36,6 +36,9 @@ public Optional<BulkResult> indexData(ElasticDataPointer targetDataPointer, Sear`
`36`	`36`	`if (hit.getFields().get("_ttl") != null) {`
`37`	`37`	`requestBuilder.setTTL(hit.getFields().get("_ttl").value());`
`38`	`38`	`}`
	`39`	`+ if (hit.getFields().get("_routing") != null) {`
	`40`	`+ requestBuilder.setRouting(hit.getFields().get("_routing").value());`
	`41`	`+ }`
`39`	`42`	`requestBuilder.setSource(source);`
`40`	`43`	`bulkRequest.add(requestBuilder);`
`41`	`44`	`}`