Skip to content

Commit 6898273

Browse files
committed
Remove line length violations for o.e.cluster (mostly) (#34923)
This commit removes line length violations in most of the classes under org.elasticsearch.cluster.
1 parent 2aab0a3 commit 6898273

File tree

97 files changed

+1070
-580
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

97 files changed

+1070
-580
lines changed

server/src/main/java/org/elasticsearch/action/admin/cluster/health/ClusterHealthRequestBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@
2626
import org.elasticsearch.common.Priority;
2727
import org.elasticsearch.common.unit.TimeValue;
2828

29-
public class ClusterHealthRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterHealthRequest, ClusterHealthResponse, ClusterHealthRequestBuilder> {
29+
public class ClusterHealthRequestBuilder
30+
extends MasterNodeReadOperationRequestBuilder<ClusterHealthRequest, ClusterHealthResponse, ClusterHealthRequestBuilder> {
3031

3132
public ClusterHealthRequestBuilder(ElasticsearchClient client, ClusterHealthAction action) {
3233
super(client, action, new ClusterHealthRequest());

server/src/main/java/org/elasticsearch/action/admin/cluster/health/TransportClusterHealthAction.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,8 @@
4747

4848
import java.util.function.Predicate;
4949

50-
public class TransportClusterHealthAction extends TransportMasterNodeReadAction<ClusterHealthRequest, ClusterHealthResponse> {
50+
public class TransportClusterHealthAction
51+
extends TransportMasterNodeReadAction<ClusterHealthRequest, ClusterHealthResponse> {
5152

5253
private final GatewayAllocator gatewayAllocator;
5354

server/src/main/java/org/elasticsearch/action/admin/cluster/node/hotthreads/NodesHotThreadsRequestBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,8 @@
2323
import org.elasticsearch.client.ElasticsearchClient;
2424
import org.elasticsearch.common.unit.TimeValue;
2525

26-
public class NodesHotThreadsRequestBuilder extends NodesOperationRequestBuilder<NodesHotThreadsRequest, NodesHotThreadsResponse, NodesHotThreadsRequestBuilder> {
26+
public class NodesHotThreadsRequestBuilder
27+
extends NodesOperationRequestBuilder<NodesHotThreadsRequest, NodesHotThreadsResponse, NodesHotThreadsRequestBuilder> {
2728

2829
public NodesHotThreadsRequestBuilder(ElasticsearchClient client, NodesHotThreadsAction action) {
2930
super(client, action, new NodesHotThreadsRequest());

server/src/main/java/org/elasticsearch/action/admin/cluster/node/stats/NodesStatsRequestBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,8 @@
2323
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
2424
import org.elasticsearch.client.ElasticsearchClient;
2525

26-
public class NodesStatsRequestBuilder extends NodesOperationRequestBuilder<NodesStatsRequest, NodesStatsResponse, NodesStatsRequestBuilder> {
26+
public class NodesStatsRequestBuilder
27+
extends NodesOperationRequestBuilder<NodesStatsRequest, NodesStatsResponse, NodesStatsRequestBuilder> {
2728

2829
public NodesStatsRequestBuilder(ElasticsearchClient client, NodesStatsAction action) {
2930
super(client, action, new NodesStatsRequest());

server/src/main/java/org/elasticsearch/action/admin/cluster/repositories/delete/DeleteRepositoryRequestBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@
2626
/**
2727
* Builder for unregister repository request
2828
*/
29-
public class DeleteRepositoryRequestBuilder extends AcknowledgedRequestBuilder<DeleteRepositoryRequest, AcknowledgedResponse, DeleteRepositoryRequestBuilder> {
29+
public class DeleteRepositoryRequestBuilder
30+
extends AcknowledgedRequestBuilder<DeleteRepositoryRequest, AcknowledgedResponse, DeleteRepositoryRequestBuilder> {
3031

3132
/**
3233
* Constructs unregister repository request builder

server/src/main/java/org/elasticsearch/action/admin/cluster/repositories/delete/TransportDeleteRepositoryAction.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,8 @@ public class TransportDeleteRepositoryAction extends TransportMasterNodeAction<D
4646
public TransportDeleteRepositoryAction(Settings settings, TransportService transportService, ClusterService clusterService,
4747
RepositoriesService repositoriesService, ThreadPool threadPool, ActionFilters actionFilters,
4848
IndexNameExpressionResolver indexNameExpressionResolver) {
49-
super(settings, DeleteRepositoryAction.NAME, transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver, DeleteRepositoryRequest::new);
49+
super(settings, DeleteRepositoryAction.NAME, transportService, clusterService, threadPool, actionFilters,
50+
indexNameExpressionResolver, DeleteRepositoryRequest::new);
5051
this.repositoriesService = repositoriesService;
5152
}
5253

@@ -66,7 +67,8 @@ protected ClusterBlockException checkBlock(DeleteRepositoryRequest request, Clus
6667
}
6768

6869
@Override
69-
protected void masterOperation(final DeleteRepositoryRequest request, ClusterState state, final ActionListener<AcknowledgedResponse> listener) {
70+
protected void masterOperation(final DeleteRepositoryRequest request, ClusterState state,
71+
final ActionListener<AcknowledgedResponse> listener) {
7072
repositoriesService.unregisterRepository(
7173
new RepositoriesService.UnregisterRepositoryRequest("delete_repository [" + request.name() + "]", request.name())
7274
.masterNodeTimeout(request.masterNodeTimeout()).ackTimeout(request.timeout()),

server/src/main/java/org/elasticsearch/action/admin/cluster/repositories/get/GetRepositoriesRequestBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@
2626
/**
2727
* Get repository request builder
2828
*/
29-
public class GetRepositoriesRequestBuilder extends MasterNodeReadOperationRequestBuilder<GetRepositoriesRequest, GetRepositoriesResponse, GetRepositoriesRequestBuilder> {
29+
public class GetRepositoriesRequestBuilder
30+
extends MasterNodeReadOperationRequestBuilder<GetRepositoriesRequest, GetRepositoriesResponse, GetRepositoriesRequestBuilder> {
3031

3132
/**
3233
* Creates new get repository request builder

server/src/main/java/org/elasticsearch/action/admin/cluster/repositories/get/TransportGetRepositoriesAction.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -50,8 +50,10 @@ public class TransportGetRepositoriesAction extends TransportMasterNodeReadActio
5050

5151
@Inject
5252
public TransportGetRepositoriesAction(Settings settings, TransportService transportService, ClusterService clusterService,
53-
ThreadPool threadPool, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver) {
54-
super(settings, GetRepositoriesAction.NAME, transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver, GetRepositoriesRequest::new);
53+
ThreadPool threadPool, ActionFilters actionFilters,
54+
IndexNameExpressionResolver indexNameExpressionResolver) {
55+
super(settings, GetRepositoriesAction.NAME, transportService, clusterService, threadPool, actionFilters,
56+
indexNameExpressionResolver, GetRepositoriesRequest::new);
5557
}
5658

5759
@Override
@@ -70,7 +72,8 @@ protected ClusterBlockException checkBlock(GetRepositoriesRequest request, Clust
7072
}
7173

7274
@Override
73-
protected void masterOperation(final GetRepositoriesRequest request, ClusterState state, final ActionListener<GetRepositoriesResponse> listener) {
75+
protected void masterOperation(final GetRepositoriesRequest request, ClusterState state,
76+
final ActionListener<GetRepositoriesResponse> listener) {
7477
MetaData metaData = state.metaData();
7578
RepositoriesMetaData repositories = metaData.custom(RepositoriesMetaData.TYPE);
7679
if (request.repositories().length == 0 || (request.repositories().length == 1 && "_all".equals(request.repositories()[0]))) {

server/src/main/java/org/elasticsearch/action/admin/cluster/repositories/put/PutRepositoryRequestBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,8 @@
3030
/**
3131
* Register repository request builder
3232
*/
33-
public class PutRepositoryRequestBuilder extends AcknowledgedRequestBuilder<PutRepositoryRequest, AcknowledgedResponse, PutRepositoryRequestBuilder> {
33+
public class PutRepositoryRequestBuilder
34+
extends AcknowledgedRequestBuilder<PutRepositoryRequest, AcknowledgedResponse, PutRepositoryRequestBuilder> {
3435

3536
/**
3637
* Constructs register repository request

server/src/main/java/org/elasticsearch/action/admin/cluster/repositories/put/TransportPutRepositoryAction.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,8 @@ public class TransportPutRepositoryAction extends TransportMasterNodeAction<PutR
4646
public TransportPutRepositoryAction(Settings settings, TransportService transportService, ClusterService clusterService,
4747
RepositoriesService repositoriesService, ThreadPool threadPool, ActionFilters actionFilters,
4848
IndexNameExpressionResolver indexNameExpressionResolver) {
49-
super(settings, PutRepositoryAction.NAME, transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver, PutRepositoryRequest::new);
49+
super(settings, PutRepositoryAction.NAME, transportService, clusterService, threadPool, actionFilters,
50+
indexNameExpressionResolver, PutRepositoryRequest::new);
5051
this.repositoriesService = repositoriesService;
5152
}
5253

@@ -66,7 +67,8 @@ protected ClusterBlockException checkBlock(PutRepositoryRequest request, Cluster
6667
}
6768

6869
@Override
69-
protected void masterOperation(final PutRepositoryRequest request, ClusterState state, final ActionListener<AcknowledgedResponse> listener) {
70+
protected void masterOperation(final PutRepositoryRequest request, ClusterState state,
71+
final ActionListener<AcknowledgedResponse> listener) {
7072

7173
repositoriesService.registerRepository(
7274
new RepositoriesService.RegisterRepositoryRequest("put_repository [" + request.name() + "]",

0 commit comments

Comments
 (0)