Change

Author: Tim-Brooks

benchmarks/src/main/java/org/elasticsearch/benchmark/eson/ESONDeserializationBenchmark.java

@@ -152,7 +152,7 @@ public void readESON(Blackhole bh) throws IOException {
                 source.length()
             )
         ) {
-            ESONSource.ESONObject eson = new ESONSource.Builder(refRecycler).parse(parser);
+            ESONSource.ESONObject eson = new ESONSource.Builder().parse(parser);
             bh.consume(eson);
         }
     }

server/src/main/java/org/elasticsearch/action/index/IndexRequest.java

@@ -564,7 +564,7 @@ public IndexRequest source(BytesReference source, XContentType xContentType) {
         this.source = Objects.requireNonNull(source);
         this.contentType = Objects.requireNonNull(xContentType);
         if (useStructuredSource) {
-            ESONSource.Builder builder = new ESONSource.Builder();
+            ESONSource.Builder builder = new ESONSource.Builder((int) (source.length() * 0.70));
             try {
                 XContentParser parser = XContentHelper.createParser(XContentParserConfiguration.EMPTY, source, xContentType);
                 structuredSource = builder.parse(parser);

server/src/main/java/org/elasticsearch/ingest/ESONSource.java

@@ -40,11 +40,15 @@ public static class Builder {
         private final List<KeyEntry> keyArray;
 
         public Builder() {
-            this(BytesRefRecycler.NON_RECYCLING_INSTANCE);
+            this(0);
         }
 
-        public Builder(Recycler<BytesRef> refRecycler) {
-            this.bytes = new BytesStreamOutput(128);
+        public Builder(int expectedSize) {
+            this(BytesRefRecycler.NON_RECYCLING_INSTANCE, expectedSize);
+        }
+
+        public Builder(Recycler<BytesRef> refRecycler, int expectedSize) {
+            this.bytes = new BytesStreamOutput(expectedSize);
             this.keyArray = new ArrayList<>();
         }
 

server/src/main/java/org/elasticsearch/ingest/IngestService.java

@@ -1341,11 +1341,12 @@ static String getProcessorName(Processor processor) {
      * Builds a new ingest document from the passed-in index request.
      */
     private static IngestDocument newIngestDocument(final IndexRequest request) {
-        ESONSource.Builder builder = new ESONSource.Builder();
+        BytesReference source = request.source();
+        ESONSource.Builder builder = new ESONSource.Builder((int) (source.length() * 0.70));
         try (
             XContentParser parser = XContentHelper.createParser(
                 XContentParserConfiguration.EMPTY,
-                request.source(),
+                source,
                 request.getContentType()
             );
         ) {