Update schema to use clustering key

yifan-c · yifan-c · commit 46d49e0d83a2 · 2026-03-23T13:04:09.000-07:00
diff --git a/cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/TestUtils.java b/cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/TestUtils.java
@@ -54,7 +54,7 @@ public final class TestUtils
      * read repairs.
      */
     public static final String CREATE_TEST_TABLE_STATEMENT =
-    "CREATE TABLE IF NOT EXISTS %s (id int, course text, marks int, PRIMARY KEY (id)) WITH read_repair='NONE';";
+    "CREATE TABLE IF NOT EXISTS %s (id int, course text, marks int, PRIMARY KEY (id, course)) WITH read_repair='NONE';";
 
     private TestUtils()
     {

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ public final class TestUtils`
`54`	`54`	`* read repairs.`
`55`	`55`	`*/`
`56`	`56`	`public static final String CREATE_TEST_TABLE_STATEMENT =`
`57`		`- "CREATE TABLE IF NOT EXISTS %s (id int, course text, marks int, PRIMARY KEY (id)) WITH read_repair='NONE';";`
	`57`	`+ "CREATE TABLE IF NOT EXISTS %s (id int, course text, marks int, PRIMARY KEY (id, course)) WITH read_repair='NONE';";`
`58`	`58`
`59`	`59`	`private TestUtils()`
`60`	`60`	`{`