CDM-54 reinstate DiffPartitionsFrom File

Author: mieslep

src/main/scala/com/datastax/cdm/job/DiffPartitionsFromFile.scala

@@ -0,0 +1,19 @@
+package com.datastax.cdm.job
+
+object DiffPartitionsFromFile extends BasePartitionJob {
+  setup("Diff Partitions from File Job", new DiffJobSessionFactory(), "./partitions.csv")
+  execute()
+  finish()
+
+  override def execute(): Unit = {
+    slices.foreach(slice => {
+      originConnection.withSessionDo(sourceSession =>
+        targetConnection.withSessionDo(destinationSession =>
+          jobFactory.getInstance(sourceSession, destinationSession, sc)
+            .processSlice(slice)))
+    })
+  }
+}
+
+
+