refactor: delete KMeansOperatorV1

Author: joker-star-l

wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels/SingleObjectChannel.java

@@ -68,9 +68,7 @@ public class Mappings {
             new KMeansMapping(),
             new LinearRegressionMapping(),
             new DecisionTreeClassificationMapping(),
-            new ModelTransformMapping(),
-
-            new KMeansMappingV1()
+            new ModelTransformMapping()
     );
 
 }

wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KMeansOperatorV1.java

@@ -25,7 +25,6 @@
 import org.apache.wayang.java.channels.CollectionChannel;
 import org.apache.wayang.spark.channels.RddChannel;
 import org.apache.wayang.spark.operators.ml.SparkKMeansOperator;
-import org.apache.wayang.spark.operators.ml.SparkKMeansOperatorV1;
 import org.apache.wayang.spark.operators.ml.SparkModelTransformOperator;
 import org.junit.Assert;
 import org.junit.Test;
@@ -97,28 +96,4 @@ public void testInference() {
                 results.get(2).field1
         );
     }
-
-    @Test
-    public void testExecutionV1() {
-        // Prepare test data.
-        RddChannel.Instance input = this.createRddChannelInstance(data);
-        RddChannel.Instance output = this.createRddChannelInstance();
-
-        SparkKMeansOperatorV1 kMeansOperator = new SparkKMeansOperatorV1(2);
-
-        // Set up the ChannelInstances.
-        ChannelInstance[] inputs = new ChannelInstance[]{input};
-        ChannelInstance[] outputs = new ChannelInstance[]{output};
-
-        // Execute.
-        this.evaluate(kMeansOperator, inputs, outputs);
-
-        // Verify the outcome.
-        final List<Tuple2<double[], Integer>> results = output.<Tuple2<double[], Integer>>provideRdd().collect();
-        Assert.assertEquals(3, results.size());
-        Assert.assertEquals(
-                results.get(0).field1,
-                results.get(2).field1
-        );
-    }
 }