Skip to content

Commit 3de266e

Browse files
DaveCTurnerDaveCTurner
committed
Merge branch 'master' into zen2
2 parents e13ce66 + fe623ac commit 3de266e

File tree

263 files changed

+6179
-2467
lines changed

Some content is hidden

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

263 files changed

+6179
-2467
lines changed

‎buildSrc/src/main/resources/checkstyle_suppressions.xml‎

Lines changed: 0 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,6 @@
4646

4747
<!-- Hopefully temporary suppression of LineLength on files that don't pass it. We should remove these when we the
4848
files start to pass. -->
49-
<suppress files="client[/\\]rest[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]client[/\\]HeapBufferedAsyncResponseConsumerTests.java" checks="LineLength" />
50-
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]apache[/\\]lucene[/\\]search[/\\]vectorhighlight[/\\]CustomFieldQuery.java" checks="LineLength" />
5149
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]health[/\\]ClusterHealthRequestBuilder.java" checks="LineLength" />
5250
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]health[/\\]TransportClusterHealthAction.java" checks="LineLength" />
5351
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]node[/\\]hotthreads[/\\]NodesHotThreadsRequestBuilder.java" checks="LineLength" />
@@ -230,13 +228,7 @@
230228
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]inject[/\\]spi[/\\]InjectionPoint.java" checks="LineLength" />
231229
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]io[/\\]Channels.java" checks="LineLength" />
232230
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]joda[/\\]Joda.java" checks="LineLength" />
233-
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]Lucene.java" checks="LineLength" />
234-
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]index[/\\]ElasticsearchDirectoryReader.java" checks="LineLength" />
235-
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]index[/\\]FilterableTermsEnum.java" checks="LineLength" />
236-
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]index[/\\]FreqTermsEnum.java" checks="LineLength" />
237231
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]search[/\\]XMoreLikeThis.java" checks="LineLength" />
238-
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]search[/\\]function[/\\]FunctionScoreQuery.java" checks="LineLength" />
239-
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]store[/\\]ByteArrayIndexInput.java" checks="LineLength" />
240232
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]network[/\\]Cidrs.java" checks="LineLength" />
241233
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]network[/\\]NetworkService.java" checks="LineLength" />
242234
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]recycler[/\\]Recyclers.java" checks="LineLength" />
@@ -388,7 +380,6 @@
388380
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]snapshots[/\\]SnapshotShardsService.java" checks="LineLength" />
389381
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]snapshots[/\\]SnapshotsService.java" checks="LineLength" />
390382
<suppress files="server[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]threadpool[/\\]ThreadPool.java" checks="LineLength" />
391-
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]apache[/\\]lucene[/\\]queries[/\\]BlendedTermQueryTests.java" checks="LineLength" />
392383
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]VersionTests.java" checks="LineLength" />
393384
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]RejectionActionIT.java" checks="LineLength" />
394385
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]HotThreadsIT.java" checks="LineLength" />
@@ -494,7 +485,6 @@
494485
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]breaker[/\\]MemoryCircuitBreakerTests.java" checks="LineLength" />
495486
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]geo[/\\]ShapeBuilderTests.java" checks="LineLength" />
496487
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]hash[/\\]MessageDigestsTests.java" checks="LineLength" />
497-
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]lucene[/\\]index[/\\]FreqTermsEnumTests.java" checks="LineLength" />
498488
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]network[/\\]CidrsTests.java" checks="LineLength" />
499489
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]unit[/\\]DistanceUnitTests.java" checks="LineLength" />
500490
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]common[/\\]unit[/\\]FuzzinessTests.java" checks="LineLength" />
@@ -665,23 +655,6 @@
665655
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]update[/\\]UpdateIT.java" checks="LineLength" />
666656
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]validate[/\\]SimpleValidateQueryIT.java" checks="LineLength" />
667657
<suppress files="server[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]versioning[/\\]SimpleVersioningIT.java" checks="LineLength" />
668-
<suppress files="modules[/\\]lang-expression[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]script[/\\]expression[/\\]ExpressionScriptEngine.java" checks="LineLength" />
669-
<suppress files="modules[/\\]lang-expression[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]script[/\\]expression[/\\]MoreExpressionTests.java" checks="LineLength" />
670-
<suppress files="modules[/\\]lang-expression[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]script[/\\]expression[/\\]StoredExpressionTests.java" checks="LineLength" />
671658
<suppress files="modules[/\\]lang-painless[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]painless[/\\]ContextExampleTests.java" checks="LineLength" />
672659
<suppress files="modules[/\\]reindex[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]reindex[/\\]TransportUpdateByQueryAction.java" checks="LineLength" />
673-
<suppress files="plugins[/\\]analysis-icu[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]analysis[/\\]IcuCollationTokenFilterFactory.java" checks="LineLength" />
674-
<suppress files="plugins[/\\]analysis-icu[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]analysis[/\\]IcuFoldingTokenFilterFactory.java" checks="LineLength" />
675-
<suppress files="plugins[/\\]analysis-icu[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]analysis[/\\]IndexableBinaryStringTools.java" checks="LineLength" />
676-
<suppress files="plugins[/\\]analysis-kuromoji[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]analysis[/\\]JapaneseStopTokenFilterFactory.java" checks="LineLength" />
677-
<suppress files="plugins[/\\]analysis-kuromoji[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]analysis[/\\]KuromojiAnalysisTests.java" checks="LineLength" />
678-
<suppress files="plugins[/\\]analysis-phonetic[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]analysis[/\\]PhoneticTokenFilterFactory.java" checks="LineLength" />
679-
<suppress files="plugins[/\\]discovery-ec2[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]discovery[/\\]ec2[/\\]AbstractAwsTestCase.java" checks="LineLength" />
680-
<suppress files="plugins[/\\]discovery-ec2[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]discovery[/\\]ec2[/\\]AmazonEC2Mock.java" checks="LineLength" />
681-
<suppress files="plugins[/\\]mapper-murmur3[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]mapper[/\\]murmur3[/\\]Murmur3FieldMapper.java" checks="LineLength" />
682-
<suppress files="plugins[/\\]repository-hdfs[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]repositories[/\\]hdfs[/\\]HdfsRepository.java" checks="LineLength" />
683-
<suppress files="plugins[/\\]repository-hdfs[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]repositories[/\\]hdfs[/\\]HdfsTests.java" checks="LineLength" />
684-
<suppress files="plugins[/\\]repository-s3[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]repositories[/\\]s3[/\\]S3Repository.java" checks="LineLength" />
685-
<suppress files="plugins[/\\]repository-s3[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]repositories[/\\]s3[/\\]AmazonS3Wrapper.java" checks="LineLength" />
686-
<suppress files="plugins[/\\]store-smb[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]index[/\\]store[/\\]SmbDirectoryWrapper.java" checks="LineLength" />
687660
</suppressions>

