CDM-88 Added the cdm namespace

pravinbhat · pravinbhat · commit da1a4cfd32dd · 2023-06-29T09:24:24.000-04:00
diff --git a/SIT/features/06_partition_range/migrate_with_partitionfile.properties b/SIT/features/06_partition_range/migrate_with_partitionfile.properties
@@ -8,5 +8,5 @@ spark.cdm.perfops.numParts                        1
 spark.cdm.autocorrect.missing                     true
 spark.cdm.autocorrect.mismatch                    true
 
-spark.tokenrange.partitionFile                    ./partitions.csv
+spark.cdm.tokenrange.partitionFile                    ./partitions.csv
 
diff --git a/SIT/features/07_migrate_rows/migrate_with_pkrowsfile.properties b/SIT/features/07_migrate_rows/migrate_with_pkrowsfile.properties
@@ -5,4 +5,4 @@ spark.cdm.schema.origin.keyspaceTable             origin.feature_migrate_rows
 spark.cdm.schema.target.keyspaceTable             target.feature_migrate_rows
 spark.cdm.perfops.numParts                        1
 
-spark.tokenrange.partitionFile                    ./primary_key_rows.csv
+spark.cdm.tokenrange.partitionFile                    ./primary_key_rows.csv
diff --git a/src/main/java/com/datastax/cdm/properties/KnownProperties.java b/src/main/java/com/datastax/cdm/properties/KnownProperties.java
@@ -136,7 +136,7 @@ public enum PropertyType {
     //==========================================================================
     // Error handling
     //==========================================================================
-    public static final String TOKEN_RANGE_PARTITION_FILE = "spark.tokenrange.partitionFile";
+    public static final String TOKEN_RANGE_PARTITION_FILE = "spark.cdm.tokenrange.partitionFile";
     static {
         types.put(TOKEN_RANGE_PARTITION_FILE, PropertyType.STRING);
     }

Original file line number	Diff line number	Diff line change
`@@ -136,7 +136,7 @@ public enum PropertyType {`
`136`	`136`	`//==========================================================================`
`137`	`137`	`// Error handling`
`138`	`138`	`//==========================================================================`
`139`		`- public static final String TOKEN_RANGE_PARTITION_FILE = "spark.tokenrange.partitionFile";`
	`139`	`+ public static final String TOKEN_RANGE_PARTITION_FILE = "spark.cdm.tokenrange.partitionFile";`
`140`	`140`	`static {`
`141`	`141`	`types.put(TOKEN_RANGE_PARTITION_FILE, PropertyType.STRING);`
`142`	`142`	`}`