Skip to content

Commit

Permalink
renaming a method
Browse files Browse the repository at this point in the history
  • Loading branch information
masseyke committed Nov 9, 2023
1 parent 255a08b commit c6e2216
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -369,13 +369,21 @@ protected void doInternalExecute(Task task, BulkRequest bulkRequest, String exec
}

// Step 3: create all the indices that are missing, if there are any missing. start the bulk after all the creates come back.
indexData(task, bulkRequest, executorName, listener, autoCreateIndices, indicesThatCannotBeCreated, startTime);
createMissingIndicesAndindexData(
task,
bulkRequest,
executorName,
listener,
autoCreateIndices,
indicesThatCannotBeCreated,
startTime
);
}

/*
* This method is responsible for creating any missing indices and indexing the data in the BulkRequest
*/
protected void indexData(
protected void createMissingIndicesAndindexData(
Task task,
BulkRequest bulkRequest,
String executorName,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ public TransportSimulateBulkAction(
* request gets a corresponding CREATE response, using information from the request.
*/
@Override
protected void indexData(
protected void createMissingIndicesAndindexData(
Task task,
BulkRequest bulkRequest,
String executorName,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -192,7 +192,7 @@ public void onFailure(Exception e) {
Set<String> autoCreateIndices = Set.of(); // unused
Map<String, IndexNotFoundException> indicesThatCannotBeCreated = Map.of(); // unused
long startTime = 0;
bulkAction.indexData(
bulkAction.createMissingIndicesAndindexData(
task,
bulkRequest,
randomAlphaOfLength(10),
Expand Down

0 comments on commit c6e2216

Please sign in to comment.