Remove readFrom from ingest
It isn't needed and will be removed from the interface declaring it. Relates to #17085
This commit is contained in:
parent
80288ad60c
commit
a6c0a813b5
|
@ -34,17 +34,6 @@ public class SimulateProcessorResult implements Writeable<SimulateProcessorResul
|
||||||
private final WriteableIngestDocument ingestDocument;
|
private final WriteableIngestDocument ingestDocument;
|
||||||
private final Exception failure;
|
private final Exception failure;
|
||||||
|
|
||||||
public SimulateProcessorResult(StreamInput in) throws IOException {
|
|
||||||
this.processorTag = in.readString();
|
|
||||||
if (in.readBoolean()) {
|
|
||||||
this.failure = in.readThrowable();
|
|
||||||
this.ingestDocument = null;
|
|
||||||
} else {
|
|
||||||
this.ingestDocument = new WriteableIngestDocument(in);
|
|
||||||
this.failure = null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public SimulateProcessorResult(String processorTag, IngestDocument ingestDocument) {
|
public SimulateProcessorResult(String processorTag, IngestDocument ingestDocument) {
|
||||||
this.processorTag = processorTag;
|
this.processorTag = processorTag;
|
||||||
this.ingestDocument = new WriteableIngestDocument(ingestDocument);
|
this.ingestDocument = new WriteableIngestDocument(ingestDocument);
|
||||||
|
@ -57,6 +46,32 @@ public class SimulateProcessorResult implements Writeable<SimulateProcessorResul
|
||||||
this.ingestDocument = null;
|
this.ingestDocument = null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Read from a stream.
|
||||||
|
*/
|
||||||
|
public SimulateProcessorResult(StreamInput in) throws IOException {
|
||||||
|
this.processorTag = in.readString();
|
||||||
|
if (in.readBoolean()) {
|
||||||
|
this.failure = in.readThrowable();
|
||||||
|
this.ingestDocument = null;
|
||||||
|
} else {
|
||||||
|
this.ingestDocument = new WriteableIngestDocument(in);
|
||||||
|
this.failure = null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
|
out.writeString(processorTag);
|
||||||
|
if (failure == null) {
|
||||||
|
out.writeBoolean(false);
|
||||||
|
ingestDocument.writeTo(out);
|
||||||
|
} else {
|
||||||
|
out.writeBoolean(true);
|
||||||
|
out.writeThrowable(failure);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public IngestDocument getIngestDocument() {
|
public IngestDocument getIngestDocument() {
|
||||||
if (ingestDocument == null) {
|
if (ingestDocument == null) {
|
||||||
return null;
|
return null;
|
||||||
|
@ -72,23 +87,6 @@ public class SimulateProcessorResult implements Writeable<SimulateProcessorResul
|
||||||
return failure;
|
return failure;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public SimulateProcessorResult readFrom(StreamInput in) throws IOException {
|
|
||||||
return new SimulateProcessorResult(in);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void writeTo(StreamOutput out) throws IOException {
|
|
||||||
out.writeString(processorTag);
|
|
||||||
if (failure == null) {
|
|
||||||
out.writeBoolean(false);
|
|
||||||
ingestDocument.writeTo(out);
|
|
||||||
} else {
|
|
||||||
out.writeBoolean(true);
|
|
||||||
out.writeThrowable(failure);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
|
|
|
@ -34,6 +34,14 @@ public class IngestStats implements Writeable<IngestStats>, ToXContent {
|
||||||
private final Stats totalStats;
|
private final Stats totalStats;
|
||||||
private final Map<String, Stats> statsPerPipeline;
|
private final Map<String, Stats> statsPerPipeline;
|
||||||
|
|
||||||
|
public IngestStats(Stats totalStats, Map<String, Stats> statsPerPipeline) {
|
||||||
|
this.totalStats = totalStats;
|
||||||
|
this.statsPerPipeline = statsPerPipeline;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Read from a stream.
|
||||||
|
*/
|
||||||
public IngestStats(StreamInput in) throws IOException {
|
public IngestStats(StreamInput in) throws IOException {
|
||||||
this.totalStats = new Stats(in);
|
this.totalStats = new Stats(in);
|
||||||
int size = in.readVInt();
|
int size = in.readVInt();
|
||||||
|
@ -43,11 +51,17 @@ public class IngestStats implements Writeable<IngestStats>, ToXContent {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public IngestStats(Stats totalStats, Map<String, Stats> statsPerPipeline) {
|
@Override
|
||||||
this.totalStats = totalStats;
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
this.statsPerPipeline = statsPerPipeline;
|
totalStats.writeTo(out);
|
||||||
|
out.writeVLong(statsPerPipeline.size());
|
||||||
|
for (Map.Entry<String, Stats> entry : statsPerPipeline.entrySet()) {
|
||||||
|
out.writeString(entry.getKey());
|
||||||
|
entry.getValue().writeTo(out);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return The accumulated stats for all pipelines
|
* @return The accumulated stats for all pipelines
|
||||||
*/
|
*/
|
||||||
|
@ -62,21 +76,6 @@ public class IngestStats implements Writeable<IngestStats>, ToXContent {
|
||||||
return statsPerPipeline;
|
return statsPerPipeline;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public IngestStats readFrom(StreamInput in) throws IOException {
|
|
||||||
return new IngestStats(in);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void writeTo(StreamOutput out) throws IOException {
|
|
||||||
totalStats.writeTo(out);
|
|
||||||
out.writeVLong(statsPerPipeline.size());
|
|
||||||
for (Map.Entry<String, Stats> entry : statsPerPipeline.entrySet()) {
|
|
||||||
out.writeString(entry.getKey());
|
|
||||||
entry.getValue().writeTo(out);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject("ingest");
|
builder.startObject("ingest");
|
||||||
|
@ -101,6 +100,16 @@ public class IngestStats implements Writeable<IngestStats>, ToXContent {
|
||||||
private final long ingestCurrent;
|
private final long ingestCurrent;
|
||||||
private final long ingestFailedCount;
|
private final long ingestFailedCount;
|
||||||
|
|
||||||
|
public Stats(long ingestCount, long ingestTimeInMillis, long ingestCurrent, long ingestFailedCount) {
|
||||||
|
this.ingestCount = ingestCount;
|
||||||
|
this.ingestTimeInMillis = ingestTimeInMillis;
|
||||||
|
this.ingestCurrent = ingestCurrent;
|
||||||
|
this.ingestFailedCount = ingestFailedCount;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Read from a stream.
|
||||||
|
*/
|
||||||
public Stats(StreamInput in) throws IOException {
|
public Stats(StreamInput in) throws IOException {
|
||||||
ingestCount = in.readVLong();
|
ingestCount = in.readVLong();
|
||||||
ingestTimeInMillis = in.readVLong();
|
ingestTimeInMillis = in.readVLong();
|
||||||
|
@ -108,11 +117,12 @@ public class IngestStats implements Writeable<IngestStats>, ToXContent {
|
||||||
ingestFailedCount = in.readVLong();
|
ingestFailedCount = in.readVLong();
|
||||||
}
|
}
|
||||||
|
|
||||||
public Stats(long ingestCount, long ingestTimeInMillis, long ingestCurrent, long ingestFailedCount) {
|
@Override
|
||||||
this.ingestCount = ingestCount;
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
this.ingestTimeInMillis = ingestTimeInMillis;
|
out.writeVLong(ingestCount);
|
||||||
this.ingestCurrent = ingestCurrent;
|
out.writeVLong(ingestTimeInMillis);
|
||||||
this.ingestFailedCount = ingestFailedCount;
|
out.writeVLong(ingestCurrent);
|
||||||
|
out.writeVLong(ingestFailedCount);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -144,19 +154,6 @@ public class IngestStats implements Writeable<IngestStats>, ToXContent {
|
||||||
return ingestFailedCount;
|
return ingestFailedCount;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public Stats readFrom(StreamInput in) throws IOException {
|
|
||||||
return new Stats(in);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void writeTo(StreamOutput out) throws IOException {
|
|
||||||
out.writeVLong(ingestCount);
|
|
||||||
out.writeVLong(ingestTimeInMillis);
|
|
||||||
out.writeVLong(ingestCurrent);
|
|
||||||
out.writeVLong(ingestFailedCount);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.field("count", ingestCount);
|
builder.field("count", ingestCount);
|
||||||
|
|
|
@ -25,7 +25,6 @@ import org.elasticsearch.common.ParseFieldMatcherSupplier;
|
||||||
import org.elasticsearch.common.bytes.BytesReference;
|
import org.elasticsearch.common.bytes.BytesReference;
|
||||||
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.ObjectParser;
|
import org.elasticsearch.common.xcontent.ObjectParser;
|
||||||
import org.elasticsearch.common.xcontent.ToXContent;
|
import org.elasticsearch.common.xcontent.ToXContent;
|
||||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||||
|
@ -39,8 +38,7 @@ import java.util.function.BiFunction;
|
||||||
/**
|
/**
|
||||||
* Encapsulates a pipeline's id and configuration as a blob
|
* Encapsulates a pipeline's id and configuration as a blob
|
||||||
*/
|
*/
|
||||||
public final class PipelineConfiguration extends AbstractDiffable<PipelineConfiguration>
|
public final class PipelineConfiguration extends AbstractDiffable<PipelineConfiguration> implements ToXContent {
|
||||||
implements Writeable<PipelineConfiguration>, ToXContent {
|
|
||||||
|
|
||||||
final static PipelineConfiguration PROTOTYPE = new PipelineConfiguration(null, null);
|
final static PipelineConfiguration PROTOTYPE = new PipelineConfiguration(null, null);
|
||||||
|
|
||||||
|
|
|
@ -21,15 +21,11 @@ package org.elasticsearch.ingest.core;
|
||||||
|
|
||||||
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.Streamable;
|
|
||||||
import org.elasticsearch.common.io.stream.Writeable;
|
import org.elasticsearch.common.io.stream.Writeable;
|
||||||
import org.elasticsearch.common.xcontent.ToXContent;
|
import org.elasticsearch.common.xcontent.ToXContent;
|
||||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.LinkedHashSet;
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
@ -39,29 +35,19 @@ public class IngestInfo implements Writeable<IngestInfo>, ToXContent {
|
||||||
|
|
||||||
private final Set<ProcessorInfo> processors;
|
private final Set<ProcessorInfo> processors;
|
||||||
|
|
||||||
public IngestInfo(StreamInput in) throws IOException {
|
|
||||||
this(Collections.emptyList());
|
|
||||||
final int size = in.readVInt();
|
|
||||||
for (int i = 0; i < size; i++) {
|
|
||||||
processors.add(new ProcessorInfo(in));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public IngestInfo(List<ProcessorInfo> processors) {
|
public IngestInfo(List<ProcessorInfo> processors) {
|
||||||
this.processors = new TreeSet<>(processors); // we use a treeset here to have a test-able / predictable order
|
this.processors = new TreeSet<>(processors); // we use a treeset here to have a test-able / predictable order
|
||||||
}
|
}
|
||||||
|
|
||||||
public Iterable<ProcessorInfo> getProcessors() {
|
/**
|
||||||
return processors;
|
* Read from a stream.
|
||||||
}
|
*/
|
||||||
|
public IngestInfo(StreamInput in) throws IOException {
|
||||||
public boolean containsProcessor(String type) {
|
processors = new TreeSet<>();
|
||||||
return processors.contains(new ProcessorInfo(type));
|
final int size = in.readVInt();
|
||||||
}
|
for (int i = 0; i < size; i++) {
|
||||||
|
processors.add(new ProcessorInfo(in));
|
||||||
@Override
|
}
|
||||||
public IngestInfo readFrom(StreamInput in) throws IOException {
|
|
||||||
return new IngestInfo(in);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -72,6 +58,14 @@ public class IngestInfo implements Writeable<IngestInfo>, ToXContent {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public Iterable<ProcessorInfo> getProcessors() {
|
||||||
|
return processors;
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean containsProcessor(String type) {
|
||||||
|
return processors.contains(new ProcessorInfo(type));
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject("ingest");
|
builder.startObject("ingest");
|
||||||
|
|
|
@ -21,7 +21,6 @@ package org.elasticsearch.ingest.core;
|
||||||
|
|
||||||
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.Streamable;
|
|
||||||
import org.elasticsearch.common.io.stream.Writeable;
|
import org.elasticsearch.common.io.stream.Writeable;
|
||||||
import org.elasticsearch.common.xcontent.ToXContent;
|
import org.elasticsearch.common.xcontent.ToXContent;
|
||||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||||
|
@ -32,12 +31,20 @@ public class ProcessorInfo implements Writeable<ProcessorInfo>, ToXContent, Comp
|
||||||
|
|
||||||
private final String type;
|
private final String type;
|
||||||
|
|
||||||
|
public ProcessorInfo(String type) {
|
||||||
|
this.type = type;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Read from a stream.
|
||||||
|
*/
|
||||||
public ProcessorInfo(StreamInput input) throws IOException {
|
public ProcessorInfo(StreamInput input) throws IOException {
|
||||||
type = input.readString();
|
type = input.readString();
|
||||||
}
|
}
|
||||||
|
|
||||||
public ProcessorInfo(String type) {
|
@Override
|
||||||
this.type = type;
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
|
out.writeString(this.type);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -47,16 +54,6 @@ public class ProcessorInfo implements Writeable<ProcessorInfo>, ToXContent, Comp
|
||||||
return type;
|
return type;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public ProcessorInfo readFrom(StreamInput in) throws IOException {
|
|
||||||
return new ProcessorInfo(in);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void writeTo(StreamOutput out) throws IOException {
|
|
||||||
out.writeString(this.type);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
|
|
|
@ -21,7 +21,6 @@ package org.elasticsearch.ingest;
|
||||||
|
|
||||||
import org.elasticsearch.common.io.stream.BytesStreamOutput;
|
import org.elasticsearch.common.io.stream.BytesStreamOutput;
|
||||||
import org.elasticsearch.common.io.stream.StreamInput;
|
import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
import org.elasticsearch.common.io.stream.Writeable;
|
|
||||||
import org.elasticsearch.test.ESTestCase;
|
import org.elasticsearch.test.ESTestCase;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
@ -60,10 +59,10 @@ public class IngestStatsTests extends ESTestCase {
|
||||||
assertEquals(leftStats.getIngestCurrent(), rightStats.getIngestCurrent());
|
assertEquals(leftStats.getIngestCurrent(), rightStats.getIngestCurrent());
|
||||||
}
|
}
|
||||||
|
|
||||||
private <T> T serialize(Writeable<T> writeable) throws IOException {
|
private IngestStats serialize(IngestStats stats) throws IOException {
|
||||||
BytesStreamOutput out = new BytesStreamOutput();
|
BytesStreamOutput out = new BytesStreamOutput();
|
||||||
writeable.writeTo(out);
|
stats.writeTo(out);
|
||||||
StreamInput in = StreamInput.wrap(out.bytes());
|
StreamInput in = StreamInput.wrap(out.bytes());
|
||||||
return writeable.readFrom(in);
|
return new IngestStats(in);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue