您可以使用datastax cassandra驱动程序，也可以使用之前发布的storm cassandra库。
你的要求不清楚。你只想存储200个元组？
无论如何，用示例数据运行拓扑，在流结束后，查询cassandra，看看有什么。
apache storm和apache cassandra是非常深入和广泛的项目。没有走来走去的学习他们和做样本项目，以学习。

希望这会有帮助。

/*Main Class */
    TopologyBuilder builder = new TopologyBuilder();
    Config conf = new Config();
    conf.put("cassandra.keyspace", "Storm_Output"); //Key_space name
    conf.put("cassandra.nodes","ip-address-of-cassandra-machine");
    conf.put("cassandra.port",9042);
    //port on which cassandra is running (Default:9042)

    builder.setSpout("generator", new RandomSentenceSpout(), 1);

    builder.setBolt("counter", new CassandraInsertionBolt(), 1).shuffleGrouping("generator");

    builder.setBolt("CassandraBolt",new CassandraWriterBolt(
            async(
                    simpleQuery("INSERT INTO Storm_Output.tanle_name  (field1,field2 ) VALUES (?,?);")
                        .with(
                            fields("field1","field2 ")
                         )
                    )
            ), 1).globalGrouping("counter");  

    // Config conf = new Config();
    conf.setDebug(true);
    conf.setNumWorkers(1);

    StormSubmitter.submitTopologyWithProgressBar("Cassnadra-Insertion", conf, builder.createTopology());

/*Bolt sending data for insertion into cassandra */
/*CassandraWriter Bolt */
public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {

    Random rand=new Random();       
    basicOutputCollector.emit(new Values(rand.nextInt(20),rand.nextInt(20)));

}

public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
    // TODO Auto-generated method stub
    outputFieldsDeclarer.declare(new Fields("field1","field2"));
}

}