spark-job/src/test/resources/cql-stress-narrow1.yaml

#
# Keyspace info
#
keyspace: difftest

#
# The CQL for creating a keyspace (optional if it already exists)
#
keyspace_definition: |
  CREATE KEYSPACE difftest WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1};

#
# Table info
#
table: narrow1

#
# The CQL for creating a table you wish to stress (optional if it already exists)
#
table_definition: |
  CREATE TABLE narrow1 (
        pk int,
        v1 text,
        v2 int,
        PRIMARY KEY(pk)
  ) 
    WITH compaction = { 'class':'LeveledCompactionStrategy' }

#
# Optional meta information on the generated columns in the above table
# The min and max only apply to text and blob types
# The distribution field represents the total unique population
# distribution of that column across rows.  Supported types are
# 
#      EXP(min..max)                        An exponential distribution over the range [min..max]
#      EXTREME(min..max,shape)              An extreme value (Weibull) distribution over the range [min..max]
#      GAUSSIAN(min..max,stdvrng)           A gaussian/normal distribution, where mean=(min+max)/2, and stdev is (mean-min)/stdvrng
#      GAUSSIAN(min..max,mean,stdev)        A gaussian/normal distribution, with explicitly defined mean and stdev
#      UNIFORM(min..max)                    A uniform distribution over the range [min, max]
#      FIXED(val)                           A fixed distribution, always returning the same value
#      Aliases: extr, gauss, normal, norm, weibull
#
#      If preceded by ~, the distribution is inverted
#
# Defaults for all columns are size: uniform(4..8), population: uniform(1..100B), cluster: fixed(1)
#
columnspec:
  - name: pk
    population: uniform(1..1B)
  - name: v1
    size: fixed(20)
  - name: v2
    population: uniform(1..100)

insert:
  partitions: fixed(50)       # number of unique partitions to update in a single operation
  batchtype: UNLOGGED         # type of batch to use

queries:
   simple1:
      cql: select * from narrow1 where pk = ? LIMIT 100
      fields: samerow         # samerow or multirow (select arguments from the same row, or randomly from all rows in the partition)