IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

updated cql-timeseries2 to nb5 format and cql driver 4 types

Browse Source
This commit is contained in:
Jonathan Shook 2022-06-29 22:37:01 -05:00
parent 359edac3aa
commit 066615ec81
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
adapter-cqld4/src/main/resources/activities/baselinesv2/cql-timeseries2.yaml
View File

@ -19,7 +19,7 @@ params:
bindings: bindings:
machine_id: Mod(TEMPLATE(sources,10000)); ToHashedUUID() -> java.util.UUID machine_id: Mod(TEMPLATE(sources,10000)); ToHashedUUID() -> java.util.UUID
sensor_name: HashedLineToString('data/variable_words.txt') sensor_name: HashedLineToString('data/variable_words.txt')
time: Mul(TEMPLATE(timespeed,100)L); Div(TEMPLATE(sources,10000)L); ToDate() time: Mul(TEMPLATE(timespeed,100)L); Div(TEMPLATE(sources,10000)L); ToJavaInstant()
cell_timestamp: Mul(TEMPLATE(timespeed,100)L); Div(TEMPLATE(sources,10000)L); Mul(1000L) cell_timestamp: Mul(TEMPLATE(timespeed,100)L); Div(TEMPLATE(sources,10000)L); Mul(1000L)
sensor_value: Normal(0.0,5.0); Add(100.0) -> double sensor_value: Normal(0.0,5.0); Add(100.0) -> double
station_id: Div(TEMPLATE(sources,10000));Mod(TEMPLATE(stations,100)); ToHashedUUID() -> java.util.UUID station_id: Div(TEMPLATE(sources,10000));Mod(TEMPLATE(stations,100)); ToHashedUUID() -> java.util.UUID
@ -68,38 +68,34 @@ blocks:
rampup: rampup:
params: params:
cl: TEMPLATE(write_cl,LOCAL_QUORUM) cl: TEMPLATE(write_cl,LOCAL_QUORUM)
idempotent: true
instrument: TEMPLATE(instrument-writes,TEMPLATE(instrument,false))
ops: ops:
insert-rampup: | insert-rampup: |
insert into TEMPLATE(keyspace,baselines).TEMPLATE(table,iot) insert into TEMPLATE(keyspace,baselines).TEMPLATE(table,iot)
(machine_id, sensor_name, time, sensor_value, station_id, data) (machine_id, sensor_name, time, sensor_value, station_id, data)
values ({machine_id}, {sensor_name}, {time}, {sensor_value}, {station_id}, {data}) values ({machine_id}, {sensor_name}, {time}, {sensor_value}, {station_id}, {data})
using timestamp {cell_timestamp} using timestamp {cell_timestamp}
params:
idempotent: true
instrument: TEMPLATE(instrument-writes,TEMPLATE(instrument,false))
verify: verify:
type: read
params: params:
ratio: 1 ratio: 1
cl: TEMPLATE(read_cl,LOCAL_QUORUM) cl: TEMPLATE(read_cl,LOCAL_QUORUM)
instrument: TEMPLATE(instrument-reads,TEMPLATE(instrument,false))
ops: ops:
select-verify: | select-verify: |
select * from TEMPLATE(keyspace,baselines).TEMPLATE(table,iot) select * from TEMPLATE(keyspace,baselines).TEMPLATE(table,iot)
where machine_id={machine_id} and sensor_name={sensor_name} and time={time}; where machine_id={machine_id} and sensor_name={sensor_name} and time={time};
verify-fields: "*, -cell_timestamp" verify-fields: "*, -cell_timestamp"
params:
instrument: TEMPLATE(instrument-reads,TEMPLATE(instrument,false))
main-read: main-read:
params: params:
ratio: TEMPLATE(read_ratio,1) ratio: TEMPLATE(read_ratio,1)
cl: TEMPLATE(read_cl,LOCAL_QUORUM) cl: TEMPLATE(read_cl,LOCAL_QUORUM)
instrument: TEMPLATE(instrument-reads,TEMPLATE(instrument,false))
ops: ops:
select-read: | select-read: |
select * from TEMPLATE(keyspace,baselines).TEMPLATE(table,iot) select * from TEMPLATE(keyspace,baselines).TEMPLATE(table,iot)
where machine_id={machine_id} and sensor_name={sensor_name} where machine_id={machine_id} and sensor_name={sensor_name}
limit TEMPLATE(limit,10) limit TEMPLATE(limit,10)
params:
instrument: TEMPLATE(instrument-reads,TEMPLATE(instrument,false))
main-write: main-write:
type: write type: write
params: params:
@ -114,4 +110,3 @@ blocks:
params: params:
instrument: TEMPLATE(instrument-writes,TEMPLATE(instrument,false)) instrument: TEMPLATE(instrument-writes,TEMPLATE(instrument,false))
idempotent: true idempotent: true