You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by da...@apache.org on 2018/01/11 08:01:13 UTC
[37/50] [abbrv] lucene-solr:jira/solr-11702: implement MapWriter
implement MapWriter
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/74128cf6
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/74128cf6
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/74128cf6
Branch: refs/heads/jira/solr-11702
Commit: 74128cf695e6c6ed4d6bc8e408c5cb7e23b9ac4e
Parents: 7a375fd
Author: Noble Paul <no...@apache.org>
Authored: Tue Jan 9 19:15:58 2018 +1100
Committer: Noble Paul <no...@apache.org>
Committed: Tue Jan 9 19:15:58 2018 +1100
----------------------------------------------------------------------
.../client/solrj/cloud/autoscaling/AddReplicaSuggester.java | 9 +++++++++
.../solrj/cloud/autoscaling/MoveReplicaSuggester.java | 8 ++++++++
2 files changed, 17 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/74128cf6/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/AddReplicaSuggester.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/AddReplicaSuggester.java b/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/AddReplicaSuggester.java
index a1cd8c9..3b997bf 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/AddReplicaSuggester.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/AddReplicaSuggester.java
@@ -17,13 +17,16 @@
package org.apache.solr.client.solrj.cloud.autoscaling;
+import java.io.IOException;
import java.util.Collections;
import java.util.List;
import java.util.Set;
import org.apache.solr.client.solrj.SolrRequest;
import org.apache.solr.client.solrj.request.CollectionAdminRequest;
+import org.apache.solr.common.MapWriter;
import org.apache.solr.common.cloud.Replica;
+import org.apache.solr.common.params.CollectionParams;
import org.apache.solr.common.util.Pair;
class AddReplicaSuggester extends Suggester {
@@ -72,4 +75,10 @@ class AddReplicaSuggester extends Suggester {
}
+ @Override
+ public void writeMap(MapWriter.EntryWriter ew) throws IOException {
+ ew.put("action", CollectionParams.CollectionAction.ADDREPLICA.toString());
+ super.writeMap(ew);
+ }
+
}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/74128cf6/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/MoveReplicaSuggester.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/MoveReplicaSuggester.java b/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/MoveReplicaSuggester.java
index 53b3bb7..b68b0b5 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/MoveReplicaSuggester.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/cloud/autoscaling/MoveReplicaSuggester.java
@@ -17,10 +17,12 @@
package org.apache.solr.client.solrj.cloud.autoscaling;
+import java.io.IOException;
import java.util.List;
import org.apache.solr.client.solrj.SolrRequest;
import org.apache.solr.client.solrj.request.CollectionAdminRequest;
+import org.apache.solr.common.params.CollectionParams;
import org.apache.solr.common.util.Pair;
public class MoveReplicaSuggester extends Suggester {
@@ -79,4 +81,10 @@ public class MoveReplicaSuggester extends Suggester {
return null;
}
+
+ @Override
+ public void writeMap(EntryWriter ew) throws IOException {
+ ew.put("action", CollectionParams.CollectionAction.MOVEREPLICA.toString());
+ super.writeMap(ew);
+ }
}