// Path: src/test/java/com/thoughtworks/datacommons/prepbuddy/api/JavaSparkTestCase.java
// public class JavaSparkTestCase implements Serializable {
//     protected transient JavaSparkContext javaSparkContext;
// 
//     @Before
//     public void setUp() throws Exception {
//         SparkConf sparkConf = new SparkConf().setAppName(getClass().getName()).setMaster("local");
//         Logger.getLogger("org").setLevel(Level.OFF);
//         Logger.getLogger("akka").setLevel(Level.OFF);
//         javaSparkContext = new JavaSparkContext(sparkConf);
//     }
// 
//     @After
//     public void tearDown() throws Exception {
//         javaSparkContext.close();
//     }
// }
// 
// Path: src/main/scala/com/thoughtworks/datacommons/prepbuddy/api/java/types/FileType.java
// public class FileType {
//     public static final com.thoughtworks.datacommons.prepbuddy.types.FileType CSV = CSV$.MODULE$;
//     public static final com.thoughtworks.datacommons.prepbuddy.types.FileType TSV = TSV$.MODULE$;
// }


import com.thoughtworks.datacommons.prepbuddy.api.JavaSparkTestCase;
import com.thoughtworks.datacommons.prepbuddy.api.java.types.FileType;
import com.thoughtworks.datacommons.prepbuddy.clusterers.LevenshteinDistance;
import com.thoughtworks.datacommons.prepbuddy.clusterers.NGramFingerprintAlgorithm;
import com.thoughtworks.datacommons.prepbuddy.clusterers.SimpleFingerprintAlgorithm;
import org.apache.spark.api.java.JavaRDD;
import org.junit.Test;
import scala.Tuple2;
import java.util.Arrays;
import java.util.List;
import static org.junit.Assert.*;
package com.thoughtworks.datacommons.prepbuddy.api.java;




public class JavaClusterTest extends JavaSparkTestCase {
    @Test
    public void shouldGiveClusterOfSimilarColumnValues() {
        JavaRDD<String> initialDataset = javaSparkContext.parallelize(Arrays.asList("CLUSTER Of Finger print", "finger print of cluster", "finger print for cluster"));
// Path: src/test/java/com/thoughtworks/datacommons/prepbuddy/api/JavaSparkTestCase.java
// public class JavaSparkTestCase implements Serializable {
//     protected transient JavaSparkContext javaSparkContext;
// 
//     @Before
//     public void setUp() throws Exception {
//         SparkConf sparkConf = new SparkConf().setAppName(getClass().getName()).setMaster("local");
//         Logger.getLogger("org").setLevel(Level.OFF);
//         Logger.getLogger("akka").setLevel(Level.OFF);
//         javaSparkContext = new JavaSparkContext(sparkConf);
//     }
// 
//     @After
//     public void tearDown() throws Exception {
//         javaSparkContext.close();
//     }
// }
// 
// Path: src/main/scala/com/thoughtworks/datacommons/prepbuddy/api/java/types/FileType.java
// public class FileType {
//     public static final com.thoughtworks.datacommons.prepbuddy.types.FileType CSV = CSV$.MODULE$;
//     public static final com.thoughtworks.datacommons.prepbuddy.types.FileType TSV = TSV$.MODULE$;
// }


// Path: src/test/java/com/thoughtworks/datacommons/prepbuddy/api/java/JavaClusterTest.java
import com.thoughtworks.datacommons.prepbuddy.api.JavaSparkTestCase;
import com.thoughtworks.datacommons.prepbuddy.api.java.types.FileType;
import com.thoughtworks.datacommons.prepbuddy.clusterers.LevenshteinDistance;
import com.thoughtworks.datacommons.prepbuddy.clusterers.NGramFingerprintAlgorithm;
import com.thoughtworks.datacommons.prepbuddy.clusterers.SimpleFingerprintAlgorithm;
import org.apache.spark.api.java.JavaRDD;
import org.junit.Test;
import scala.Tuple2;
import java.util.Arrays;
import java.util.List;
import static org.junit.Assert.*;

package com.thoughtworks.datacommons.prepbuddy.api.java;




public class JavaClusterTest extends JavaSparkTestCase {
    @Test
    public void shouldGiveClusterOfSimilarColumnValues() {
        JavaRDD<String> initialDataset = javaSparkContext.parallelize(Arrays.asList("CLUSTER Of Finger print", "finger print of cluster", "finger print for cluster"));
        JavaTransformableRDD initialRDD = new JavaTransformableRDD(initialDataset, FileType.CSV);