removed source refs from config and code

Author: mfmaher2

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

@@ -46,23 +46,23 @@ protected OriginCountJobSession(CqlSession sourceSession, SparkConf sparkConf) {
         }
 
         readLimiter = RateLimiter.create(new Integer(sparkConf.get("spark.readRateLimit", "20000")));
-        sourceKeyspaceTable = sparkConf.get("spark.source.keyspaceTable");
+        sourceKeyspaceTable = sparkConf.get("spark.origin.keyspaceTable");
 
-        hasRandomPartitioner = Boolean.parseBoolean(sparkConf.get("spark.source.hasRandomPartitioner", "false"));
-        isCounterTable = Boolean.parseBoolean(sparkConf.get("spark.source.counterTable", "false"));
+        hasRandomPartitioner = Boolean.parseBoolean(sparkConf.get("spark.origin.hasRandomPartitioner", "false"));
+        isCounterTable = Boolean.parseBoolean(sparkConf.get("spark.counterTable", "false"));
 
-        checkTableforColSize = Boolean.parseBoolean(sparkConf.get("spark.source.checkTableforColSize", "false"));
-        checkTableforselectCols = sparkConf.get("spark.source.checkTableforColSize.cols");
-        checkTableforColSizeTypes = getTypes(sparkConf.get("spark.source.checkTableforColSize.cols.types"));
-        filterColName = sparkConf.get("spark.source.FilterColumn");
-        filterColType = sparkConf.get("spark.source.FilterColumnType");
-        filterColIndex =  Integer.parseInt(sparkConf.get("spark.source.FilterColumnIndex", "0"));
+        checkTableforColSize = Boolean.parseBoolean(sparkConf.get("spark.origin.checkTableforColSize", "false"));
+        checkTableforselectCols = sparkConf.get("spark.origin.checkTableforColSize.cols");
+        checkTableforColSizeTypes = getTypes(sparkConf.get("spark.origin.checkTableforColSize.cols.types"));
+        filterColName = sparkConf.get("spark.origin.FilterColumn");
+        filterColType = sparkConf.get("spark.origin.FilterColumnType");
+        filterColIndex =  Integer.parseInt(sparkConf.get("spark.origin.FilterColumnIndex", "0"));
 
         String partionKey = sparkConf.get("spark.query.cols.partitionKey");
         idColTypes = getTypes(sparkConf.get("spark.query.cols.id.types"));
 
         String selectCols = sparkConf.get("spark.query.cols.select");
-        String updateSelectMappingStr = sparkConf.get("spark.source.counterTable.update.select.index", "0");
+        String updateSelectMappingStr = sparkConf.get("spark.counterTable.cql.index", "0");
         for (String updateSelectIndex : updateSelectMappingStr.split(",")) {
             updateSelectMapping.add(Integer.parseInt(updateSelectIndex));
         }

src/resources/sparkConf.properties

@@ -4,12 +4,12 @@ spark.origin.username                             some-username
 spark.origin.password                             some-secret-password
 spark.origin.read.consistency.level               LOCAL_QUORUM
 spark.origin.keyspaceTable                        test.a1
-spark.source.checkTableforColSize                 false
-spark.source.checkTableforColSize.cols            partition-key,clustering-key
-spark.source.checkTableforColSize.cols.types      9,1
-spark.source.FilterColumn                         test
-spark.source.FilterColumnIndex                    2
-spark.source.FilterColumnType                     6%16
+spark.origin.checkTableforColSize                 false
+spark.origin.checkTableforColSize.cols            partition-key,clustering-key
+spark.origin.checkTableforColSize.cols.types      9,1
+spark.origin.FilterColumn                         test
+spark.origin.FilterColumnIndex                    2
+spark.origin.FilterColumnType                     6%16
 
 spark.target.isAstra                              true
 spark.target.scb                                  file:///aaa/bbb/secure-connect-enterprise.zip