honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix line too long 

Original commit: elastic/x-pack-elasticsearch@084095a944
This commit is contained in:
Costin Leau 2017-10-11 22:32:14 +03:00
parent d6881e25c9
commit 6a1806a3eb
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/embed/ProtoHandler.java
View File

@ -29,8 +29,7 @@ import static org.elasticsearch.common.unit.TimeValue.timeValueMinutes;
public abstract class ProtoHandler implements HttpHandler, AutoCloseable {
private static PlanExecutor planExecutor(EmbeddedModeFilterClient client) {
Supplier<ClusterState> clusterStateSupplier =
() -> client.admin().cluster().prepareState().get(timeValueMinutes(1)).getState();
Supplier<ClusterState> clusterStateSupplier = () -> client.admin().cluster().prepareState().get(timeValueMinutes(1)).getState();
return new PlanExecutor(client, clusterStateSupplier, EsCatalog::new);
}
@ -43,7 +42,8 @@ public abstract class ProtoHandler implements HttpHandler, AutoCloseable {
protected ProtoHandler(Client client) {
NodesInfoResponse niResponse = client.admin().cluster().prepareNodesInfo("_local").clear().get(TV);
this.client = !(client instanceof EmbeddedModeFilterClient) ? new EmbeddedModeFilterClient(client) : (EmbeddedModeFilterClient) client;
this.client = !(client instanceof EmbeddedModeFilterClient) ? new EmbeddedModeFilterClient(
client) : (EmbeddedModeFilterClient) client;
this.client.setPlanExecutor(planExecutor(this.client));
info = niResponse.getNodes().get(0);
clusterName = niResponse.getClusterName().value();