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

Column Name: event
Validation Class:
org.apache.cassandra.db.marshal.UTF8Type
Compaction Strategy:
org.apache.cassandra.db.compaction.
SizeTieredCompactionStrategy
Compression Options:
sstable_compression:
org.apache.cassandra.io.compress.SnappyCompressor
4. Create a column family:
[default@unknown] USE myKeySpace;
[default@demo] CREATE COLUMN FAMILY appUsers
WITH comparator = UTF8Type
AND key_validation_class=UTF8Type
AND column_metadata = [
{column_name:user_name, validation_class: UTF8Type}
{column_name: Dept, validation_class: UTF8Type}
{column_name: email, validation_class: UTF8Type}
];
5. Insert data into the column family:
[default@demo] SET
appUsers['SS'][user_name']='shilpi';
[default@demo] SET appUsers['ss'][Dept]='BigData';
[default@demo] SET
appUsers['ss']['email']=[e-mail]';
Note
In this example, the code ss is my row key.
6. Retrieve data from the Cassandra column family:
GET appUsers[utf8('ss')][utf8('user_name')];
List appUsers;