‎client/rest-high-level/build.gradle‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ integTestCluster {
9191
// Truststore settings are not used since TLS is not enabled. Included for testing the get certificates API
9292
setting 'xpack.ssl.certificate_authorities', 'testnode.crt'
9393
setting 'xpack.security.transport.ssl.truststore.path', 'testnode.jks'
94-
setting 'xpack.security.transport.ssl.truststore.password', 'testnode'
94+
keystoreSetting 'xpack.security.transport.ssl.truststore.secure_password', 'testnode'
9595
setupCommand 'setupDummyUser',
9696
'bin/elasticsearch-users',
9797
'useradd', System.getProperty('tests.rest.cluster.username', 'test_user'),

‎client/rest-high-level/src/main/java/org/elasticsearch/client/LicenseClient.java‎

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,8 @@
2222
import org.apache.http.HttpEntity;
2323
import org.elasticsearch.action.ActionListener;
2424
import org.elasticsearch.action.support.master.AcknowledgedResponse;
25+
import org.elasticsearch.client.license.StartTrialRequest;
26+
import org.elasticsearch.client.license.StartTrialResponse;
2527
import org.elasticsearch.client.license.StartBasicRequest;
2628
import org.elasticsearch.client.license.StartBasicResponse;
2729
import org.elasticsearch.common.Strings;
@@ -44,6 +46,7 @@
4446
import java.nio.charset.StandardCharsets;
4547

4648
import static java.util.Collections.emptySet;
49+
import static java.util.Collections.singleton;
4750

4851
/**
4952
* A wrapper for the {@link RestHighLevelClient} that provides methods for
@@ -123,6 +126,30 @@ public void deleteLicenseAsync(DeleteLicenseRequest request, RequestOptions opti
123126
AcknowledgedResponse::fromXContent, listener, emptySet());
124127
}
125128

129+
/**
130+
* Starts a trial license on the cluster.
131+
* @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
132+
* @return the response
133+
* @throws IOException in case there is a problem sending the request or parsing back the response
134+
*/
135+
public StartTrialResponse startTrial(StartTrialRequest request, RequestOptions options) throws IOException {
136+
return restHighLevelClient.performRequestAndParseEntity(request, LicenseRequestConverters::startTrial, options,
137+
StartTrialResponse::fromXContent, singleton(403));
138+
}
139+
140+
/**
141+
* Asynchronously starts a trial license on the cluster.
142+
* @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
143+
* @param listener the listener to be notified upon request completion
144+
*/
145+
public void startTrialAsync(StartTrialRequest request,
146+
RequestOptions options,
147+
ActionListener<StartTrialResponse> listener) {
148+
149+
restHighLevelClient.performRequestAsyncAndParseEntity(request, LicenseRequestConverters::startTrial, options,
150+
StartTrialResponse::fromXContent, listener, singleton(403));
151+
}
152+
126153
/**
127154
* Initiates an indefinite basic license.
128155
* @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized

‎client/rest-high-level/src/main/java/org/elasticsearch/client/LicenseRequestConverters.java‎

Lines changed: 17 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -23,17 +23,15 @@
2323
import org.apache.http.client.methods.HttpGet;
2424
import org.apache.http.client.methods.HttpPost;
2525
import org.apache.http.client.methods.HttpPut;
26+
import org.elasticsearch.client.license.StartTrialRequest;
2627
import org.elasticsearch.client.license.StartBasicRequest;
2728
import org.elasticsearch.protocol.xpack.license.DeleteLicenseRequest;
2829
import org.elasticsearch.protocol.xpack.license.GetLicenseRequest;
2930
import org.elasticsearch.protocol.xpack.license.PutLicenseRequest;
3031

3132
public class LicenseRequestConverters {
3233
static Request putLicense(PutLicenseRequest putLicenseRequest) {
33-
String endpoint = new RequestConverters.EndpointBuilder()
34-
.addPathPartAsIs("_xpack")
35-
.addPathPartAsIs("license")
36-
.build();
34+
String endpoint = new RequestConverters.EndpointBuilder().addPathPartAsIs("_xpack", "license").build();
3735
Request request = new Request(HttpPut.METHOD_NAME, endpoint);
3836
RequestConverters.Params parameters = new RequestConverters.Params(request);
3937
parameters.withTimeout(putLicenseRequest.timeout());
@@ -46,24 +44,34 @@ static Request putLicense(PutLicenseRequest putLicenseRequest) {
4644
}
4745

4846
static Request getLicense(GetLicenseRequest getLicenseRequest) {
49-
String endpoint = new RequestConverters.EndpointBuilder()
50-
.addPathPartAsIs("_xpack")
51-
.addPathPartAsIs("license")
52-
.build();
47+
String endpoint = new RequestConverters.EndpointBuilder().addPathPartAsIs("_xpack", "license").build();
5348
Request request = new Request(HttpGet.METHOD_NAME, endpoint);
5449
RequestConverters.Params parameters = new RequestConverters.Params(request);
5550
parameters.withLocal(getLicenseRequest.local());
5651
return request;
5752
}
5853

5954
static Request deleteLicense(DeleteLicenseRequest deleteLicenseRequest) {
60-
Request request = new Request(HttpDelete.METHOD_NAME, "/_xpack/license");
55+
String endpoint = new RequestConverters.EndpointBuilder().addPathPartAsIs("_xpack", "license").build();
56+
Request request = new Request(HttpDelete.METHOD_NAME, endpoint);
6157
RequestConverters.Params parameters = new RequestConverters.Params(request);
6258
parameters.withTimeout(deleteLicenseRequest.timeout());
6359
parameters.withMasterTimeout(deleteLicenseRequest.masterNodeTimeout());
6460
return request;
6561
}
6662

63+
static Request startTrial(StartTrialRequest startTrialRequest) {
64+
final String endpoint = new RequestConverters.EndpointBuilder().addPathPartAsIs("_xpack", "license", "start_trial").build();
65+
final Request request = new Request(HttpPost.METHOD_NAME, endpoint);
66+
67+
RequestConverters.Params parameters = new RequestConverters.Params(request);
68+
parameters.putParam("acknowledge", Boolean.toString(startTrialRequest.isAcknowledge()));
69+
if (startTrialRequest.getLicenseType() != null) {
70+
parameters.putParam("type", startTrialRequest.getLicenseType());
71+
}
72+
return request;
73+
}
74+
6775
static Request startBasic(StartBasicRequest startBasicRequest) {
6876
String endpoint = new RequestConverters.EndpointBuilder()
6977
.addPathPartAsIs("_xpack", "license", "start_basic")

‎client/rest-high-level/src/main/java/org/elasticsearch/client/RequestConverters.java‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -980,7 +980,7 @@ EndpointBuilder addCommaSeparatedPathParts(String[] parts) {
980980
return this;
981981
}
982982

983-
EndpointBuilder addPathPartAsIs(String ... parts) {
983+
EndpointBuilder addPathPartAsIs(String... parts) {
984984
for (String part : parts) {
985985
if (Strings.hasLength(part)) {
986986
joiner.add(part);
@@ -1007,3 +1007,4 @@ private static String encodePart(String pathPart) {
10071007
}
10081008
}
10091009
}
1010+

‎client/rest-high-level/src/main/java/org/elasticsearch/client/RollupClient.java‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,8 @@
2424
import org.elasticsearch.client.rollup.DeleteRollupJobResponse;
2525
import org.elasticsearch.client.rollup.GetRollupJobRequest;
2626
import org.elasticsearch.client.rollup.GetRollupJobResponse;
27+
import org.elasticsearch.client.rollup.GetRollupCapsRequest;
28+
import org.elasticsearch.client.rollup.GetRollupCapsResponse;
2729
import org.elasticsearch.client.rollup.PutRollupJobRequest;
2830
import org.elasticsearch.client.rollup.PutRollupJobResponse;
2931

@@ -137,11 +139,48 @@ public GetRollupJobResponse getRollupJob(GetRollupJobRequest request, RequestOpt
137139
* @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
138140
* @param listener the listener to be notified upon request completion
139141
*/
142+
143+
140144
public void getRollupJobAsync(GetRollupJobRequest request, RequestOptions options, ActionListener<GetRollupJobResponse> listener) {
141145
restHighLevelClient.performRequestAsyncAndParseEntity(request,
142146
RollupRequestConverters::getJob,
143147
options,
144148
GetRollupJobResponse::fromXContent,
145149
listener, Collections.emptySet());
146150
}
151+
152+
/**
153+
* Get the Rollup Capabilities of a target (non-rollup) index or pattern
154+
* See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/master/rollup-get-rollup-caps.html">
155+
* the docs</a> for more.
156+
* @param request the request
157+
* @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
158+
* @return the response
159+
* @throws IOException in case there is a problem sending the request or parsing back the response
160+
*/
161+
public GetRollupCapsResponse getRollupCapabilities(GetRollupCapsRequest request, RequestOptions options) throws IOException {
162+
return restHighLevelClient.performRequestAndParseEntity(request,
163+
RollupRequestConverters::getRollupCaps,
164+
options,
165+
GetRollupCapsResponse::fromXContent,
166+
Collections.emptySet());
167+
}
168+
169+
/**
170+
* Asynchronously Get the Rollup Capabilities of a target (non-rollup) index or pattern
171+
* See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/rollup-put-job.html">
172+
* the docs</a> for more.
173+
* @param request the request
174+
* @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
175+
* @param listener the listener to be notified upon request completion
176+
*/
177+
public void getRollupCapabilitiesAsync(GetRollupCapsRequest request, RequestOptions options,
178+
ActionListener<GetRollupCapsResponse> listener) {
179+
restHighLevelClient.performRequestAsyncAndParseEntity(request,
180+
RollupRequestConverters::getRollupCaps,
181+
options,
182+
GetRollupCapsResponse::fromXContent,
183+
listener,
184+
Collections.emptySet());
185+
}
147186
}

