diff --git a/core/src/main/java/org/elasticsearch/common/io/stream/StreamInput.java b/core/src/main/java/org/elasticsearch/common/io/stream/StreamInput.java index f4cf824fdd4..92506214480 100644 --- a/core/src/main/java/org/elasticsearch/common/io/stream/StreamInput.java +++ b/core/src/main/java/org/elasticsearch/common/io/stream/StreamInput.java @@ -739,13 +739,6 @@ public abstract class StreamInput extends InputStream { return null; } - /** - * Reads a {@link PipelineAggregatorBuilder} from the current stream - */ - public PipelineAggregatorBuilder readPipelineAggregatorBuilder() throws IOException { - return readNamedWriteable(PipelineAggregatorBuilder.class); - } - /** * Reads a {@link QueryBuilder} from the current stream */ diff --git a/core/src/main/java/org/elasticsearch/common/io/stream/StreamOutput.java b/core/src/main/java/org/elasticsearch/common/io/stream/StreamOutput.java index f574c8fda2b..c3c6e5c1671 100644 --- a/core/src/main/java/org/elasticsearch/common/io/stream/StreamOutput.java +++ b/core/src/main/java/org/elasticsearch/common/io/stream/StreamOutput.java @@ -704,13 +704,6 @@ public abstract class StreamOutput extends OutputStream { } } - /** - * Writes a {@link PipelineAggregatorBuilder} to the current stream - */ - public void writePipelineAggregatorBuilder(PipelineAggregatorBuilder builder) throws IOException { - writeNamedWriteable(builder); - } - /** * Writes a {@link QueryBuilder} to the current stream */ diff --git a/core/src/test/java/org/elasticsearch/search/aggregations/BasePipelineAggregationTestCase.java b/core/src/test/java/org/elasticsearch/search/aggregations/BasePipelineAggregationTestCase.java index 29db7aee5e9..daee1782f4b 100644 --- a/core/src/test/java/org/elasticsearch/search/aggregations/BasePipelineAggregationTestCase.java +++ b/core/src/test/java/org/elasticsearch/search/aggregations/BasePipelineAggregationTestCase.java @@ -256,9 +256,9 @@ public abstract class BasePipelineAggregationTestCase deserializedQuery = in.readNamedWriteable(PipelineAggregatorBuilder.class); assertEquals(deserializedQuery, testAgg); assertEquals(deserializedQuery.hashCode(), testAgg.hashCode()); assertNotSame(deserializedQuery, testAgg); @@ -296,10 +296,10 @@ public abstract class BasePipelineAggregationTestCase