· 7 years ago · Jan 19, 2019, 03:48 PM
1# ebdse -v run type=cql yaml=baselines/key-value tags=phase:schema host=dsehost
2blocks:
3 - name: schema
4 tags:
5 phase: schema
6 params:
7 prepared: false
8 statements:
9 - |
10 create keyspace if not exists <<keyspace:baselines>>
11 WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '<<rf:1>>'}
12 AND durable_writes = true;
13 - |
14 create table if not exists <<keyspace:baselines>>.<<table:widerows>> (
15 part text,
16 clust timestamp,
17 data text,
18 PRIMARY KEY (part,clust)
19 );
20 - name: rampup
21 tags:
22 phase: rampup
23 params:
24 cl: <<write_cl:LOCAL_ONE>>
25 bindings:
26 part: Div(<<partsize:1000000>>); ToString() -> String
27 clust: StartingEpochMillis('2017-01-01 23:59:59'); AddHashRange(0L,31536000000L); StringDateWrapper("YYYY-MM-dd HH:mm:ss.SSS")
28 data: HashedFileExtractToString('data/lorem_ipsum_full.txt',50,150)
29 statements:
30 - |
31 insert into <<keyspace:baselines>>.<<table:widerows>>
32 (part,clust,data)
33 values (?part,?clust,?data)
34 - name: main-read
35 tags:
36 phase: main
37 type: read
38 params:
39 ratio: 5
40 cl: <<read_cl:LOCAL_ONE>>
41 statements:
42 - |
43 select * from <<keyspace:baselines>>.<<table:widerows>> where part=?part limit ?limit;
44 bindings:
45 limit: Uniform(1,10) -> int
46 part: Uniform(0,<<partcount:100>>)->int; ToString() -> String
47 clust: StartingEpochMillis('2017-01-01 23:59:59'); AddHashRange(0L,31536000000L); StringDateWrapper("YYYY-MM-dd HH:mm:ss.SSS")