‎client/rest-high-level/src/main/java/org/elasticsearch/client/RollupRequestConverters.java‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import org.apache.http.client.methods.HttpPut;
2424
import org.elasticsearch.client.rollup.DeleteRollupJobRequest;
2525
import org.elasticsearch.client.rollup.GetRollupJobRequest;
26+
import org.elasticsearch.client.rollup.GetRollupCapsRequest;
2627
import org.elasticsearch.client.rollup.PutRollupJobRequest;
2728

2829
import java.io.IOException;
@@ -68,4 +69,16 @@ static Request deleteJob(final DeleteRollupJobRequest deleteRollupJobRequest) th
6869
request.setEntity(createEntity(deleteRollupJobRequest, REQUEST_BODY_CONTENT_TYPE));
6970
return request;
7071
}
72+
73+
static Request getRollupCaps(final GetRollupCapsRequest getRollupCapsRequest) throws IOException {
74+
String endpoint = new RequestConverters.EndpointBuilder()
75+
.addPathPartAsIs("_xpack")
76+
.addPathPartAsIs("rollup")
77+
.addPathPartAsIs("data")
78+
.addPathPart(getRollupCapsRequest.getIndexPattern())
79+
.build();
80+
Request request = new Request(HttpGet.METHOD_NAME, endpoint);
81+
request.setEntity(createEntity(getRollupCapsRequest, REQUEST_BODY_CONTENT_TYPE));
82+
return request;
83+
}
7184
}

0 commit comments

Comments
 (0)