honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed compile errors after merge.

This commit is contained in:
Martijn van Groningen 2019-06-25 10:09:29 +02:00
parent f587519f17
commit d0634e444d
No known key found for this signature in database
GPG Key ID: AB236F4FCF2AF12A
3 changed files with 21 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/enrich/action/DeleteEnrichPolicyAction.java
View File

@ -11,6 +11,7 @@ import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.support.master.MasterNodeRequest; import org.elasticsearch.action.support.master.MasterNodeRequest;
import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput; import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import java.io.IOException; import java.io.IOException;
import java.util.Objects; import java.util.Objects;
@ -24,9 +25,14 @@ public class DeleteEnrichPolicyAction extends Action<AcknowledgedResponse> {
super(NAME); super(NAME);
} }
@Override
public Writeable.Reader<AcknowledgedResponse> getResponseReader() {
return AcknowledgedResponse::new;
}
@Override @Override
public AcknowledgedResponse newResponse() { public AcknowledgedResponse newResponse() {
return new AcknowledgedResponse(); throw new UnsupportedOperationException("usage of Streamable is to be replaced by Writeable");
} }
public static class Request extends MasterNodeRequest<DeleteEnrichPolicyAction.Request> { public static class Request extends MasterNodeRequest<DeleteEnrichPolicyAction.Request> {

8
x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/enrich/action/ExecuteEnrichPolicyAction.java
View File

@ -11,6 +11,7 @@ import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.support.master.MasterNodeReadRequest; import org.elasticsearch.action.support.master.MasterNodeReadRequest;
import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput; import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import java.io.IOException; import java.io.IOException;
import java.util.Objects; import java.util.Objects;
@ -24,9 +25,14 @@ public class ExecuteEnrichPolicyAction extends Action<AcknowledgedResponse> {
super(NAME); super(NAME);
} }
@Override
public Writeable.Reader<AcknowledgedResponse> getResponseReader() {
return AcknowledgedResponse::new;
}
@Override @Override
public AcknowledgedResponse newResponse() { public AcknowledgedResponse newResponse() {
return new AcknowledgedResponse(); throw new UnsupportedOperationException("usage of Streamable is to be replaced by Writeable");
} }
public static class Request extends MasterNodeReadRequest<Request> { public static class Request extends MasterNodeReadRequest<Request> {

8
x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/enrich/action/PutEnrichPolicyAction.java
View File

@ -11,6 +11,7 @@ import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.support.master.MasterNodeRequest; import org.elasticsearch.action.support.master.MasterNodeRequest;
import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput; import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.xcontent.XContentParser; import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.xpack.core.enrich.EnrichPolicy; import org.elasticsearch.xpack.core.enrich.EnrichPolicy;
@ -30,9 +31,14 @@ public class PutEnrichPolicyAction extends Action<AcknowledgedResponse> {
return new Request(name, EnrichPolicy.fromXContent(parser)); return new Request(name, EnrichPolicy.fromXContent(parser));
} }
@Override
public Writeable.Reader<AcknowledgedResponse> getResponseReader() {
return AcknowledgedResponse::new;
}
@Override @Override
public AcknowledgedResponse newResponse() { public AcknowledgedResponse newResponse() {
return new AcknowledgedResponse(); throw new UnsupportedOperationException("usage of Streamable is to be replaced by Writeable");
} }
public static class Request extends MasterNodeRequest<PutEnrichPolicyAction.Request> { public static class Request extends MasterNodeRequest<PutEnrichPolicyAction.Request> {