1010package org .elasticsearch .plugins .internal ;
1111
1212import org .elasticsearch .action .index .IndexRequest ;
13+ import org .elasticsearch .index .Index ;
1314import org .elasticsearch .index .IndexSettings ;
1415import org .elasticsearch .index .engine .EngineFactory ;
1516import org .elasticsearch .index .engine .InternalEngine ;
@@ -104,7 +105,7 @@ public IndexResult index(Index index) throws IOException {
104105 IndexResult result = super .index (index );
105106
106107 DocumentSizeReporter documentParsingReporter = documentParsingProvider .newDocumentSizeReporter (
107- shardId .getIndexName (),
108+ shardId .getIndex (),
108109 config ().getMapperService (),
109110 DocumentSizeAccumulator .EMPTY_INSTANCE
110111 );
@@ -131,22 +132,22 @@ public <T> XContentMeteringParserDecorator newMeteringParserDecorator(IndexReque
131132
132133 @ Override
133134 public DocumentSizeReporter newDocumentSizeReporter (
134- String indexName ,
135+ Index index ,
135136 MapperService mapperService ,
136137 DocumentSizeAccumulator documentSizeAccumulator
137138 ) {
138- return new TestDocumentSizeReporter (indexName );
139+ return new TestDocumentSizeReporter (index );
139140 }
140141 };
141142 }
142143 }
143144
144145 public static class TestDocumentSizeReporter implements DocumentSizeReporter {
145146
146- private final String indexName ;
147+ private final Index index ;
147148
148- public TestDocumentSizeReporter (String indexName ) {
149- this .indexName = indexName ;
149+ public TestDocumentSizeReporter (Index index ) {
150+ this .index = index ;
150151 }
151152
152153 @ Override
@@ -155,7 +156,7 @@ public void onIndexingCompleted(ParsedDocument parsedDocument) {
155156 if (delta > XContentMeteringParserDecorator .UNKNOWN_SIZE ) {
156157 COUNTER .addAndGet (delta );
157158 }
158- assertThat (indexName , equalTo (TEST_INDEX_NAME ));
159+ assertThat (index . getName () , equalTo (TEST_INDEX_NAME ));
159160 }
160161 }
161162
0 commit comments