Skip to content

Commit

Permalink
checkstyle
Browse files Browse the repository at this point in the history
  • Loading branch information
l-trotta committed Jan 30, 2025
1 parent 4b81a79 commit 5c4c705
Show file tree
Hide file tree
Showing 4 changed files with 42 additions and 4 deletions.
Original file line number Diff line number Diff line change
@@ -1,3 +1,22 @@
/*
* Licensed to Elasticsearch B.V. under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch B.V. licenses this file to you under
* the Apache License, Version 2.0 (the "License"); you may
* not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/

package co.elastic.clients.elasticsearch._helpers.bulk;

import co.elastic.clients.elasticsearch.core.bulk.BulkOperation;
Expand All @@ -13,7 +32,7 @@ class BulkOperationRepeatable<Context> {
private final Iterator<Long> retries;
private Long retryTime;

public BulkOperationRepeatable(BulkOperation request, Context context, Iterator<Long> retries) {
BulkOperationRepeatable(BulkOperation request, Context context, Iterator<Long> retries) {
this.operation = request;
this.context = context;
this.retries = retries;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ class IngesterOperation {
private final BulkOperationRepeatable repeatableOp;
private final long size;

public IngesterOperation(BulkOperationRepeatable repeatableOp, long size) {
IngesterOperation(BulkOperationRepeatable repeatableOp, long size) {
this.repeatableOp = repeatableOp;
this.size = size;
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,22 @@
/*
* Licensed to Elasticsearch B.V. under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch B.V. licenses this file to you under
* the Apache License, Version 2.0 (the "License"); you may
* not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/

package co.elastic.clients.elasticsearch._helpers.bulk;

import co.elastic.clients.elasticsearch.ElasticsearchClient;
Expand All @@ -17,7 +36,6 @@
import co.elastic.clients.transport.Endpoint;
import co.elastic.clients.transport.TransportOptions;
import org.jetbrains.annotations.Nullable;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -447,7 +447,8 @@ public void pipelineTest() {
String createStr = JsonpUtils.toJsonString(create, mapper);
assertEquals(json, createStr);

BulkOperation create1 = IngesterOperation.of(new BulkOperationRepeatable<>(create, null, null), mapper).repeatableOperation().getOperation();
BulkOperation create1 = IngesterOperation.of(new BulkOperationRepeatable<>(create, null, null), mapper)
.repeatableOperation().getOperation();

String create1Str = JsonpUtils.toJsonString(create1, mapper);
assertEquals(json, create1Str);
Expand Down

0 comments on commit 5c4c705

Please sign in to comment.