|
22 | 22 | import org.elasticsearch.action.ActionListener; |
23 | 23 | import org.elasticsearch.client.rollup.DeleteRollupJobRequest; |
24 | 24 | import org.elasticsearch.client.rollup.DeleteRollupJobResponse; |
25 | | -import org.elasticsearch.client.rollup.GetRollupJobRequest; |
26 | | -import org.elasticsearch.client.rollup.GetRollupJobResponse; |
27 | 25 | import org.elasticsearch.client.rollup.GetRollupCapsRequest; |
28 | 26 | import org.elasticsearch.client.rollup.GetRollupCapsResponse; |
| 27 | +import org.elasticsearch.client.rollup.GetRollupJobRequest; |
| 28 | +import org.elasticsearch.client.rollup.GetRollupJobResponse; |
29 | 29 | import org.elasticsearch.client.rollup.PutRollupJobRequest; |
30 | 30 | import org.elasticsearch.client.rollup.PutRollupJobResponse; |
31 | | -import org.elasticsearch.client.rollup.StopRollupJobRequest; |
32 | | -import org.elasticsearch.client.rollup.StopRollupJobResponse; |
33 | 31 | import org.elasticsearch.client.rollup.StartRollupJobRequest; |
34 | 32 | import org.elasticsearch.client.rollup.StartRollupJobResponse; |
| 33 | +import org.elasticsearch.client.rollup.StopRollupJobRequest; |
| 34 | +import org.elasticsearch.client.rollup.StopRollupJobResponse; |
35 | 35 |
|
36 | 36 | import java.io.IOException; |
37 | 37 | import java.util.Collections; |
@@ -102,19 +102,20 @@ public StartRollupJobResponse startRollupJob(StartRollupJobRequest request, Requ |
102 | 102 | } |
103 | 103 |
|
104 | 104 | /** |
105 | | - * Asynchronously start a rollup job See <a href= |
106 | | - * "https://www.elastic.co/guide/en/elasticsearch/reference/current/rollup-start-job.html"> |
| 105 | + * Asynchronously start a rollup job |
| 106 | + * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/rollup-start-job.html"> |
107 | 107 | * the docs</a> for more. |
108 | | - * |
109 | 108 | * @param request the request |
110 | | - * @param options the request options (e.g. headers), use |
111 | | - * {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 109 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
112 | 110 | * @param listener the listener to be notified upon request completion |
113 | 111 | */ |
114 | 112 | public void startRollupJobAsync(StartRollupJobRequest request, RequestOptions options, |
115 | 113 | ActionListener<StartRollupJobResponse> listener) { |
116 | | - restHighLevelClient.performRequestAsyncAndParseEntity(request, RollupRequestConverters::startJob, options, |
117 | | - StartRollupJobResponse::fromXContent, listener, Collections.emptySet()); |
| 114 | + restHighLevelClient.performRequestAsyncAndParseEntity(request, |
| 115 | + RollupRequestConverters::startJob, |
| 116 | + options, |
| 117 | + StartRollupJobResponse::fromXContent, |
| 118 | + listener, Collections.emptySet()); |
118 | 119 | } |
119 | 120 |
|
120 | 121 | /** |
|
0 commit comments