我是《暴风雪》和《Cassandra》的新手。我想用一个螺栓来写一个喷口发出的字符串,在Cassandra的一个列族中。我已经读过这个例子,它对我来说有点复杂,因为它使用不同的类来编写cassandradb。此外,我想知道字符串在cassandra数据库中被写了多少次。在这个示例中,对于我来说,不清楚如何控制在cassandradb中输入的字符串的数量?
简单地说,我需要一个螺栓来将喷口发出的字符串写入cassandra列族,例如200条记录?
提前谢谢!
我是《暴风雪》和《Cassandra》的新手。我想用一个螺栓来写一个喷口发出的字符串,在Cassandra的一个列族中。我已经读过这个例子,它对我来说有点复杂,因为它使用不同的类来编写cassandradb。此外,我想知道字符串在cassandra数据库中被写了多少次。在这个示例中,对于我来说,不清楚如何控制在cassandradb中输入的字符串的数量?
简单地说,我需要一个螺栓来将喷口发出的字符串写入cassandra列族,例如200条记录?
提前谢谢!
2条答案
按热度按时间lf5gs5x21#
您可以使用datastax cassandra驱动程序,也可以使用之前发布的storm cassandra库。
你的要求不清楚。你只想存储200个元组?
无论如何,用示例数据运行拓扑,在流结束后,查询cassandra,看看有什么。
apache storm和apache cassandra是非常深入和广泛的项目。没有走来走去的学习他们和做样本项目,以学习。
mzsu5hc02#
希望这会有帮助。
}