メソッドbulkSaveToCassandraをspark-cassandra-connectorで使用する方法

Question

私はCassandra Databaseでの挿入を最適化するために、bulkSaveToCassandraのspark-cassandra-connectorを使用しています。しかし、私は方法を見つけることができないと私はlibをインポートする方法がわからない。

現在、私はこの依存関係を使用しています：

Datastaxからの方法bulkSaveToCassandraの参照以下

<dependency> 
      <groupId>com.datastax.spark</groupId> 
      <artifactId>spark-cassandra-connector_2.11</artifactId> 
      <version>2.0.2</version> 
</dependency> 

を： http://docs.datastax.com/en/datastax_enterprise/4.7/datastax_enterprise/migration/migratingBulkSparkRDD.html

私がリンクに提示インポートを使用しますが、それはとにかく動作しません。

敬具、方法はDataStax Enterpriseでのみ利用可能であること

Answer 1

。

必要なクラスは、DSEインストールに付属するdse-spark * .jarの内部にあります。

たとえば、dse sparkシェルから利用できます。

通常の書き込み方法を使用することをお勧めしますが、bulkMethodは本番用のケースでうまく動作しない可用性の問題を持つsstableライターを使用するため、ほとんどの使用例では推奨します。