|
@@ -153,13 +153,13 @@ public final class MachineLearningClient {
|
|
|
* <p>
|
|
|
* For additional info
|
|
|
* see <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-put-job.html">ML PUT job documentation</a>
|
|
|
- *
|
|
|
* @param request The request containing the {@link org.elasticsearch.client.ml.job.config.Job} settings
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void putJobAsync(PutJobRequest request, RequestOptions options, ActionListener<PutJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable putJobAsync(PutJobRequest request, RequestOptions options, ActionListener<PutJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::putJob,
|
|
|
options,
|
|
|
PutJobResponse::fromXContent,
|
|
@@ -192,13 +192,13 @@ public final class MachineLearningClient {
|
|
|
* <p>
|
|
|
* For additional info
|
|
|
* see <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-get-job.html">ML GET job documentation</a>
|
|
|
- *
|
|
|
* @param request {@link GetJobRequest} Request containing a list of jobId(s) and additional options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified with {@link GetJobResponse} upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getJobAsync(GetJobRequest request, RequestOptions options, ActionListener<GetJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getJobAsync(GetJobRequest request, RequestOptions options, ActionListener<GetJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getJob,
|
|
|
options,
|
|
|
GetJobResponse::fromXContent,
|
|
@@ -231,13 +231,13 @@ public final class MachineLearningClient {
|
|
|
* <p>
|
|
|
* For additional info
|
|
|
* see <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-get-job-stats.html">Get job stats docs</a>
|
|
|
- *
|
|
|
* @param request {@link GetJobStatsRequest} Request containing a list of jobId(s) and additional options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified with {@link GetJobStatsResponse} upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getJobStatsAsync(GetJobStatsRequest request, RequestOptions options, ActionListener<GetJobStatsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getJobStatsAsync(GetJobStatsRequest request, RequestOptions options, ActionListener<GetJobStatsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getJobStats,
|
|
|
options,
|
|
|
GetJobStatsResponse::fromXContent,
|
|
@@ -272,14 +272,14 @@ public final class MachineLearningClient {
|
|
|
* For additional info
|
|
|
* see <a href="http://www.elastic.co/guide/en/elasticsearch/reference/current/ml-delete-expired-data.html">ML Delete Expired Data
|
|
|
* documentation</a>
|
|
|
- *
|
|
|
* @param request The request to delete expired ML data
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteExpiredDataAsync(DeleteExpiredDataRequest request, RequestOptions options,
|
|
|
- ActionListener<DeleteExpiredDataResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteExpiredDataAsync(DeleteExpiredDataRequest request, RequestOptions options,
|
|
|
+ ActionListener<DeleteExpiredDataResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteExpiredData,
|
|
|
options,
|
|
|
DeleteExpiredDataResponse::fromXContent,
|
|
@@ -313,12 +313,13 @@ public final class MachineLearningClient {
|
|
|
* For additional info
|
|
|
* see <a href="http://www.elastic.co/guide/en/elasticsearch/reference/current/ml-delete-job.html">ML Delete Job documentation</a>
|
|
|
*
|
|
|
- * @param request The request to delete the job
|
|
|
+ * @param request The request to delete the job
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteJobAsync(DeleteJobRequest request, RequestOptions options, ActionListener<DeleteJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteJobAsync(DeleteJobRequest request, RequestOptions options, ActionListener<DeleteJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteJob,
|
|
|
options,
|
|
|
DeleteJobResponse::fromXContent,
|
|
@@ -360,9 +361,10 @@ public final class MachineLearningClient {
|
|
|
* @param request Request containing job_id and additional optional options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void openJobAsync(OpenJobRequest request, RequestOptions options, ActionListener<OpenJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable openJobAsync(OpenJobRequest request, RequestOptions options, ActionListener<OpenJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::openJob,
|
|
|
options,
|
|
|
OpenJobResponse::fromXContent,
|
|
@@ -400,9 +402,10 @@ public final class MachineLearningClient {
|
|
|
* @param request Request containing job_ids and additional options. See {@link CloseJobRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void closeJobAsync(CloseJobRequest request, RequestOptions options, ActionListener<CloseJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable closeJobAsync(CloseJobRequest request, RequestOptions options, ActionListener<CloseJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::closeJob,
|
|
|
options,
|
|
|
CloseJobResponse::fromXContent,
|
|
@@ -449,9 +452,10 @@ public final class MachineLearningClient {
|
|
|
* @param request The {@link FlushJobRequest} object enclosing the `jobId` and additional request options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void flushJobAsync(FlushJobRequest request, RequestOptions options, ActionListener<FlushJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable flushJobAsync(FlushJobRequest request, RequestOptions options, ActionListener<FlushJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::flushJob,
|
|
|
options,
|
|
|
FlushJobResponse::fromXContent,
|
|
@@ -489,9 +493,10 @@ public final class MachineLearningClient {
|
|
|
* @param request ForecastJobRequest with forecasting options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void forecastJobAsync(ForecastJobRequest request, RequestOptions options, ActionListener<ForecastJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable forecastJobAsync(ForecastJobRequest request, RequestOptions options, ActionListener<ForecastJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::forecastJob,
|
|
|
options,
|
|
|
ForecastJobResponse::fromXContent,
|
|
@@ -529,9 +534,11 @@ public final class MachineLearningClient {
|
|
|
* @param request the {@link DeleteForecastRequest} object enclosing the desired jobId, forecastIDs, and other options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteForecastAsync(DeleteForecastRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteForecastAsync(DeleteForecastRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteForecast,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -569,10 +576,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to delete the model snapshot
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteModelSnapshotAsync(DeleteModelSnapshotRequest request, RequestOptions options,
|
|
|
- ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteModelSnapshotAsync(DeleteModelSnapshotRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteModelSnapshot,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -610,10 +618,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to revert to a previous model snapshot
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void revertModelSnapshotAsync(RevertModelSnapshotRequest request, RequestOptions options,
|
|
|
- ActionListener<RevertModelSnapshotResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable revertModelSnapshotAsync(RevertModelSnapshotRequest request, RequestOptions options,
|
|
|
+ ActionListener<RevertModelSnapshotResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::revertModelSnapshot,
|
|
|
options,
|
|
|
RevertModelSnapshotResponse::fromXContent,
|
|
@@ -649,9 +658,10 @@ public final class MachineLearningClient {
|
|
|
* @param request The request containing the {@link org.elasticsearch.client.ml.datafeed.DatafeedConfig} settings
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void putDatafeedAsync(PutDatafeedRequest request, RequestOptions options, ActionListener<PutDatafeedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable putDatafeedAsync(PutDatafeedRequest request, RequestOptions options, ActionListener<PutDatafeedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::putDatafeed,
|
|
|
options,
|
|
|
PutDatafeedResponse::fromXContent,
|
|
@@ -689,9 +699,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request containing the {@link org.elasticsearch.client.ml.datafeed.DatafeedUpdate} settings
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void updateDatafeedAsync(UpdateDatafeedRequest request, RequestOptions options, ActionListener<PutDatafeedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable updateDatafeedAsync(UpdateDatafeedRequest request, RequestOptions options,
|
|
|
+ ActionListener<PutDatafeedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::updateDatafeed,
|
|
|
options,
|
|
|
PutDatafeedResponse::fromXContent,
|
|
@@ -730,9 +742,11 @@ public final class MachineLearningClient {
|
|
|
* @param request {@link GetDatafeedRequest} Request containing a list of datafeedId(s) and additional options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified with {@link GetDatafeedResponse} upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getDatafeedAsync(GetDatafeedRequest request, RequestOptions options, ActionListener<GetDatafeedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getDatafeedAsync(GetDatafeedRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetDatafeedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getDatafeed,
|
|
|
options,
|
|
|
GetDatafeedResponse::fromXContent,
|
|
@@ -770,9 +784,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to delete the datafeed
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteDatafeedAsync(DeleteDatafeedRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteDatafeedAsync(DeleteDatafeedRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteDatafeed,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -810,9 +826,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to start the datafeed
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void startDatafeedAsync(StartDatafeedRequest request, RequestOptions options, ActionListener<StartDatafeedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable startDatafeedAsync(StartDatafeedRequest request, RequestOptions options,
|
|
|
+ ActionListener<StartDatafeedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::startDatafeed,
|
|
|
options,
|
|
|
StartDatafeedResponse::fromXContent,
|
|
@@ -850,9 +868,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to stop the datafeed
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void stopDatafeedAsync(StopDatafeedRequest request, RequestOptions options, ActionListener<StopDatafeedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable stopDatafeedAsync(StopDatafeedRequest request, RequestOptions options,
|
|
|
+ ActionListener<StopDatafeedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::stopDatafeed,
|
|
|
options,
|
|
|
StopDatafeedResponse::fromXContent,
|
|
@@ -910,11 +930,12 @@ public final class MachineLearningClient {
|
|
|
* @param request {@link GetDatafeedStatsRequest} Request containing a list of datafeedId(s) and additional options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified with {@link GetDatafeedStatsResponse} upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getDatafeedStatsAsync(GetDatafeedStatsRequest request,
|
|
|
- RequestOptions options,
|
|
|
- ActionListener<GetDatafeedStatsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getDatafeedStatsAsync(GetDatafeedStatsRequest request,
|
|
|
+ RequestOptions options,
|
|
|
+ ActionListener<GetDatafeedStatsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getDatafeedStats,
|
|
|
options,
|
|
|
GetDatafeedStatsResponse::fromXContent,
|
|
@@ -932,11 +953,12 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to preview the datafeed
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void previewDatafeedAsync(PreviewDatafeedRequest request,
|
|
|
- RequestOptions options,
|
|
|
- ActionListener<PreviewDatafeedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable previewDatafeedAsync(PreviewDatafeedRequest request,
|
|
|
+ RequestOptions options,
|
|
|
+ ActionListener<PreviewDatafeedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::previewDatafeed,
|
|
|
options,
|
|
|
PreviewDatafeedResponse::fromXContent,
|
|
@@ -972,9 +994,10 @@ public final class MachineLearningClient {
|
|
|
* @param request the {@link UpdateJobRequest} object enclosing the desired updates
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void updateJobAsync(UpdateJobRequest request, RequestOptions options, ActionListener<PutJobResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable updateJobAsync(UpdateJobRequest request, RequestOptions options, ActionListener<PutJobResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::updateJob,
|
|
|
options,
|
|
|
PutJobResponse::fromXContent,
|
|
@@ -1005,12 +1028,13 @@ public final class MachineLearningClient {
|
|
|
* For additional info
|
|
|
* see <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-get-bucket.html">ML GET buckets documentation</a>
|
|
|
*
|
|
|
- * @param request The request
|
|
|
+ * @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getBucketsAsync(GetBucketsRequest request, RequestOptions options, ActionListener<GetBucketsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getBucketsAsync(GetBucketsRequest request, RequestOptions options, ActionListener<GetBucketsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getBuckets,
|
|
|
options,
|
|
|
GetBucketsResponse::fromXContent,
|
|
@@ -1047,9 +1071,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getCategoriesAsync(GetCategoriesRequest request, RequestOptions options, ActionListener<GetCategoriesResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getCategoriesAsync(GetCategoriesRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetCategoriesResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getCategories,
|
|
|
options,
|
|
|
GetCategoriesResponse::fromXContent,
|
|
@@ -1086,10 +1112,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getModelSnapshotsAsync(GetModelSnapshotsRequest request, RequestOptions options,
|
|
|
- ActionListener<GetModelSnapshotsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getModelSnapshotsAsync(GetModelSnapshotsRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetModelSnapshotsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getModelSnapshots,
|
|
|
options,
|
|
|
GetModelSnapshotsResponse::fromXContent,
|
|
@@ -1127,10 +1154,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void updateModelSnapshotAsync(UpdateModelSnapshotRequest request, RequestOptions options,
|
|
|
- ActionListener<UpdateModelSnapshotResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable updateModelSnapshotAsync(UpdateModelSnapshotRequest request, RequestOptions options,
|
|
|
+ ActionListener<UpdateModelSnapshotResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::updateModelSnapshot,
|
|
|
options,
|
|
|
UpdateModelSnapshotResponse::fromXContent,
|
|
@@ -1166,10 +1194,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getOverallBucketsAsync(GetOverallBucketsRequest request, RequestOptions options,
|
|
|
- ActionListener<GetOverallBucketsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getOverallBucketsAsync(GetOverallBucketsRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetOverallBucketsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getOverallBuckets,
|
|
|
options,
|
|
|
GetOverallBucketsResponse::fromXContent,
|
|
@@ -1203,9 +1232,10 @@ public final class MachineLearningClient {
|
|
|
* @param request the request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getRecordsAsync(GetRecordsRequest request, RequestOptions options, ActionListener<GetRecordsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getRecordsAsync(GetRecordsRequest request, RequestOptions options, ActionListener<GetRecordsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getRecords,
|
|
|
options,
|
|
|
GetRecordsResponse::fromXContent,
|
|
@@ -1245,9 +1275,10 @@ public final class MachineLearningClient {
|
|
|
* @param request PostDataRequest containing the data to post and some additional options
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void postDataAsync(PostDataRequest request, RequestOptions options, ActionListener<PostDataResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable postDataAsync(PostDataRequest request, RequestOptions options, ActionListener<PostDataResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::postData,
|
|
|
options,
|
|
|
PostDataResponse::fromXContent,
|
|
@@ -1283,9 +1314,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The calendars request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getCalendarsAsync(GetCalendarsRequest request, RequestOptions options, ActionListener<GetCalendarsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getCalendarsAsync(GetCalendarsRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetCalendarsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getCalendars,
|
|
|
options,
|
|
|
GetCalendarsResponse::fromXContent,
|
|
@@ -1321,10 +1354,11 @@ public final class MachineLearningClient {
|
|
|
* @param request the request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getInfluencersAsync(GetInfluencersRequest request, RequestOptions options,
|
|
|
- ActionListener<GetInfluencersResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getInfluencersAsync(GetInfluencersRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetInfluencersResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getInfluencers,
|
|
|
options,
|
|
|
GetInfluencersResponse::fromXContent,
|
|
@@ -1362,9 +1396,10 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void putCalendarAsync(PutCalendarRequest request, RequestOptions options, ActionListener<PutCalendarResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable putCalendarAsync(PutCalendarRequest request, RequestOptions options, ActionListener<PutCalendarResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::putCalendar,
|
|
|
options,
|
|
|
PutCalendarResponse::fromXContent,
|
|
@@ -1402,9 +1437,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void putCalendarJobAsync(PutCalendarJobRequest request, RequestOptions options, ActionListener<PutCalendarResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable putCalendarJobAsync(PutCalendarJobRequest request, RequestOptions options,
|
|
|
+ ActionListener<PutCalendarResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::putCalendarJob,
|
|
|
options,
|
|
|
PutCalendarResponse::fromXContent,
|
|
@@ -1442,11 +1479,12 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteCalendarJobAsync(DeleteCalendarJobRequest request,
|
|
|
- RequestOptions options,
|
|
|
- ActionListener<PutCalendarResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteCalendarJobAsync(DeleteCalendarJobRequest request,
|
|
|
+ RequestOptions options,
|
|
|
+ ActionListener<PutCalendarResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteCalendarJob,
|
|
|
options,
|
|
|
PutCalendarResponse::fromXContent,
|
|
@@ -1484,9 +1522,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to delete the calendar
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteCalendarAsync(DeleteCalendarRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteCalendarAsync(DeleteCalendarRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteCalendar,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -1524,10 +1564,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getCalendarEventsAsync(GetCalendarEventsRequest request, RequestOptions options,
|
|
|
- ActionListener<GetCalendarEventsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getCalendarEventsAsync(GetCalendarEventsRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetCalendarEventsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getCalendarEvents,
|
|
|
options,
|
|
|
GetCalendarEventsResponse::fromXContent,
|
|
@@ -1565,10 +1606,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void postCalendarEventAsync(PostCalendarEventRequest request, RequestOptions options,
|
|
|
- ActionListener<PostCalendarEventResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable postCalendarEventAsync(PostCalendarEventRequest request, RequestOptions options,
|
|
|
+ ActionListener<PostCalendarEventResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::postCalendarEvents,
|
|
|
options,
|
|
|
PostCalendarEventResponse::fromXContent,
|
|
@@ -1606,11 +1648,12 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteCalendarEventAsync(DeleteCalendarEventRequest request,
|
|
|
- RequestOptions options,
|
|
|
- ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteCalendarEventAsync(DeleteCalendarEventRequest request,
|
|
|
+ RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteCalendarEvent,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -1646,9 +1689,10 @@ public final class MachineLearningClient {
|
|
|
* @param request The request containing the {@link org.elasticsearch.client.ml.job.config.MlFilter} settings
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void putFilterAsync(PutFilterRequest request, RequestOptions options, ActionListener<PutFilterResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable putFilterAsync(PutFilterRequest request, RequestOptions options, ActionListener<PutFilterResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::putFilter,
|
|
|
options,
|
|
|
PutFilterResponse::fromXContent,
|
|
@@ -1684,9 +1728,10 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getFilterAsync(GetFiltersRequest request, RequestOptions options, ActionListener<GetFiltersResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getFilterAsync(GetFiltersRequest request, RequestOptions options, ActionListener<GetFiltersResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getFilter,
|
|
|
options,
|
|
|
GetFiltersResponse::fromXContent,
|
|
@@ -1724,9 +1769,10 @@ public final class MachineLearningClient {
|
|
|
* @param request The request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void updateFilterAsync(UpdateFilterRequest request, RequestOptions options, ActionListener<PutFilterResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable updateFilterAsync(UpdateFilterRequest request, RequestOptions options, ActionListener<PutFilterResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::updateFilter,
|
|
|
options,
|
|
|
PutFilterResponse::fromXContent,
|
|
@@ -1764,9 +1810,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request to delete the filter
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteFilterAsync(DeleteFilterRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteFilterAsync(DeleteFilterRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteFilter,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -1802,9 +1850,10 @@ public final class MachineLearningClient {
|
|
|
* @param request The request of Machine Learning info
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getMlInfoAsync(MlInfoRequest request, RequestOptions options, ActionListener<MlInfoResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getMlInfoAsync(MlInfoRequest request, RequestOptions options, ActionListener<MlInfoResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::mlInfo,
|
|
|
options,
|
|
|
MlInfoResponse::fromXContent,
|
|
@@ -1842,10 +1891,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The find file structure request
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void findFileStructureAsync(FindFileStructureRequest request, RequestOptions options,
|
|
|
- ActionListener<FindFileStructureResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable findFileStructureAsync(FindFileStructureRequest request, RequestOptions options,
|
|
|
+ ActionListener<FindFileStructureResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::findFileStructure,
|
|
|
options,
|
|
|
FindFileStructureResponse::fromXContent,
|
|
@@ -1881,9 +1931,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The request of Machine Learning info
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void setUpgradeModeAsync(SetUpgradeModeRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable setUpgradeModeAsync(SetUpgradeModeRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::setUpgradeMode,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -1925,10 +1977,11 @@ public final class MachineLearningClient {
|
|
|
* {@link org.elasticsearch.client.ml.dataframe.DataFrameAnalyticsConfig}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void putDataFrameAnalyticsAsync(PutDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
- ActionListener<PutDataFrameAnalyticsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable putDataFrameAnalyticsAsync(PutDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
+ ActionListener<PutDataFrameAnalyticsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::putDataFrameAnalytics,
|
|
|
options,
|
|
|
PutDataFrameAnalyticsResponse::fromXContent,
|
|
@@ -1967,10 +2020,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The {@link GetDataFrameAnalyticsRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getDataFrameAnalyticsAsync(GetDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
- ActionListener<GetDataFrameAnalyticsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getDataFrameAnalyticsAsync(GetDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetDataFrameAnalyticsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getDataFrameAnalytics,
|
|
|
options,
|
|
|
GetDataFrameAnalyticsResponse::fromXContent,
|
|
@@ -2008,10 +2062,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The {@link GetDataFrameAnalyticsStatsRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void getDataFrameAnalyticsStatsAsync(GetDataFrameAnalyticsStatsRequest request, RequestOptions options,
|
|
|
- ActionListener<GetDataFrameAnalyticsStatsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable getDataFrameAnalyticsStatsAsync(GetDataFrameAnalyticsStatsRequest request, RequestOptions options,
|
|
|
+ ActionListener<GetDataFrameAnalyticsStatsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::getDataFrameAnalyticsStats,
|
|
|
options,
|
|
|
GetDataFrameAnalyticsStatsResponse::fromXContent,
|
|
@@ -2047,13 +2102,14 @@ public final class MachineLearningClient {
|
|
|
* see <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/start-dfanalytics.html">
|
|
|
* Start Data Frame Analytics documentation</a>
|
|
|
*
|
|
|
- * @param request The {@link StartDataFrameAnalyticsRequest}
|
|
|
+ * @param request The {@link StartDataFrameAnalyticsRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void startDataFrameAnalyticsAsync(StartDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
- ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable startDataFrameAnalyticsAsync(StartDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::startDataFrameAnalytics,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -2092,10 +2148,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The {@link StopDataFrameAnalyticsRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void stopDataFrameAnalyticsAsync(StopDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
- ActionListener<StopDataFrameAnalyticsResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable stopDataFrameAnalyticsAsync(StopDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
+ ActionListener<StopDataFrameAnalyticsResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::stopDataFrameAnalytics,
|
|
|
options,
|
|
|
StopDataFrameAnalyticsResponse::fromXContent,
|
|
@@ -2134,10 +2191,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The {@link DeleteDataFrameAnalyticsRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void deleteDataFrameAnalyticsAsync(DeleteDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
- ActionListener<AcknowledgedResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable deleteDataFrameAnalyticsAsync(DeleteDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
+ ActionListener<AcknowledgedResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::deleteDataFrameAnalytics,
|
|
|
options,
|
|
|
AcknowledgedResponse::fromXContent,
|
|
@@ -2176,10 +2234,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The {@link EvaluateDataFrameRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void evaluateDataFrameAsync(EvaluateDataFrameRequest request, RequestOptions options,
|
|
|
- ActionListener<EvaluateDataFrameResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
+ public Cancellable evaluateDataFrameAsync(EvaluateDataFrameRequest request, RequestOptions options,
|
|
|
+ ActionListener<EvaluateDataFrameResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(request,
|
|
|
MLRequestConverters::evaluateDataFrame,
|
|
|
options,
|
|
|
EvaluateDataFrameResponse::fromXContent,
|
|
@@ -2219,10 +2278,11 @@ public final class MachineLearningClient {
|
|
|
* @param request The {@link PutDataFrameAnalyticsRequest}
|
|
|
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
|
|
|
* @param listener Listener to be notified upon request completion
|
|
|
+ * @return cancellable that may be used to cancel the request
|
|
|
*/
|
|
|
- public void estimateMemoryUsageAsync(PutDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
- ActionListener<EstimateMemoryUsageResponse> listener) {
|
|
|
- restHighLevelClient.performRequestAsyncAndParseEntity(
|
|
|
+ public Cancellable estimateMemoryUsageAsync(PutDataFrameAnalyticsRequest request, RequestOptions options,
|
|
|
+ ActionListener<EstimateMemoryUsageResponse> listener) {
|
|
|
+ return restHighLevelClient.performRequestAsyncAndParseEntity(
|
|
|
request,
|
|
|
MLRequestConverters::estimateMemoryUsage,
|
|
|
options,
|