Removed job MigrateRowsFromFile which was earlier used to load PK rec…

…ords from a file, search them in origin & Migrate those to Target.

The file with PK records was generated with the PK validation errors found.
However this feature is no longer needed with many advanced features like validation auto-correct, rerun migration/validation only on token-ranges with diff, etc.

src/main/java/com/datastax/cdm/job/SplitPartitions.java

@@ -27,7 +27,6 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.regex.Pattern;
-import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 import java.util.stream.Stream;
 
@@ -94,25 +93,6 @@ public PartitionMinMax(String line) {
         }
     }
 
-    public static List<PKRows> getRowPartsFromFile(int numSplits, String inputFilename) throws IOException {
-        logger.info("ThreadID: {} Splitting rows in file: {} using a split-size of {}"
-                , Thread.currentThread().getId(), inputFilename, numSplits);
-        List<String> pkRows = new ArrayList<String>();
-        BufferedReader reader = getfileReader(inputFilename);
-        String pkRow = null;
-        while ((pkRow = reader.readLine()) != null) {
-            if (pkRow.startsWith("#")) {
-                continue;
-            }
-            pkRows.add(pkRow);
-        }
-        int partSize = pkRows.size() / numSplits;
-        if (partSize == 0) {
-            partSize = pkRows.size();
-        }
-        return batches(pkRows, partSize).map(l -> (new PKRows(l))).collect(Collectors.toList());
-    }
-
     public static <T> Stream<List<T>> batches(List<T> source, int length) {
         if (length <= 0)
             throw new IllegalArgumentException("length = " + length);
@@ -188,19 +168,6 @@ public static String getPartitionFileOutput(PropertyHelper propertyHelper) {
         return "./" + propertyHelper.getString(KnownProperties.ORIGIN_KEYSPACE_TABLE) + "_partitions.csv";
     }
 
-    public static class PKRows implements Serializable {
-        private static final long serialVersionUID = 1L;
-        private List<String> pkRows;
-
-        public List<String> getPkRows() {
-            return pkRows;
-        }
-
-        public PKRows(List<String> rows) {
-            pkRows = new ArrayList<>(rows);
-        }
-    }
-
     public static class Partition implements Serializable {
         private static final long serialVersionUID = 1L;