diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/RestHighLevelClient.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/RestHighLevelClient.java
index 65d517231f2..171dfb174dc 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/RestHighLevelClient.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/RestHighLevelClient.java
@@ -256,7 +256,7 @@ public class RestHighLevelClient implements Closeable {
private final IndexLifecycleClient ilmClient = new IndexLifecycleClient(this);
private final RollupClient rollupClient = new RollupClient(this);
private final CcrClient ccrClient = new CcrClient(this);
- private final DataFrameClient dataFrameClient = new DataFrameClient(this);
+ private final TransformClient transformClient = new TransformClient(this);
/**
* Creates a {@link RestHighLevelClient} given the low level {@link RestClientBuilder} that allows to build the
@@ -477,8 +477,8 @@ public class RestHighLevelClient implements Closeable {
*
* @return the client wrapper for making Data Frame API calls
*/
- public DataFrameClient dataFrame() {
- return dataFrameClient;
+ public TransformClient transform() {
+ return transformClient;
}
/**
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/DataFrameClient.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/TransformClient.java
similarity index 65%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/DataFrameClient.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/TransformClient.java
index e56bd442292..9b18fbc06af 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/DataFrameClient.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/TransformClient.java
@@ -21,29 +21,29 @@ package org.elasticsearch.client;
import org.elasticsearch.action.ActionListener;
import org.elasticsearch.client.core.AcknowledgedResponse;
-import org.elasticsearch.client.transform.DeleteDataFrameTransformRequest;
-import org.elasticsearch.client.transform.GetDataFrameTransformRequest;
-import org.elasticsearch.client.transform.GetDataFrameTransformResponse;
-import org.elasticsearch.client.transform.GetDataFrameTransformStatsRequest;
-import org.elasticsearch.client.transform.GetDataFrameTransformStatsResponse;
-import org.elasticsearch.client.transform.PreviewDataFrameTransformRequest;
-import org.elasticsearch.client.transform.PreviewDataFrameTransformResponse;
-import org.elasticsearch.client.transform.PutDataFrameTransformRequest;
-import org.elasticsearch.client.transform.StartDataFrameTransformRequest;
-import org.elasticsearch.client.transform.StartDataFrameTransformResponse;
-import org.elasticsearch.client.transform.StopDataFrameTransformRequest;
-import org.elasticsearch.client.transform.StopDataFrameTransformResponse;
-import org.elasticsearch.client.transform.UpdateDataFrameTransformRequest;
-import org.elasticsearch.client.transform.UpdateDataFrameTransformResponse;
+import org.elasticsearch.client.transform.DeleteTransformRequest;
+import org.elasticsearch.client.transform.GetTransformRequest;
+import org.elasticsearch.client.transform.GetTransformResponse;
+import org.elasticsearch.client.transform.GetTransformStatsRequest;
+import org.elasticsearch.client.transform.GetTransformStatsResponse;
+import org.elasticsearch.client.transform.PreviewTransformRequest;
+import org.elasticsearch.client.transform.PreviewTransformResponse;
+import org.elasticsearch.client.transform.PutTransformRequest;
+import org.elasticsearch.client.transform.StartTransformRequest;
+import org.elasticsearch.client.transform.StartTransformResponse;
+import org.elasticsearch.client.transform.StopTransformRequest;
+import org.elasticsearch.client.transform.StopTransformResponse;
+import org.elasticsearch.client.transform.UpdateTransformRequest;
+import org.elasticsearch.client.transform.UpdateTransformResponse;
import java.io.IOException;
import java.util.Collections;
-public final class DataFrameClient {
+public final class TransformClient {
private final RestHighLevelClient restHighLevelClient;
- DataFrameClient(RestHighLevelClient restHighLevelClient) {
+ TransformClient(RestHighLevelClient restHighLevelClient) {
this.restHighLevelClient = restHighLevelClient;
}
@@ -54,15 +54,15 @@ public final class DataFrameClient {
* see
* Create transform documentation
*
- * @param request The PutDataFrameTransformRequest containing the
- * {@link org.elasticsearch.client.transform.transforms.DataFrameTransformConfig}.
+ * @param request The PutTransformRequest containing the
+ * {@link org.elasticsearch.client.transform.transforms.TransformConfig}.
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
* @return An AcknowledgedResponse object indicating request success
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public AcknowledgedResponse putDataFrameTransform(PutDataFrameTransformRequest request, RequestOptions options) throws IOException {
+ public AcknowledgedResponse putTransform(PutTransformRequest request, RequestOptions options) throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::putDataFrameTransform,
+ TransformRequestConverters::putTransform,
options,
AcknowledgedResponse::fromXContent,
Collections.emptySet());
@@ -74,16 +74,16 @@ public final class DataFrameClient {
* For additional info
* see
* Create transform documentation
- * @param request The PutDataFrameTransformRequest containing the
- * {@link org.elasticsearch.client.transform.transforms.DataFrameTransformConfig}.
+ * @param request The PutTransformRequest containing the
+ * {@link org.elasticsearch.client.transform.transforms.TransformConfig}.
* @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 Cancellable putDataFrameTransformAsync(PutDataFrameTransformRequest request, RequestOptions options,
- ActionListener listener) {
+ public Cancellable putTransformAsync(PutTransformRequest request, RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::putDataFrameTransform,
+ TransformRequestConverters::putTransform,
options,
AcknowledgedResponse::fromXContent,
listener,
@@ -97,18 +97,18 @@ public final class DataFrameClient {
* see
* Create transform documentation
*
- * @param request The UpdateDataFrameTransformRequest containing the
- * {@link org.elasticsearch.client.transform.transforms.DataFrameTransformConfigUpdate}.
+ * @param request The UpdateTransformRequest containing the
+ * {@link org.elasticsearch.client.transform.transforms.TransformConfigUpdate}.
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
- * @return An UpdateDataFrameTransformResponse object containing the updated configuration
+ * @return An UpdateTransformResponse object containing the updated configuration
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public UpdateDataFrameTransformResponse updateDataFrameTransform(UpdateDataFrameTransformRequest request,
- RequestOptions options) throws IOException {
+ public UpdateTransformResponse updateTransform(UpdateTransformRequest request,
+ RequestOptions options) throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::updateDataFrameTransform,
+ TransformRequestConverters::updateTransform,
options,
- UpdateDataFrameTransformResponse::fromXContent,
+ UpdateTransformResponse::fromXContent,
Collections.emptySet());
}
@@ -118,19 +118,19 @@ public final class DataFrameClient {
* For additional info
* see
* Create transform documentation
- * @param request The UpdateDataFrameTransformRequest containing the
- * {@link org.elasticsearch.client.transform.transforms.DataFrameTransformConfigUpdate}.
+ * @param request The UpdateTransformRequest containing the
+ * {@link org.elasticsearch.client.transform.transforms.TransformConfigUpdate}.
* @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 Cancellable updateDataFrameTransformAsync(UpdateDataFrameTransformRequest request,
- RequestOptions options,
- ActionListener listener) {
+ public Cancellable updateTransformAsync(UpdateTransformRequest request,
+ RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::updateDataFrameTransform,
+ TransformRequestConverters::updateTransform,
options,
- UpdateDataFrameTransformResponse::fromXContent,
+ UpdateTransformResponse::fromXContent,
listener,
Collections.emptySet());
}
@@ -142,17 +142,17 @@ public final class DataFrameClient {
* see
* Get transform stats documentation
*
- * @param request Specifies the which transforms to get the stats for
+ * @param request Specifies which transforms to get the stats for
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
* @return The transform stats
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public GetDataFrameTransformStatsResponse getDataFrameTransformStats(GetDataFrameTransformStatsRequest request, RequestOptions options)
+ public GetTransformStatsResponse getTransformStats(GetTransformStatsRequest request, RequestOptions options)
throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::getDataFrameTransformStats,
+ TransformRequestConverters::getTransformStats,
options,
- GetDataFrameTransformStatsResponse::fromXContent,
+ GetTransformStatsResponse::fromXContent,
Collections.emptySet());
}
@@ -162,17 +162,17 @@ public final class DataFrameClient {
* For additional info
* see
* Get transform stats documentation
- * @param request Specifies the which transforms to get the stats for
+ * @param request Specifies which transforms to get the stats for
* @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 Cancellable getDataFrameTransformStatsAsync(GetDataFrameTransformStatsRequest request, RequestOptions options,
- ActionListener listener) {
+ public Cancellable getTransformStatsAsync(GetTransformStatsRequest request, RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::getDataFrameTransformStats,
+ TransformRequestConverters::getTransformStats,
options,
- GetDataFrameTransformStatsResponse::fromXContent,
+ GetTransformStatsResponse::fromXContent,
listener,
Collections.emptySet());
}
@@ -189,10 +189,10 @@ public final class DataFrameClient {
* @return An AcknowledgedResponse object indicating request success
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public AcknowledgedResponse deleteDataFrameTransform(DeleteDataFrameTransformRequest request, RequestOptions options)
+ public AcknowledgedResponse deleteTransform(DeleteTransformRequest request, RequestOptions options)
throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::deleteDataFrameTransform,
+ TransformRequestConverters::deleteTransform,
options,
AcknowledgedResponse::fromXContent,
Collections.emptySet());
@@ -209,10 +209,10 @@ public final class DataFrameClient {
* @param listener Listener to be notified upon request completion
* @return cancellable that may be used to cancel the request
*/
- public Cancellable deleteDataFrameTransformAsync(DeleteDataFrameTransformRequest request, RequestOptions options,
- ActionListener listener) {
+ public Cancellable deleteTransformAsync(DeleteTransformRequest request, RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::deleteDataFrameTransform,
+ TransformRequestConverters::deleteTransform,
options,
AcknowledgedResponse::fromXContent,
listener,
@@ -231,12 +231,12 @@ public final class DataFrameClient {
* @return A response containing the results of the applied transform
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public PreviewDataFrameTransformResponse previewDataFrameTransform(PreviewDataFrameTransformRequest request, RequestOptions options)
+ public PreviewTransformResponse previewTransform(PreviewTransformRequest request, RequestOptions options)
throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::previewDataFrameTransform,
+ TransformRequestConverters::previewTransform,
options,
- PreviewDataFrameTransformResponse::fromXContent,
+ PreviewTransformResponse::fromXContent,
Collections.emptySet());
}
@@ -250,12 +250,12 @@ public final class DataFrameClient {
* @param listener Listener to be notified upon request completion
* @return cancellable that may be used to cancel the request
*/
- public Cancellable previewDataFrameTransformAsync(PreviewDataFrameTransformRequest request, RequestOptions options,
- ActionListener listener) {
+ public Cancellable previewTransformAsync(PreviewTransformRequest request, RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::previewDataFrameTransform,
+ TransformRequestConverters::previewTransform,
options,
- PreviewDataFrameTransformResponse::fromXContent,
+ PreviewTransformResponse::fromXContent,
listener,
Collections.emptySet());
}
@@ -272,12 +272,12 @@ public final class DataFrameClient {
* @return A response object indicating request success
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public StartDataFrameTransformResponse startDataFrameTransform(StartDataFrameTransformRequest request, RequestOptions options)
+ public StartTransformResponse startTransform(StartTransformRequest request, RequestOptions options)
throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::startDataFrameTransform,
+ TransformRequestConverters::startTransform,
options,
- StartDataFrameTransformResponse::fromXContent,
+ StartTransformResponse::fromXContent,
Collections.emptySet());
}
@@ -292,12 +292,12 @@ public final class DataFrameClient {
* @param listener Listener to be notified upon request completion
* @return cancellable that may be used to cancel the request
*/
- public Cancellable startDataFrameTransformAsync(StartDataFrameTransformRequest request, RequestOptions options,
- ActionListener listener) {
+ public Cancellable startTransformAsync(StartTransformRequest request, RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::startDataFrameTransform,
+ TransformRequestConverters::startTransform,
options,
- StartDataFrameTransformResponse::fromXContent,
+ StartTransformResponse::fromXContent,
listener,
Collections.emptySet());
}
@@ -314,12 +314,12 @@ public final class DataFrameClient {
* @return A response object indicating request success
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public StopDataFrameTransformResponse stopDataFrameTransform(StopDataFrameTransformRequest request, RequestOptions options)
+ public StopTransformResponse stopTransform(StopTransformRequest request, RequestOptions options)
throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::stopDataFrameTransform,
+ TransformRequestConverters::stopTransform,
options,
- StopDataFrameTransformResponse::fromXContent,
+ StopTransformResponse::fromXContent,
Collections.emptySet());
}
@@ -334,12 +334,12 @@ public final class DataFrameClient {
* @param listener Listener to be notified upon request completion
* @return cancellable that may be used to cancel the request
*/
- public Cancellable stopDataFrameTransformAsync(StopDataFrameTransformRequest request, RequestOptions options,
- ActionListener listener) {
+ public Cancellable stopTransformAsync(StopTransformRequest request, RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::stopDataFrameTransform,
+ TransformRequestConverters::stopTransform,
options,
- StopDataFrameTransformResponse::fromXContent,
+ StopTransformResponse::fromXContent,
listener,
Collections.emptySet());
}
@@ -353,15 +353,15 @@ public final class DataFrameClient {
*
* @param request The get transform request
* @param options Additional request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
- * @return An GetDataFrameTransformResponse containing the requested transforms
+ * @return An GetTransformResponse containing the requested transforms
* @throws IOException when there is a serialization issue sending the request or receiving the response
*/
- public GetDataFrameTransformResponse getDataFrameTransform(GetDataFrameTransformRequest request, RequestOptions options)
+ public GetTransformResponse getTransform(GetTransformRequest request, RequestOptions options)
throws IOException {
return restHighLevelClient.performRequestAndParseEntity(request,
- DataFrameRequestConverters::getDataFrameTransform,
+ TransformRequestConverters::getTransform,
options,
- GetDataFrameTransformResponse::fromXContent,
+ GetTransformResponse::fromXContent,
Collections.emptySet());
}
@@ -376,12 +376,12 @@ public final class DataFrameClient {
* @param listener Listener to be notified upon request completion
* @return cancellable that may be used to cancel the request
*/
- public Cancellable getDataFrameTransformAsync(GetDataFrameTransformRequest request, RequestOptions options,
- ActionListener listener) {
+ public Cancellable getTransformAsync(GetTransformRequest request, RequestOptions options,
+ ActionListener listener) {
return restHighLevelClient.performRequestAsyncAndParseEntity(request,
- DataFrameRequestConverters::getDataFrameTransform,
+ TransformRequestConverters::getTransform,
options,
- GetDataFrameTransformResponse::fromXContent,
+ GetTransformResponse::fromXContent,
listener,
Collections.emptySet());
}
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/DataFrameRequestConverters.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/TransformRequestConverters.java
similarity index 79%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/DataFrameRequestConverters.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/TransformRequestConverters.java
index ab8c79a1784..49d347ae2b6 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/DataFrameRequestConverters.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/TransformRequestConverters.java
@@ -24,29 +24,29 @@ import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
import org.elasticsearch.client.core.PageParams;
-import org.elasticsearch.client.transform.DeleteDataFrameTransformRequest;
-import org.elasticsearch.client.transform.GetDataFrameTransformRequest;
-import org.elasticsearch.client.transform.GetDataFrameTransformStatsRequest;
-import org.elasticsearch.client.transform.PreviewDataFrameTransformRequest;
-import org.elasticsearch.client.transform.PutDataFrameTransformRequest;
-import org.elasticsearch.client.transform.StartDataFrameTransformRequest;
-import org.elasticsearch.client.transform.StopDataFrameTransformRequest;
-import org.elasticsearch.client.transform.UpdateDataFrameTransformRequest;
+import org.elasticsearch.client.transform.DeleteTransformRequest;
+import org.elasticsearch.client.transform.GetTransformRequest;
+import org.elasticsearch.client.transform.GetTransformStatsRequest;
+import org.elasticsearch.client.transform.PreviewTransformRequest;
+import org.elasticsearch.client.transform.PutTransformRequest;
+import org.elasticsearch.client.transform.StartTransformRequest;
+import org.elasticsearch.client.transform.StopTransformRequest;
+import org.elasticsearch.client.transform.UpdateTransformRequest;
import org.elasticsearch.common.Strings;
import java.io.IOException;
import static org.elasticsearch.client.RequestConverters.REQUEST_BODY_CONTENT_TYPE;
import static org.elasticsearch.client.RequestConverters.createEntity;
-import static org.elasticsearch.client.transform.DeleteDataFrameTransformRequest.FORCE;
-import static org.elasticsearch.client.transform.GetDataFrameTransformRequest.ALLOW_NO_MATCH;
-import static org.elasticsearch.client.transform.PutDataFrameTransformRequest.DEFER_VALIDATION;
+import static org.elasticsearch.client.transform.DeleteTransformRequest.FORCE;
+import static org.elasticsearch.client.transform.GetTransformRequest.ALLOW_NO_MATCH;
+import static org.elasticsearch.client.transform.PutTransformRequest.DEFER_VALIDATION;
-final class DataFrameRequestConverters {
+final class TransformRequestConverters {
- private DataFrameRequestConverters() {}
+ private TransformRequestConverters() {}
- static Request putDataFrameTransform(PutDataFrameTransformRequest putRequest) throws IOException {
+ static Request putTransform(PutTransformRequest putRequest) throws IOException {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms")
.addPathPart(putRequest.getConfig().getId())
@@ -59,7 +59,7 @@ final class DataFrameRequestConverters {
return request;
}
- static Request updateDataFrameTransform(UpdateDataFrameTransformRequest updateDataFrameTransformRequest) throws IOException {
+ static Request updateTransform(UpdateTransformRequest updateDataFrameTransformRequest) throws IOException {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms")
.addPathPart(updateDataFrameTransformRequest.getId())
@@ -73,7 +73,7 @@ final class DataFrameRequestConverters {
return request;
}
- static Request getDataFrameTransform(GetDataFrameTransformRequest getRequest) {
+ static Request getTransform(GetTransformRequest getRequest) {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms")
.addPathPart(Strings.collectionToCommaDelimitedString(getRequest.getId()))
@@ -91,7 +91,7 @@ final class DataFrameRequestConverters {
return request;
}
- static Request deleteDataFrameTransform(DeleteDataFrameTransformRequest deleteRequest) {
+ static Request deleteTransform(DeleteTransformRequest deleteRequest) {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms")
.addPathPart(deleteRequest.getId())
@@ -103,7 +103,7 @@ final class DataFrameRequestConverters {
return request;
}
- static Request startDataFrameTransform(StartDataFrameTransformRequest startRequest) {
+ static Request startTransform(StartTransformRequest startRequest) {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms")
.addPathPart(startRequest.getId())
@@ -118,7 +118,7 @@ final class DataFrameRequestConverters {
return request;
}
- static Request stopDataFrameTransform(StopDataFrameTransformRequest stopRequest) {
+ static Request stopTransform(StopTransformRequest stopRequest) {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms")
.addPathPart(stopRequest.getId())
@@ -139,7 +139,7 @@ final class DataFrameRequestConverters {
return request;
}
- static Request previewDataFrameTransform(PreviewDataFrameTransformRequest previewRequest) throws IOException {
+ static Request previewTransform(PreviewTransformRequest previewRequest) throws IOException {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms", "_preview")
.build();
@@ -148,7 +148,7 @@ final class DataFrameRequestConverters {
return request;
}
- static Request getDataFrameTransformStats(GetDataFrameTransformStatsRequest statsRequest) {
+ static Request getTransformStats(GetTransformStatsRequest statsRequest) {
String endpoint = new RequestConverters.EndpointBuilder()
.addPathPartAsIs("_data_frame", "transforms")
.addPathPart(statsRequest.getId())
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/DeleteDataFrameTransformRequest.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/DeleteTransformRequest.java
similarity index 85%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/transform/DeleteDataFrameTransformRequest.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/transform/DeleteTransformRequest.java
index d28779efd1d..7eaeb1435b6 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/DeleteDataFrameTransformRequest.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/DeleteTransformRequest.java
@@ -27,16 +27,16 @@ import java.util.Optional;
/**
- * Request to delete a data frame transform
+ * Request to delete a transform
*/
-public class DeleteDataFrameTransformRequest implements Validatable {
+public class DeleteTransformRequest implements Validatable {
public static final String FORCE = "force";
private final String id;
private Boolean force;
- public DeleteDataFrameTransformRequest(String id) {
+ public DeleteTransformRequest(String id) {
this.id = id;
}
@@ -56,7 +56,7 @@ public class DeleteDataFrameTransformRequest implements Validatable {
public Optional validate() {
if (id == null) {
ValidationException validationException = new ValidationException();
- validationException.addValidationError("data frame transform id must not be null");
+ validationException.addValidationError("transform id must not be null");
return Optional.of(validationException);
} else {
return Optional.empty();
@@ -77,7 +77,7 @@ public class DeleteDataFrameTransformRequest implements Validatable {
if (obj == null || getClass() != obj.getClass()) {
return false;
}
- DeleteDataFrameTransformRequest other = (DeleteDataFrameTransformRequest) obj;
+ DeleteTransformRequest other = (DeleteTransformRequest) obj;
return Objects.equals(id, other.id) && Objects.equals(force, other.force);
}
}
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformRequest.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformRequest.java
similarity index 80%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformRequest.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformRequest.java
index 3c442b65010..f0238083f6a 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformRequest.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformRequest.java
@@ -28,22 +28,22 @@ import java.util.List;
import java.util.Objects;
import java.util.Optional;
-public class GetDataFrameTransformRequest implements Validatable {
+public class GetTransformRequest implements Validatable {
public static final String ALLOW_NO_MATCH = "allow_no_match";
/**
- * Helper method to create a request that will get ALL Data Frame Transforms
- * @return new {@link GetDataFrameTransformRequest} object for the id "_all"
+ * Helper method to create a request that will get ALL Transforms
+ * @return new {@link GetTransformRequest} object for the id "_all"
*/
- public static GetDataFrameTransformRequest getAllDataFrameTransformsRequest() {
- return new GetDataFrameTransformRequest("_all");
+ public static GetTransformRequest getAllTransformRequest() {
+ return new GetTransformRequest("_all");
}
private final List ids;
private PageParams pageParams;
private Boolean allowNoMatch;
- public GetDataFrameTransformRequest(String... ids) {
+ public GetTransformRequest(String... ids) {
this.ids = Arrays.asList(ids);
}
@@ -71,7 +71,7 @@ public class GetDataFrameTransformRequest implements Validatable {
public Optional validate() {
if (ids == null || ids.isEmpty()) {
ValidationException validationException = new ValidationException();
- validationException.addValidationError("data frame transform id must not be null");
+ validationException.addValidationError("transform id must not be null");
return Optional.of(validationException);
} else {
return Optional.empty();
@@ -92,7 +92,7 @@ public class GetDataFrameTransformRequest implements Validatable {
if (obj == null || getClass() != obj.getClass()) {
return false;
}
- GetDataFrameTransformRequest other = (GetDataFrameTransformRequest) obj;
+ GetTransformRequest other = (GetTransformRequest) obj;
return Objects.equals(ids, other.ids)
&& Objects.equals(pageParams, other.pageParams)
&& Objects.equals(allowNoMatch, other.allowNoMatch);
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformResponse.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformResponse.java
similarity index 77%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformResponse.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformResponse.java
index e1ca2df503d..de2418b3852 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformResponse.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformResponse.java
@@ -19,7 +19,7 @@
package org.elasticsearch.client.transform;
-import org.elasticsearch.client.transform.transforms.DataFrameTransformConfig;
+import org.elasticsearch.client.transform.transforms.TransformConfig;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.ParseField;
import org.elasticsearch.common.xcontent.ConstructingObjectParser;
@@ -31,7 +31,7 @@ import java.util.Objects;
import static org.elasticsearch.common.xcontent.ConstructingObjectParser.constructorArg;
import static org.elasticsearch.common.xcontent.ConstructingObjectParser.optionalConstructorArg;
-public class GetDataFrameTransformResponse {
+public class GetTransformResponse {
public static final ParseField TRANSFORMS = new ParseField("transforms");
public static final ParseField INVALID_TRANSFORMS = new ParseField("invalid_transforms");
@@ -42,30 +42,30 @@ public class GetDataFrameTransformResponse {
new ConstructingObjectParser<>("invalid_transforms", true, args -> new InvalidTransforms((List) args[0]));
@SuppressWarnings("unchecked")
- static final ConstructingObjectParser PARSER = new ConstructingObjectParser<>(
- "get_data_frame_transform", true, args -> new GetDataFrameTransformResponse(
- (List) args[0], (int) args[1], (InvalidTransforms) args[2]));
+ static final ConstructingObjectParser PARSER = new ConstructingObjectParser<>(
+ "get_transform", true, args -> new GetTransformResponse(
+ (List) args[0], (int) args[1], (InvalidTransforms) args[2]));
static {
// Discard the count field which is the size of the transforms array
INVALID_TRANSFORMS_PARSER.declareInt((a, b) -> {}, COUNT);
INVALID_TRANSFORMS_PARSER.declareStringArray(constructorArg(), TRANSFORMS);
- PARSER.declareObjectArray(constructorArg(), DataFrameTransformConfig.PARSER::apply, TRANSFORMS);
+ PARSER.declareObjectArray(constructorArg(), TransformConfig.PARSER::apply, TRANSFORMS);
PARSER.declareInt(constructorArg(), COUNT);
PARSER.declareObject(optionalConstructorArg(), INVALID_TRANSFORMS_PARSER::apply, INVALID_TRANSFORMS);
}
- public static GetDataFrameTransformResponse fromXContent(final XContentParser parser) {
- return GetDataFrameTransformResponse.PARSER.apply(parser, null);
+ public static GetTransformResponse fromXContent(final XContentParser parser) {
+ return GetTransformResponse.PARSER.apply(parser, null);
}
- private List transformConfigurations;
+ private List transformConfigurations;
private int count;
private InvalidTransforms invalidTransforms;
- public GetDataFrameTransformResponse(List transformConfigurations,
- int count,
- @Nullable InvalidTransforms invalidTransforms) {
+ public GetTransformResponse(List transformConfigurations,
+ int count,
+ @Nullable InvalidTransforms invalidTransforms) {
this.transformConfigurations = transformConfigurations;
this.count = count;
this.invalidTransforms = invalidTransforms;
@@ -80,7 +80,7 @@ public class GetDataFrameTransformResponse {
return count;
}
- public List getTransformConfigurations() {
+ public List getTransformConfigurations() {
return transformConfigurations;
}
@@ -99,7 +99,7 @@ public class GetDataFrameTransformResponse {
return false;
}
- final GetDataFrameTransformResponse that = (GetDataFrameTransformResponse) other;
+ final GetTransformResponse that = (GetTransformResponse) other;
return Objects.equals(this.transformConfigurations, that.transformConfigurations)
&& Objects.equals(this.count, that.count)
&& Objects.equals(this.invalidTransforms, that.invalidTransforms);
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformStatsRequest.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformStatsRequest.java
similarity index 88%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformStatsRequest.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformStatsRequest.java
index 579dd715cbc..d226d5c67bb 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformStatsRequest.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformStatsRequest.java
@@ -26,12 +26,12 @@ import org.elasticsearch.client.core.PageParams;
import java.util.Objects;
import java.util.Optional;
-public class GetDataFrameTransformStatsRequest implements Validatable {
+public class GetTransformStatsRequest implements Validatable {
private final String id;
private PageParams pageParams;
private Boolean allowNoMatch;
- public GetDataFrameTransformStatsRequest(String id) {
+ public GetTransformStatsRequest(String id) {
this.id = id;
}
@@ -59,7 +59,7 @@ public class GetDataFrameTransformStatsRequest implements Validatable {
public Optional validate() {
if (id == null) {
ValidationException validationException = new ValidationException();
- validationException.addValidationError("data frame transform id must not be null");
+ validationException.addValidationError("transform id must not be null");
return Optional.of(validationException);
} else {
return Optional.empty();
@@ -80,7 +80,7 @@ public class GetDataFrameTransformStatsRequest implements Validatable {
if (obj == null || getClass() != obj.getClass()) {
return false;
}
- GetDataFrameTransformStatsRequest other = (GetDataFrameTransformStatsRequest) obj;
+ GetTransformStatsRequest other = (GetTransformStatsRequest) obj;
return Objects.equals(id, other.id)
&& Objects.equals(pageParams, other.pageParams)
&& Objects.equals(allowNoMatch, other.allowNoMatch);
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformStatsResponse.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformStatsResponse.java
similarity index 78%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformStatsResponse.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformStatsResponse.java
index a1c4fc81974..4debe2ffd75 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetDataFrameTransformStatsResponse.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/GetTransformStatsResponse.java
@@ -21,7 +21,7 @@ package org.elasticsearch.client.transform;
import org.elasticsearch.ElasticsearchException;
import org.elasticsearch.action.TaskOperationFailure;
-import org.elasticsearch.client.transform.transforms.DataFrameTransformStats;
+import org.elasticsearch.client.transform.transforms.TransformStats;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.ParseField;
import org.elasticsearch.common.xcontent.ConstructingObjectParser;
@@ -34,19 +34,19 @@ import java.util.Objects;
import static org.elasticsearch.common.xcontent.ConstructingObjectParser.constructorArg;
import static org.elasticsearch.common.xcontent.ConstructingObjectParser.optionalConstructorArg;
-public class GetDataFrameTransformStatsResponse {
+public class GetTransformStatsResponse {
public static final ParseField TRANSFORMS = new ParseField("transforms");
public static final ParseField COUNT = new ParseField("count");
@SuppressWarnings("unchecked")
- static final ConstructingObjectParser PARSER = new ConstructingObjectParser<>(
- "get_data_frame_transform_stats_response", true,
- args -> new GetDataFrameTransformStatsResponse((List) args[0],
+ static final ConstructingObjectParser PARSER = new ConstructingObjectParser<>(
+ "get_transform_stats_response", true,
+ args -> new GetTransformStatsResponse((List) args[0],
(List) args[1], (List) args[2]));
static {
- PARSER.declareObjectArray(constructorArg(), DataFrameTransformStats.PARSER::apply, TRANSFORMS);
+ PARSER.declareObjectArray(constructorArg(), TransformStats.PARSER::apply, TRANSFORMS);
// Discard the count field which is the size of the transforms array
PARSER.declareInt((a, b) -> {}, COUNT);
PARSER.declareObjectArray(optionalConstructorArg(), (p, c) -> TaskOperationFailure.fromXContent(p),
@@ -55,15 +55,15 @@ public class GetDataFrameTransformStatsResponse {
AcknowledgedTasksResponse.NODE_FAILURES);
}
- public static GetDataFrameTransformStatsResponse fromXContent(final XContentParser parser) {
- return GetDataFrameTransformStatsResponse.PARSER.apply(parser, null);
+ public static GetTransformStatsResponse fromXContent(final XContentParser parser) {
+ return GetTransformStatsResponse.PARSER.apply(parser, null);
}
- private final List transformsStats;
+ private final List transformsStats;
private final List taskFailures;
private final List nodeFailures;
- public GetDataFrameTransformStatsResponse(List transformsStats,
+ public GetTransformStatsResponse(List transformsStats,
@Nullable List taskFailures,
@Nullable List extends ElasticsearchException> nodeFailures) {
this.transformsStats = transformsStats;
@@ -71,7 +71,7 @@ public class GetDataFrameTransformStatsResponse {
this.nodeFailures = nodeFailures == null ? Collections.emptyList() : Collections.unmodifiableList(nodeFailures);
}
- public List getTransformsStats() {
+ public List getTransformsStats() {
return transformsStats;
}
@@ -98,7 +98,7 @@ public class GetDataFrameTransformStatsResponse {
return false;
}
- final GetDataFrameTransformStatsResponse that = (GetDataFrameTransformStatsResponse) other;
+ final GetTransformStatsResponse that = (GetTransformStatsResponse) other;
return Objects.equals(this.transformsStats, that.transformsStats)
&& Objects.equals(this.nodeFailures, that.nodeFailures)
&& Objects.equals(this.taskFailures, that.taskFailures);
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewDataFrameTransformRequest.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewTransformRequest.java
similarity index 80%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewDataFrameTransformRequest.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewTransformRequest.java
index ab06ebfa4c9..4eba5c60aa7 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewDataFrameTransformRequest.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewTransformRequest.java
@@ -21,7 +21,7 @@ package org.elasticsearch.client.transform;
import org.elasticsearch.client.Validatable;
import org.elasticsearch.client.ValidationException;
-import org.elasticsearch.client.transform.transforms.DataFrameTransformConfig;
+import org.elasticsearch.client.transform.transforms.TransformConfig;
import org.elasticsearch.common.xcontent.ToXContent;
import org.elasticsearch.common.xcontent.ToXContentObject;
import org.elasticsearch.common.xcontent.XContentBuilder;
@@ -30,15 +30,15 @@ import java.io.IOException;
import java.util.Objects;
import java.util.Optional;
-public class PreviewDataFrameTransformRequest implements ToXContentObject, Validatable {
+public class PreviewTransformRequest implements ToXContentObject, Validatable {
- private final DataFrameTransformConfig config;
+ private final TransformConfig config;
- public PreviewDataFrameTransformRequest(DataFrameTransformConfig config) {
+ public PreviewTransformRequest(TransformConfig config) {
this.config = config;
}
- public DataFrameTransformConfig getConfig() {
+ public TransformConfig getConfig() {
return config;
}
@@ -51,11 +51,11 @@ public class PreviewDataFrameTransformRequest implements ToXContentObject, Valid
public Optional validate() {
ValidationException validationException = new ValidationException();
if (config == null) {
- validationException.addValidationError("preview requires a non-null data frame config");
+ validationException.addValidationError("preview requires a non-null transform config");
return Optional.of(validationException);
} else {
if (config.getSource() == null) {
- validationException.addValidationError("data frame transform source cannot be null");
+ validationException.addValidationError("transform source cannot be null");
}
}
@@ -79,7 +79,7 @@ public class PreviewDataFrameTransformRequest implements ToXContentObject, Valid
if (getClass() != obj.getClass()) {
return false;
}
- PreviewDataFrameTransformRequest other = (PreviewDataFrameTransformRequest) obj;
+ PreviewTransformRequest other = (PreviewTransformRequest) obj;
return Objects.equals(config, other.config);
}
}
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewDataFrameTransformResponse.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewTransformResponse.java
similarity index 80%
rename from client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewDataFrameTransformResponse.java
rename to client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewTransformResponse.java
index 9f7cd2b313a..215d529f949 100644
--- a/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewDataFrameTransformResponse.java
+++ b/client/rest-high-level/src/main/java/org/elasticsearch/client/transform/PreviewTransformResponse.java
@@ -26,23 +26,23 @@ import java.util.List;
import java.util.Map;
import java.util.Objects;
-public class PreviewDataFrameTransformResponse {
+public class PreviewTransformResponse {
private static final String PREVIEW = "preview";
private static final String MAPPINGS = "mappings";
@SuppressWarnings("unchecked")
- public static PreviewDataFrameTransformResponse fromXContent(final XContentParser parser) throws IOException {
+ public static PreviewTransformResponse fromXContent(final XContentParser parser) throws IOException {
Map previewMap = parser.mapOrdered();
Object previewDocs = previewMap.get(PREVIEW);
Object mappings = previewMap.get(MAPPINGS);
- return new PreviewDataFrameTransformResponse((List