Internal: remove some more bwc code

Some more code that was left for backwards compatibility can now be removed on master since 2.0 will require a full cluster restart.

Closes #8778

Author: javanna

src/main/java/org/elasticsearch/action/admin/indices/get/TransportGetIndexAction.java

@@ -80,7 +80,7 @@ protected void doMasterOperation(final GetIndexRequest request, String[] concret
         ImmutableOpenMap<String, ImmutableOpenMap<String, MappingMetaData>> mappingsResult = ImmutableOpenMap.of();
         ImmutableOpenMap<String, ImmutableList<AliasMetaData>> aliasesResult = ImmutableOpenMap.of();
         ImmutableOpenMap<String, Settings> settings = ImmutableOpenMap.of();
-        Feature[] features = request.featuresAsEnums();
+        Feature[] features = request.features();
         boolean doneAliases = false;
         boolean doneMappings = false;
         boolean doneSettings = false;

src/main/java/org/elasticsearch/action/admin/indices/mapping/get/GetFieldMappingsRequest.java

@@ -23,11 +23,9 @@
 import org.elasticsearch.action.ActionRequestValidationException;
 import org.elasticsearch.action.IndicesRequest;
 import org.elasticsearch.action.support.IndicesOptions;
-import org.elasticsearch.action.support.master.MasterNodeOperationRequest;
 import org.elasticsearch.common.Strings;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
-import org.elasticsearch.common.unit.TimeValue;
 
 import java.io.IOException;
 
@@ -49,15 +47,6 @@ public GetFieldMappingsRequest() {
 
     }
 
-    public GetFieldMappingsRequest(GetFieldMappingsRequest other) {
-        this.local = other.local;
-        this.includeDefaults = other.includeDefaults;
-        this.indices = other.indices;
-        this.types = other.types;
-        this.indicesOptions = other.indicesOptions;
-        this.fields = other.fields;
-    }
-
     /**
      * Indicate whether the receiving node should operate based on local index information or forward requests,
      * where needed, to other nodes. If running locally, request will not raise errors if running locally & missing indices.
@@ -129,8 +118,6 @@ public ActionRequestValidationException validate() {
     @Override
     public void writeTo(StreamOutput out) throws IOException {
         super.writeTo(out);
-        // This request used to inherit from MasterNodeOperationRequest, so for bwc we need to keep serializing it.
-        MasterNodeOperationRequest.DEFAULT_MASTER_NODE_TIMEOUT.writeTo(out);
         out.writeStringArray(indices);
         out.writeStringArray(types);
         indicesOptions.writeIndicesOptions(out);
@@ -142,8 +129,6 @@ public void writeTo(StreamOutput out) throws IOException {
     @Override
     public void readFrom(StreamInput in) throws IOException {
         super.readFrom(in);
-        // This request used to inherit from MasterNodeOperationRequest, so for bwc we need to keep serializing it.
-        TimeValue.readTimeValue(in);
         indices = in.readStringArray();
         types = in.readStringArray();
         indicesOptions = IndicesOptions.readIndicesOptions(in);

src/main/java/org/elasticsearch/action/search/SearchScrollRequest.java

@@ -19,7 +19,6 @@
 
 package org.elasticsearch.action.search;
 
-import org.elasticsearch.Version;
 import org.elasticsearch.action.ActionRequest;
 import org.elasticsearch.action.ActionRequestValidationException;
 import org.elasticsearch.common.io.stream.StreamInput;
@@ -100,9 +99,6 @@ public SearchScrollRequest scroll(String keepAlive) {
     @Override
     public void readFrom(StreamInput in) throws IOException {
         super.readFrom(in);
-        if (in.getVersion().before(Version.V_1_2_0)) {
-            in.readByte(); // backward comp. for operation threading
-        }
         scrollId = in.readString();
         if (in.readBoolean()) {
             scroll = readScroll(in);
@@ -112,9 +108,6 @@ public void readFrom(StreamInput in) throws IOException {
     @Override
     public void writeTo(StreamOutput out) throws IOException {
         super.writeTo(out);
-        if (out.getVersion().before(Version.V_1_2_0)) {
-            out.writeByte((byte) 2); // operation threading
-        }
         out.writeString(scrollId);
         if (scroll == null) {
             out.writeBoolean(false);

src/main/java/org/elasticsearch/action/support/broadcast/BroadcastOperationRequest.java

@@ -19,7 +19,6 @@
 
 package org.elasticsearch.action.support.broadcast;
 
-import org.elasticsearch.Version;
 import org.elasticsearch.action.ActionRequest;
 import org.elasticsearch.action.ActionRequestValidationException;
 import org.elasticsearch.action.IndicesRequest;
@@ -89,19 +88,13 @@ protected void beforeLocalFork() {
     public void writeTo(StreamOutput out) throws IOException {
         super.writeTo(out);
         out.writeStringArrayNullable(indices);
-        if (out.getVersion().before(Version.V_1_2_0)) {
-            out.writeByte((byte) 2); // bwc operation threading
-        }
         indicesOptions.writeIndicesOptions(out);
     }
 
     @Override
     public void readFrom(StreamInput in) throws IOException {
         super.readFrom(in);
         indices = in.readStringArray();
-        if (in.getVersion().before(Version.V_1_2_0)) {
-            in.readByte(); // bwc operation threading
-        }
         indicesOptions = IndicesOptions.readIndicesOptions(in);
     }
 }

src/main/java/org/elasticsearch/discovery/zen/ping/ZenPingService.java

@@ -50,12 +50,6 @@ public class ZenPingService extends AbstractLifecycleComponent<ZenPing> implemen
 
     private volatile ImmutableList<? extends ZenPing> zenPings = ImmutableList.of();
 
-    // here for backward comp. with discovery plugins
-    public ZenPingService(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName, NetworkService networkService,
-                          ElectMasterService electMasterService, @Nullable Set<UnicastHostsProvider> unicastHostsProviders) {
-        this(settings, threadPool, transportService, clusterName, networkService, Version.CURRENT, electMasterService, unicastHostsProviders);
-    }
-
     @Inject
     public ZenPingService(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName, NetworkService networkService,
                           Version version, ElectMasterService electMasterService, @Nullable Set<UnicastHostsProvider> unicastHostsProviders) {
@@ -74,19 +68,6 @@ public ImmutableList<? extends ZenPing> zenPings() {
         return this.zenPings;
     }
 
-    public void zenPings(ImmutableList<? extends ZenPing> pings) {
-        this.zenPings = pings;
-        if (lifecycle.started()) {
-            for (ZenPing zenPing : zenPings) {
-                zenPing.start();
-            }
-        } else if (lifecycle.stopped()) {
-            for (ZenPing zenPing : zenPings) {
-                zenPing.stop();
-            }
-        }
-    }
-
     @Override
     public void setPingContextProvider(PingContextProvider contextProvider) {
         if (lifecycle.started()) {

src/main/java/org/elasticsearch/rest/action/explain/RestExplainAction.java

@@ -106,10 +106,9 @@ public void handleRequest(final RestRequest request, final RestChannel channel,
             @Override
             public RestResponse buildResponse(ExplainResponse response, XContentBuilder builder) throws Exception {
                 builder.startObject();
-                //null checks for bw comp, since we only added in 1.4 index, type and id to ExplainResponse
-                builder.field(Fields._INDEX, response.getIndex() != null ? response.getIndex() : explainRequest.index())
-                        .field(Fields._TYPE, response.getType() != null ? response.getType() : explainRequest.type())
-                        .field(Fields._ID, response.getId() != null ? response.getId() : explainRequest.id())
+                builder.field(Fields._INDEX, response.getIndex())
+                        .field(Fields._TYPE, response.getType())
+                        .field(Fields._ID, response.getId())
                         .field(Fields.MATCHED, response.isMatch());
 
                 if (response.hasExplanation()) {