class CassandraBolt implements Serializable {

    @SuppressWarnings("unchecked")
    public void prepare(Map<String, Object> stormConf, TopologyContext context) {
        Map<String, Object> config = (Map<String, Object>) stormConf.get(this.clientConfigKey);
        this.client = new AstyanaxClient<K, C, V>();
        this.client.start(config);
    }

    public  CassandraBolt(String clientConfigKey, TupleMapper<K, C, V> tupleMapper);

}