[ML][Inference] adds lazy model loader and inference

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/XPackClientPlugin.java

@@ -98,6 +98,7 @@
 import org.elasticsearch.xpack.core.ml.action.GetModelSnapshotsAction;
 import org.elasticsearch.xpack.core.ml.action.GetOverallBucketsAction;
 import org.elasticsearch.xpack.core.ml.action.GetRecordsAction;
+import org.elasticsearch.xpack.core.ml.action.InferModelAction;
 import org.elasticsearch.xpack.core.ml.action.IsolateDatafeedAction;
 import org.elasticsearch.xpack.core.ml.action.KillProcessAction;
 import org.elasticsearch.xpack.core.ml.action.MlInfoAction;
@@ -323,6 +324,7 @@ public List<ActionType<? extends ActionResponse>> getClientActions() {
                 StartDataFrameAnalyticsAction.INSTANCE,
                 EvaluateDataFrameAction.INSTANCE,
                 EstimateMemoryUsageAction.INSTANCE,
+                InferModelAction.INSTANCE,
                 // security
                 ClearRealmCacheAction.INSTANCE,
                 ClearRolesCacheAction.INSTANCE,

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/InferModelAction.java

@@ -0,0 +1,188 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+package org.elasticsearch.xpack.core.ml.action;
+
+import org.elasticsearch.action.ActionRequest;
+import org.elasticsearch.action.ActionRequestBuilder;
+import org.elasticsearch.action.ActionRequestValidationException;
+import org.elasticsearch.action.ActionResponse;
+import org.elasticsearch.action.ActionType;
+import org.elasticsearch.client.ElasticsearchClient;
+import org.elasticsearch.common.io.stream.StreamInput;
+import org.elasticsearch.common.io.stream.StreamOutput;
+import org.elasticsearch.xpack.core.ml.inference.results.ClassificationInferenceResults;
+import org.elasticsearch.xpack.core.ml.inference.results.InferenceResults;
+import org.elasticsearch.xpack.core.ml.inference.results.RegressionInferenceResults;
+import org.elasticsearch.xpack.core.ml.utils.ExceptionsHelper;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+public class InferModelAction extends ActionType<InferModelAction.Response> {
+
+    public static final InferModelAction INSTANCE = new InferModelAction();
+    public static final String NAME = "cluster:admin/xpack/ml/infer";
+
+    private InferModelAction() {
+        super(NAME, Response::new);
+    }
+
+    public static class Request extends ActionRequest {
+
+        private final String modelId;
+        private final long modelVersion;
+        private final List<Map<String, Object>> objectsToInfer;
+        private final boolean cacheModel;
+        private final Integer topClasses;
+
+        public Request(String modelId, long modelVersion) {
+            this(modelId, modelVersion, Collections.emptyList(), null);
+        }
+
+        public Request(String modelId, long modelVersion, List<Map<String, Object>> objectsToInfer, Integer topClasses) {
+            this.modelId = modelId;
+            this.modelVersion = modelVersion;
+            this.objectsToInfer = objectsToInfer == null ?
+                Collections.emptyList() :
+                Collections.unmodifiableList(objectsToInfer);
+            this.cacheModel = true;
+            this.topClasses = topClasses;
+        }
+
+        public Request(String modelId, long modelVersion, Map<String, Object> objectToInfer, Integer topClasses) {
+            this(modelId,
+                modelVersion,
+                objectToInfer == null ? null : Arrays.asList(objectToInfer),
+                topClasses);
+        }
+
+        public Request(StreamInput in) throws IOException {
+            super(in);
+            this.modelId = in.readString();
+            this.modelVersion = in.readVLong();
+            this.objectsToInfer = Collections.unmodifiableList(in.readList(StreamInput::readMap));
+            this.topClasses = in.readOptionalInt();
+            this.cacheModel = in.readBoolean();
+        }
+
+        public String getModelId() {
+            return modelId;
+        }
+
+        public long getModelVersion() {
+            return modelVersion;
+        }
+
+        public List<Map<String, Object>> getObjectsToInfer() {
+            return objectsToInfer;
+        }
+
+        public boolean isCacheModel() {
+            return cacheModel;
+        }
+
+        public Integer getTopClasses() {
+            return topClasses;
+        }
+
+        @Override
+        public ActionRequestValidationException validate() {
+            return null;
+        }
+
+        @Override
+        public void writeTo(StreamOutput out) throws IOException {
+            super.writeTo(out);
+            out.writeString(modelId);
+            out.writeVLong(modelVersion);
+            out.writeCollection(objectsToInfer, StreamOutput::writeMap);
+            out.writeOptionalInt(topClasses);
+            out.writeBoolean(cacheModel);
+        }
+
+        @Override
+        public boolean equals(Object o) {
+            if (this == o) return true;
+            if (o == null || getClass() != o.getClass()) return false;
+            InferModelAction.Request that = (InferModelAction.Request) o;
+            return Objects.equals(modelId, that.modelId)
+                && Objects.equals(modelVersion, that.modelVersion)
+                && Objects.equals(topClasses, that.topClasses)
+                && Objects.equals(cacheModel, that.cacheModel)
+                && Objects.equals(objectsToInfer, that.objectsToInfer);
+        }
+
+        @Override
+        public int hashCode() {
+            return Objects.hash(modelId, modelVersion, objectsToInfer, topClasses, cacheModel);
+        }
+
+    }
+
+    public static class RequestBuilder extends ActionRequestBuilder<Request, Response> {
+        public RequestBuilder(ElasticsearchClient client, Request request) {
+            super(client, INSTANCE, request);
+        }
+    }
+
+    public static class Response extends ActionResponse {
+
+        private final List<InferenceResults<?>> inferenceResponse;
+        private final String resultsType;
+
+        public Response(List<InferenceResults<?>> inferenceResponse, String resultsType) {
+            super();
+            this.resultsType = ExceptionsHelper.requireNonNull(resultsType, "resultsType");
+            this.inferenceResponse = inferenceResponse == null ?
+                Collections.emptyList() :
+                Collections.unmodifiableList(inferenceResponse);
+        }
+
+        public Response(StreamInput in) throws IOException {
+            super(in);
+            this.resultsType = in.readString();
+            if(resultsType.equals(ClassificationInferenceResults.RESULT_TYPE)) {
+                this.inferenceResponse = Collections.unmodifiableList(in.readList(ClassificationInferenceResults::new));
+            } else if (this.resultsType.equals(RegressionInferenceResults.RESULT_TYPE)) {
+                this.inferenceResponse = Collections.unmodifiableList(in.readList(RegressionInferenceResults::new));
+            } else {
+                throw new IOException("Unrecognized result type [" + resultsType + "]");
+            }
+        }
+
+        public List<InferenceResults<?>> getInferenceResponse() {
+            return inferenceResponse;
+        }
+
+        public String getResultsType() {
+            return resultsType;
+        }
+
+        @Override
+        public void writeTo(StreamOutput out) throws IOException {
+            out.writeString(resultsType);
+            out.writeCollection(inferenceResponse);
+        }
+
+        @Override
+        public boolean equals(Object o) {
+            if (this == o) return true;
+            if (o == null || getClass() != o.getClass()) return false;
+            InferModelAction.Response that = (InferModelAction.Response) o;
+            return Objects.equals(resultsType, that.resultsType) && Objects.equals(inferenceResponse, that.inferenceResponse);
+        }
+
+        @Override
+        public int hashCode() {
+            return Objects.hash(resultsType, inferenceResponse);
+        }
+
+    }
+}

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/results/ClassificationInferenceResults.java

@@ -0,0 +1,155 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+package org.elasticsearch.xpack.core.ml.inference.results;
+
+import org.elasticsearch.common.ParseField;
+import org.elasticsearch.common.io.stream.StreamInput;
+import org.elasticsearch.common.io.stream.StreamOutput;
+import org.elasticsearch.common.io.stream.Writeable;
+import org.elasticsearch.common.xcontent.ToXContentObject;
+import org.elasticsearch.common.xcontent.XContentBuilder;
+import org.elasticsearch.xpack.core.ml.utils.ExceptionsHelper;
+
+import java.io.IOException;
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+
+public class ClassificationInferenceResults extends SingleValueInferenceResults {
+
+    public static final String RESULT_TYPE = "classification";
+    public static final ParseField CLASSIFICATION_LABEL = new ParseField("classification_label");
+    public static final ParseField TOP_CLASSES = new ParseField("top_classes");
+
+    private final String classificationLabel;
+    private final List<TopClassEntry> topClasses;
+
+    public ClassificationInferenceResults(double value, String classificationLabel, List<TopClassEntry> topClasses) {
+        super(value);
+        this.classificationLabel = classificationLabel;
+        this.topClasses = topClasses == null ? null : Collections.unmodifiableList(topClasses);
+    }
+
+    public ClassificationInferenceResults(StreamInput in) throws IOException {
+        super(in);
+        this.classificationLabel = in.readOptionalString();
+        if (in.readBoolean()) {
+            this.topClasses = Collections.unmodifiableList(in.readList(TopClassEntry::new));
+        } else {
+            this.topClasses = null;
+        }
+    }
+
+    public String getClassificationLabel() {
+        return classificationLabel;
+    }
+
+    public List<TopClassEntry> getTopClasses() {
+        return topClasses;
+    }
+
+    @Override
+    public void writeTo(StreamOutput out) throws IOException {
+        super.writeTo(out);
+        out.writeOptionalString(classificationLabel);
+        out.writeBoolean(topClasses != null);
+        if (topClasses != null) {
+            out.writeCollection(topClasses);
+        }
+    }
+
+    @Override
+    XContentBuilder innerToXContent(XContentBuilder builder, Params params) throws IOException {
+        if (classificationLabel != null) {
+            builder.field(CLASSIFICATION_LABEL.getPreferredName(), classificationLabel);
+        }
+        if (topClasses != null) {
+            builder.field(TOP_CLASSES.getPreferredName(), topClasses);
+        }
+        return builder;
+    }
+
+    @Override
+    public boolean equals(Object object) {
+        if (object == this) { return true; }
+        if (object == null || getClass() != object.getClass()) { return false; }
+        ClassificationInferenceResults that = (ClassificationInferenceResults) object;
+        return Objects.equals(value(), that.value()) &&
+            Objects.equals(classificationLabel, that.classificationLabel) &&
+            Objects.equals(topClasses, that.topClasses);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(value(), classificationLabel, topClasses);
+    }
+
+    @Override
+    public String resultType() {
+        return RESULT_TYPE;
+    }
+
+    @Override
+    public String valueAsString() {
+        return classificationLabel == null ? super.valueAsString() : classificationLabel;
+    }
+
+    public static class TopClassEntry implements ToXContentObject, Writeable {
+
+        public final ParseField LABEL = new ParseField("label");
+        public final ParseField PROBABILITY = new ParseField("probability");
+
+        private final String label;
+        private final double probability;
+
+        public TopClassEntry(String label, Double probability) {
+            this.label = ExceptionsHelper.requireNonNull(label, LABEL);
+            this.probability = ExceptionsHelper.requireNonNull(probability, PROBABILITY);
+        }
+
+        public TopClassEntry(StreamInput in) throws IOException {
+            this.label = in.readString();
+            this.probability = in.readDouble();
+        }
+
+        public String getLabel() {
+            return label;
+        }
+
+        public double getProbability() {
+            return probability;
+        }
+
+        @Override
+        public void writeTo(StreamOutput out) throws IOException {
+            out.writeString(label);
+            out.writeDouble(probability);
+        }
+
+        @Override
+        public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
+            builder.startObject();
+            builder.field(LABEL.getPreferredName(), label);
+            builder.field(PROBABILITY.getPreferredName(), probability);
+            builder.endObject();
+            return builder;
+        }
+
+        @Override
+        public boolean equals(Object object) {
+            if (object == this) { return true; }
+            if (object == null || getClass() != object.getClass()) { return false; }
+            TopClassEntry that = (TopClassEntry) object;
+            return Objects.equals(label, that.label) &&
+                Objects.equals(probability, that.probability);
+        }
+
+        @Override
+        public int hashCode() {
+            return Objects.hash(label, probability);
+        }
+    }
+}

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/inference/results/InferenceResults.java

@@ -0,0 +1,19 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+package org.elasticsearch.xpack.core.ml.inference.results;
+
+import org.elasticsearch.common.io.stream.Writeable;
+import org.elasticsearch.common.xcontent.ToXContentObject;
+
+public interface InferenceResults<T> extends ToXContentObject, Writeable {
+
+    String resultType();
+
+    T value();
+
+    String valueAsString();
+
+}