我想将一些数据从现有数据库迁移到Cassandra DB。迁移后,我想验证所有数据是否都迁移成功。我想知道Cassandra Driver for JAVA是否提供了任何内部实现功能来验证这一点,这样我就可以减少与Cassandra DB交互时产生的不必要的开销。
发布于 2017-04-10 21:41:45
这完全取决于您要从其迁移的数据库的类型,您可以在以前的数据库中逐行检查行,然后对cassandra进行查询,看看行是否在那里。这将是最安全的方法。
然后你可以做一些非常复杂的事情,比如让spark工作来做比较。
或者,您可以迭代cassandra中的所有行,并对照原始数据库进行检查。如下所示:Fetch all rows in cassandra
这份清单可能会继续下去。有关详细信息,您必须更多地了解原始数据库,cassandra中的数据模型,并提供一些上下文,说明要验证的行的含义……而不是它在那里。
https://stackoverflow.com/questions/43320332
复制相似问题