Adding NoSQL Persistence to Storm - Real-time Analytics with Storm and Cassandra - page 138

From the Cassandra cluster, a UI-based consumer retrieves the data based on a search
query defined by the user, thus providing the adhoc, real-time reporting over live data.
For the sake of our implementation, we will query the data from CLI/CQLSH as shown
here:
1. Create a keyspace:
create keyspace my_keyspace with placement_strategy =
'SimpleStrategy' and strategy_options =
{replication_factor : 3} and durable_writes = true;
use my_keyspace;
2. Create the column family:
create column family my_columnfamily
with column_type = 'Standard'
and comparator = 'UTF8Type'
and default_validation_class = 'BytesType'
and key_validation_class = 'TimeUUIDType'
and read_repair_chance = 0.1
and dclocal_read_repair_chance = 0.0
and gc_grace = 0
and min_compaction_threshold = 4
and max_compaction_threshold = 32
and replicate_on_write = true
and compaction_strategy =
'org.apache.cassandra.db.compaction.
SizeTieredCompactionStrategy'
and caching = 'KEYS_ONLY'
and bloom_filter_fp_chance = 0.5
and column_metadata = [
{column_name : 'cellnumber',
validation_class : Int32Type },
{column_name : 'tollchrg',
validation_class : UTF8Type},
{column_name : 'msgres',
validation_class : UTF8Type},
{column_name : 'servicetype',