Merge pull request #155 from weideng1/master

added astra-specific schema support for Astra or DSE with guardrail

driver-cql-shaded/src/main/resources/activities/baselines/cql-iot.yaml

@@ -7,6 +7,10 @@ scenarios:
     - run driver=cql tags==phase:schema threads==1 cycles==UNDEF
     - run driver=cql tags==phase:rampup cycles===TEMPLATE(rampup-cycles,10000000) threads=auto
     - run driver=cql tags==phase:main cycles===TEMPLATE(main-cycles,10000000) threads=auto
+  astra:
+    - run driver=cql tags==phase:schema-astra threads==1 cycles==UNDEF
+    - run driver=cql tags==phase:rampup cycles===TEMPLATE(rampup-cycles,10000000) threads=auto
+    - run driver=cql tags==phase:main cycles===TEMPLATE(main-cycles,10000000) threads=auto      
 params:
   instrument: TEMPLATE(instrument,false)
 bindings:
@@ -51,6 +55,23 @@ blocks:
          truncate table <<keyspace:baselines>>.<<table:iot>>;
        tags:
          name: truncate-table
+  - tags:
+      phase: schema-astra
+    params:
+      prepared: false
+    statements:
+     - create-table-astra : |
+        create table if not exists <<keyspace:baselines>>.<<table:iot>> (
+        machine_id UUID,     // source machine
+        sensor_name text,    // sensor name
+        time timestamp,      // timestamp of collection
+        sensor_value double, //
+        station_id UUID,     // source location
+        data text,
+        PRIMARY KEY ((machine_id, sensor_name), time)
+        ) WITH CLUSTERING ORDER BY (time DESC);
+       tags:
+         name: create-table-astra
   - tags:
       phase: rampup
     params:

driver-cql-shaded/src/main/resources/activities/baselines/cql-keyvalue.yaml

@@ -4,6 +4,10 @@ scenarios:
     - run driver=cql tags==phase:schema threads==1 cycles==UNDEF
     - run driver=cql tags==phase:rampup cycles===TEMPLATE(rampup-cycles,10000000) threads=auto
     - run driver=cql tags==phase:main cycles===TEMPLATE(main-cycles,10000000) threads=auto
+  astra:
+    - run driver=cql tags==phase:schema-astra threads==1 cycles==UNDEF
+    - run driver=cql tags==phase:rampup cycles===TEMPLATE(rampup-cycles,10000000) threads=auto
+    - run driver=cql tags==phase:main cycles===TEMPLATE(main-cycles,10000000) threads=auto
 bindings:
   seq_key: Mod(<<keycount:1000000000>>); ToString() -> String
   seq_value: Hash(); Mod(<<valuecount:1000000000>>); ToString() -> String
@@ -31,6 +35,20 @@ blocks:
         );
       tags:
         name: create-table
+  - name: schema-astra
+    tags:
+      phase: schema-astra
+    params:
+      prepared: false
+    statements:
+    - create-table: |
+        create table if not exists <<keyspace:baselines>>.<<table:keyvalue>> (
+        key text,
+         value text,
+         PRIMARY KEY (key)
+        );
+      tags:
+        name: create-table-astra
   - name: rampup
     tags:
       phase: rampup

driver-cql-shaded/src/main/resources/activities/baselines/cql-tabular.yaml

@@ -4,6 +4,10 @@ scenarios:
     - run driver=cql tags==phase:schema threads==1 cycles==UNDEF
     - run driver=cql tags==phase:rampup cycles===TEMPLATE(rampup-cycles,10000000) threads=auto
     - run driver=cql tags==phase:main cycles===TEMPLATE(main-cycles,10000000) threads=auto
+  astra:
+    - run driver=cql tags==phase:schema-astra threads==1 cycles==UNDEF
+    - run driver=cql tags==phase:rampup cycles===TEMPLATE(rampup-cycles,10000000) threads=auto
+    - run driver=cql tags==phase:main cycles===TEMPLATE(main-cycles,10000000) threads=auto      
 bindings:
   # for ramp-up and verify
   part_layout: Div(<<partsize:1000000>>); ToString() -> String
@@ -40,6 +44,21 @@ blocks:
         );
       tags:
         name: create-table
+  - name: schema-astra
+    tags:
+      phase: schema-astra
+    params:
+      prepared: false
+    statements:
+    - create-table: |
+        create table if not exists <<keyspace:baselines>>.<<table:tabular>> (
+         part text,
+         clust text,
+         data text,
+         PRIMARY KEY (part,clust)
+        );
+      tags:
+        name: create-table-astra
   - name: rampup
     tags:
       phase: rampup