[Transform] Rename data frame plugin to transform: classes in xpack.c…

…ore (#46644) rename classes in xpack.core of transform plugin from "data frame transform" to "transform"
elastic · Sep 15, 2019 · de17140 · de17140
1 parent 3f18cf7
commit de17140
Show file tree

Hide file tree

Showing 148 changed files with 1,862 additions and 1,862 deletions.
diff --git a/...ava/org/elasticsearch/client/transform/transforms/hlrc/DataFrameIndexerPositionTests.java b/...ava/org/elasticsearch/client/transform/transforms/hlrc/DataFrameIndexerPositionTests.java
@@ -22,31 +22,31 @@
 import org.elasticsearch.client.AbstractResponseTestCase;
 import org.elasticsearch.common.xcontent.XContentParser;
 import org.elasticsearch.common.xcontent.XContentType;
-import org.elasticsearch.xpack.core.transform.transforms.DataFrameIndexerPosition;
+import org.elasticsearch.xpack.core.transform.transforms.TransformIndexerPosition;
 
 import java.util.LinkedHashMap;
 import java.util.Map;
 
 import static org.hamcrest.Matchers.equalTo;
 
 public class DataFrameIndexerPositionTests extends AbstractResponseTestCase<
-        DataFrameIndexerPosition,
+        TransformIndexerPosition,
         org.elasticsearch.client.transform.transforms.DataFrameIndexerPosition> {
 
-    public static DataFrameIndexerPosition fromHlrc(
+    public static TransformIndexerPosition fromHlrc(
             org.elasticsearch.client.transform.transforms.DataFrameIndexerPosition instance) {
         if (instance == null) {
             return null;
         }
-        return new DataFrameIndexerPosition(instance.getIndexerPosition(), instance.getBucketsPosition());
+        return new TransformIndexerPosition(instance.getIndexerPosition(), instance.getBucketsPosition());
     }
 
-    public static DataFrameIndexerPosition randomDataFrameIndexerPosition() {
-        return new DataFrameIndexerPosition(randomPositionMap(), randomPositionMap());
+    public static TransformIndexerPosition randomDataFrameIndexerPosition() {
+        return new TransformIndexerPosition(randomPositionMap(), randomPositionMap());
     }
 
     @Override
-    protected DataFrameIndexerPosition createServerTestInstance(XContentType xContentType) {
+    protected TransformIndexerPosition createServerTestInstance(XContentType xContentType) {
         return randomDataFrameIndexerPosition();
     }
 
@@ -56,7 +56,7 @@ protected org.elasticsearch.client.transform.transforms.DataFrameIndexerPosition
     }
 
     @Override
-    protected void assertInstances(DataFrameIndexerPosition serverTestInstance,
+    protected void assertInstances(TransformIndexerPosition serverTestInstance,
                                    org.elasticsearch.client.transform.transforms.DataFrameIndexerPosition clientInstance) {
         assertThat(serverTestInstance.getIndexerPosition(), equalTo(clientInstance.getIndexerPosition()));
         assertThat(serverTestInstance.getBucketsPosition(), equalTo(clientInstance.getBucketsPosition()));

diff --git a/...g/elasticsearch/client/transform/transforms/hlrc/DataFrameIndexerTransformStatsTests.java b/...g/elasticsearch/client/transform/transforms/hlrc/DataFrameIndexerTransformStatsTests.java
@@ -21,17 +21,17 @@
 
 import org.elasticsearch.client.AbstractHlrcXContentTestCase;
 import org.elasticsearch.common.xcontent.XContentParser;
-import org.elasticsearch.xpack.core.transform.transforms.DataFrameIndexerTransformStats;
+import org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats;
 
 import java.io.IOException;
 
 public class DataFrameIndexerTransformStatsTests extends AbstractHlrcXContentTestCase<
-        DataFrameIndexerTransformStats,
+        TransformIndexerStats,
         org.elasticsearch.client.transform.transforms.DataFrameIndexerTransformStats> {
 
-    public static DataFrameIndexerTransformStats fromHlrc(
+    public static TransformIndexerStats fromHlrc(
             org.elasticsearch.client.transform.transforms.DataFrameIndexerTransformStats instance) {
-        return new DataFrameIndexerTransformStats(
+        return new TransformIndexerStats(
             instance.getNumPages(),
             instance.getNumDocuments(),
             instance.getOutputDocuments(),
@@ -54,13 +54,13 @@ public org.elasticsearch.client.transform.transforms.DataFrameIndexerTransformSt
     }
 
     @Override
-    public DataFrameIndexerTransformStats convertHlrcToInternal(
+    public TransformIndexerStats convertHlrcToInternal(
             org.elasticsearch.client.transform.transforms.DataFrameIndexerTransformStats instance) {
         return fromHlrc(instance);
     }
 
-    public static DataFrameIndexerTransformStats randomStats() {
-        return new DataFrameIndexerTransformStats(randomLongBetween(10L, 10000L),
+    public static TransformIndexerStats randomStats() {
+        return new TransformIndexerStats(randomLongBetween(10L, 10000L),
             randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L),
             randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L),
             randomLongBetween(0L, 10000L),
@@ -70,13 +70,13 @@ public static DataFrameIndexerTransformStats randomStats() {
     }
 
     @Override
-    protected DataFrameIndexerTransformStats createTestInstance() {
+    protected TransformIndexerStats createTestInstance() {
         return randomStats();
     }
 
     @Override
-    protected DataFrameIndexerTransformStats doParseInstance(XContentParser parser) throws IOException {
-        return DataFrameIndexerTransformStats.fromXContent(parser);
+    protected TransformIndexerStats doParseInstance(XContentParser parser) throws IOException {
+        return TransformIndexerStats.fromXContent(parser);
     }
 
     @Override

diff --git a/...lasticsearch/client/transform/transforms/hlrc/DataFrameTransformCheckpointStatsTests.java b/...lasticsearch/client/transform/transforms/hlrc/DataFrameTransformCheckpointStatsTests.java
@@ -22,34 +22,34 @@
 import org.elasticsearch.client.AbstractResponseTestCase;
 import org.elasticsearch.common.xcontent.XContentParser;
 import org.elasticsearch.common.xcontent.XContentType;
-import org.elasticsearch.xpack.core.transform.transforms.DataFrameTransformCheckpointStats;
+import org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointStats;
 
 import java.io.IOException;
 
 import static org.hamcrest.Matchers.equalTo;
 
 public class DataFrameTransformCheckpointStatsTests extends AbstractResponseTestCase<
-        DataFrameTransformCheckpointStats,
+        TransformCheckpointStats,
         org.elasticsearch.client.transform.transforms.DataFrameTransformCheckpointStats> {
 
-    public static DataFrameTransformCheckpointStats fromHlrc(
+    public static TransformCheckpointStats fromHlrc(
             org.elasticsearch.client.transform.transforms.DataFrameTransformCheckpointStats instance) {
-        return new DataFrameTransformCheckpointStats(instance.getCheckpoint(),
+        return new TransformCheckpointStats(instance.getCheckpoint(),
             DataFrameIndexerPositionTests.fromHlrc(instance.getPosition()),
             DataFrameTransformProgressTests.fromHlrc(instance.getCheckpointProgress()),
             instance.getTimestampMillis(),
             instance.getTimeUpperBoundMillis());
     }
 
-    public static DataFrameTransformCheckpointStats randomDataFrameTransformCheckpointStats() {
-        return new DataFrameTransformCheckpointStats(randomLongBetween(1, 1_000_000),
+    public static TransformCheckpointStats randomDataFrameTransformCheckpointStats() {
+        return new TransformCheckpointStats(randomLongBetween(1, 1_000_000),
             DataFrameIndexerPositionTests.randomDataFrameIndexerPosition(),
             randomBoolean() ? null : DataFrameTransformProgressTests.randomDataFrameTransformProgress(),
             randomLongBetween(1, 1_000_000), randomLongBetween(0, 1_000_000));
     }
 
     @Override
-    protected DataFrameTransformCheckpointStats createServerTestInstance(XContentType xContentType) {
+    protected TransformCheckpointStats createServerTestInstance(XContentType xContentType) {
         return randomDataFrameTransformCheckpointStats();
     }
 
@@ -60,7 +60,7 @@ protected org.elasticsearch.client.transform.transforms.DataFrameTransformCheckp
     }
 
     @Override
-    protected void assertInstances(DataFrameTransformCheckpointStats serverTestInstance,
+    protected void assertInstances(TransformCheckpointStats serverTestInstance,
                                    org.elasticsearch.client.transform.transforms.DataFrameTransformCheckpointStats clientInstance) {
         assertThat(serverTestInstance.getCheckpoint(), equalTo(clientInstance.getCheckpoint()));
         assertThat(serverTestInstance.getPosition().getBucketsPosition(), equalTo(clientInstance.getPosition().getBucketsPosition()));

diff --git a/...sticsearch/client/transform/transforms/hlrc/DataFrameTransformCheckpointingInfoTests.java b/...sticsearch/client/transform/transforms/hlrc/DataFrameTransformCheckpointingInfoTests.java
@@ -21,19 +21,19 @@
 
 import org.elasticsearch.client.AbstractHlrcXContentTestCase;
 import org.elasticsearch.common.xcontent.XContentParser;
-import org.elasticsearch.xpack.core.transform.transforms.DataFrameTransformCheckpointingInfo;
+import org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo;
 
 import java.io.IOException;
 import java.time.Instant;
 import java.util.function.Predicate;
 
 public class DataFrameTransformCheckpointingInfoTests extends AbstractHlrcXContentTestCase<
-        DataFrameTransformCheckpointingInfo,
+        TransformCheckpointingInfo,
         org.elasticsearch.client.transform.transforms.DataFrameTransformCheckpointingInfo> {
 
-    public static DataFrameTransformCheckpointingInfo fromHlrc(
+    public static TransformCheckpointingInfo fromHlrc(
             org.elasticsearch.client.transform.transforms.DataFrameTransformCheckpointingInfo instance) {
-        return new DataFrameTransformCheckpointingInfo(
+        return new TransformCheckpointingInfo(
             DataFrameTransformCheckpointStatsTests.fromHlrc(instance.getLast()),
             DataFrameTransformCheckpointStatsTests.fromHlrc(instance.getNext()),
             instance.getOperationsBehind(),
@@ -46,27 +46,27 @@ public org.elasticsearch.client.transform.transforms.DataFrameTransformCheckpoin
     }
 
     @Override
-    public DataFrameTransformCheckpointingInfo convertHlrcToInternal(
+    public TransformCheckpointingInfo convertHlrcToInternal(
             org.elasticsearch.client.transform.transforms.DataFrameTransformCheckpointingInfo instance) {
         return fromHlrc(instance);
     }
 
-    public static DataFrameTransformCheckpointingInfo randomDataFrameTransformCheckpointingInfo() {
-        return new DataFrameTransformCheckpointingInfo(
+    public static TransformCheckpointingInfo randomDataFrameTransformCheckpointingInfo() {
+        return new TransformCheckpointingInfo(
             DataFrameTransformCheckpointStatsTests.randomDataFrameTransformCheckpointStats(),
             DataFrameTransformCheckpointStatsTests.randomDataFrameTransformCheckpointStats(),
             randomNonNegativeLong(),
             randomBoolean() ? null : Instant.ofEpochMilli(randomNonNegativeLong()));
     }
 
     @Override
-    protected DataFrameTransformCheckpointingInfo createTestInstance() {
+    protected TransformCheckpointingInfo createTestInstance() {
         return randomDataFrameTransformCheckpointingInfo();
     }
 
     @Override
-    protected DataFrameTransformCheckpointingInfo doParseInstance(XContentParser parser) throws IOException {
-        return DataFrameTransformCheckpointingInfo.fromXContent(parser);
+    protected TransformCheckpointingInfo doParseInstance(XContentParser parser) throws IOException {
+        return TransformCheckpointingInfo.fromXContent(parser);
     }
 
     @Override

diff --git a/...a/org/elasticsearch/client/transform/transforms/hlrc/DataFrameTransformProgressTests.java b/...a/org/elasticsearch/client/transform/transforms/hlrc/DataFrameTransformProgressTests.java
@@ -22,37 +22,37 @@
 import org.elasticsearch.client.AbstractResponseTestCase;
 import org.elasticsearch.common.xcontent.XContentParser;
 import org.elasticsearch.common.xcontent.XContentType;
-import org.elasticsearch.xpack.core.transform.transforms.DataFrameTransformProgress;
+import org.elasticsearch.xpack.core.transform.transforms.TransformProgress;
 
 import static org.hamcrest.Matchers.equalTo;
 
 public class DataFrameTransformProgressTests extends AbstractResponseTestCase<
-        DataFrameTransformProgress,
+        TransformProgress,
         org.elasticsearch.client.transform.transforms.DataFrameTransformProgress> {
 
-    public static DataFrameTransformProgress fromHlrc(
+    public static TransformProgress fromHlrc(
             org.elasticsearch.client.transform.transforms.DataFrameTransformProgress instance) {
         if (instance == null) {
             return null;
         }
-        return new DataFrameTransformProgress(instance.getTotalDocs(),
+        return new TransformProgress(instance.getTotalDocs(),
             instance.getRemainingDocs(),
             instance.getDocumentsProcessed(),
             instance.getDocumentsIndexed());
     }
 
-    public static DataFrameTransformProgress randomDataFrameTransformProgress() {
+    public static TransformProgress randomDataFrameTransformProgress() {
         Long totalDocs = randomBoolean() ? null : randomNonNegativeLong();
         Long docsRemaining = totalDocs != null ? randomLongBetween(0, totalDocs) : null;
-        return new DataFrameTransformProgress(
+        return new TransformProgress(
             totalDocs,
             docsRemaining,
             totalDocs != null ? totalDocs - docsRemaining : randomNonNegativeLong(),
             randomBoolean() ? null : randomNonNegativeLong());
     }
 
     @Override
-    protected DataFrameTransformProgress createServerTestInstance(XContentType xContentType) {
+    protected TransformProgress createServerTestInstance(XContentType xContentType) {
         return randomDataFrameTransformProgress();
     }
 
@@ -62,7 +62,7 @@ protected org.elasticsearch.client.transform.transforms.DataFrameTransformProgre
     }
 
     @Override
-    protected void assertInstances(DataFrameTransformProgress serverTestInstance,
+    protected void assertInstances(TransformProgress serverTestInstance,
                                    org.elasticsearch.client.transform.transforms.DataFrameTransformProgress clientInstance) {
         assertThat(serverTestInstance.getTotalDocs(), equalTo(clientInstance.getTotalDocs()));
         assertThat(serverTestInstance.getDocumentsProcessed(), equalTo(clientInstance.getDocumentsProcessed()));