SparkからCassandraへのアクセス

DataStax Enterpriseでは、SparkがCassandraと統合されています。そのため、SparkからCassandraテーブルのすべての機能を使用できます。

SparkアプリケーションからCassandraへのアクセス

SparkアプリケーションからCassandraにアクセスするには、Sparkの例「Sparkを使用したPortfolio Managerのデモ」の手順に従います。

SparkシェルからCassandraへのアクセス

DataStax Enterpriseでは、CassandraとSparkの統合を可能にするためにSpark Cassandra Connectorが使用されます。SparkシェルをDataStax Enterpriseで実行することにより、エンリッチ形式のSpark Contextオブジェクト（sc）にアクセスして、Cassandraに直接アクセスできるようになります。

SparkシェルからCassandraにアクセスするには、dse sparkコマンドを実行して、その後に表示されるセクションの手順に従います。

$ dse spark

Welcome to
      ____              __
     / __/__  ___ _____/ /__
_\ \/ _ \/ _ `/ __/  '_/
/___/ .__/\_,_/_/ /_/\_\   version 1.6.1
      /_/

Using Scala version 2.10.5 (OpenJDK 64-Bit Server VM, Java 1.8.0_91)
Type in expressions to have them evaluated.
Type :help for more information.
Creating SparkContext...
Created spark context..
Spark context available as sc.
Hive context available as sqlContext.Will be initialized on first use.

scala>