Refactoring changes

Author: faizalrub-datastax

src/main/java/datastax/astra/migrate/AbstractJobSession.java

@@ -69,7 +69,7 @@ protected AbstractJobSession(CqlSession sourceSession, CqlSession astraSession,
         }
 
         String customWriteTimeStr =
-                sparkConf.get("spark.migrate.custom.writeTime", "0");
+                sparkConf.get("spark.destination.custom.writeTime", "0");
         if (null != customWriteTimeStr && customWriteTimeStr.trim().length() > 1) {
             customWritetime = Long.parseLong(customWriteTimeStr);
         }

src/resources/sparkConf.properties

@@ -42,7 +42,8 @@ spark.source.writeTimeStampFilter                       false
 spark.source.writeTimeStampFilter.cols                  4,5
 spark.source.minWriteTimeStampFilter                    0
 spark.source.maxWriteTimeStampFilter                    9223372036854775807
-spark.migrate.custom.writeTime 				            1664980600000000
+
+spark.destination.custom.writeTime 			            1664980600000000
 
 ########################## ONLY USE if SSL clientAuth is enabled on source Cassandra/DSE ###############################
 #spark.source.trustStore.path
@@ -91,7 +92,7 @@ spark.migrate.custom.writeTime 				            1664980600000000
 # "spark.source.writeTimeStampFilter.cols" - Comma separated column indexes from "spark.query.cols.select".
 #  Script will only use the largest value per row.
 #
-# "spark.migrate.custom.writeTime" - User specified write time. When set it will be used as writetime for target writes.
+# "spark.destination.custom.writeTime" - User specified write time. When set it will be used as writetime for target writes.
 #
 # Default value for "spark.source.maxWriteTimeStampFilter" is alway "9223372036854775807" (max long value)
 #