BulkLoader cassandra java api 示例上传 SSTable 到 cassandra 集群

问题描述 投票:0回答:0

我正在尝试将 csv 数据文件上传到 cassandra 集群。这应该是一个连续的过程,为此我正在创建一个简单的 java 应用程序,它将读取 csv 文件,然后将其转换为 SSTable,然后将其上传到 cassandra 集群。

我能够使用 CQLSSTableWriter 实现第一步,并且能够创建本地 SSTable 数据。根据我的搜索,我了解到我们必须使用 apache.cassandra.tools 提供的 BulkLoader 将 SSTable 上传到集群。我想不通那部分。此外,我的 SSTable 副本将在本地,而不是在运行集群的服务器中。如果可能的话,有人可以帮助我如何实现它,这真的很有帮助。

补充:我的实际用例是将数据从Sybase连续归档到cassandra为此我试图创建一个Sybase数据的csv并将其上传到Sybase,因为数据将以数百万计。这里也欢迎任何其他方法。

cassandra cassandra-3.0 bulk-load
© www.soinside.com 2019 - 2024. All rights reserved.