spark-cassandra-connector

0熱

1答えて

RDD [PersonType] = [pid、cid、firstname、lastname、age、source、sourceType、message]の値はRDD = [1000,100、Vikash、Singh、33 、source、sourceType、message] ここでは、[pid、cid、firstname、lastname、age、dept、mrids]としてcsaandra行

0熱

1答えて

beelineまたはhive2 jdbcドライバ（Tableau）を使用している場合のDatastax接続の例外

Datastax enterprise 2.8をmy dev VM（Centos 7）にインストールしました。インストールがスムーズに完了し、単一ノードクラスタが機能しています。しかし、beelineやhive2 jdbcドライバを使ってクラスタに接続しようとすると、以下のようなエラーが出ます。私の主な目的は、Datastax EnterpriseドライバまたはSpark Sqlドライバを使用して

1熱

1答えて

DSE VMは（？多分）スパークしてカサンドラにDatastaxチュートリアルからVMを破損しているとエラーに実行

のVirtualBoxで起動時にエラーがスローされます私のMacはEl Capitanを運営しています。完全なVMと思われるものを正常にダウンロードできました。私はVirtualBoxのv5.0ではを使用していSpark.vboxの* サイズ：9174 私はFinderウィンドウから*の.vboxに-CLKをDBLたら、私は次のエラーを取得する： Failed to open a session

3熱

1答えて

スパークがcassandraノードを読み込みに選択する方法は？

N台のマシンにN個のノードを持つCassandraクラスタを持っています。また、私はすべてのマシンに作業員を派遣しています。私はDatastax spark-cassandraコネクタを使用しています。私は労働者（スタンドアロンモード）を設定しているときに私は彼らのためのマスターホストと言う。ドライバでは、spark.cassandra.connection.hostプロパティでCassandra

2熱

1答えて

スパークカサンドラコネクタ1.5.0

問題使用してカサンドラ3.0を接続できません - 私はスパーク1.5から使用してカサンドラ3.0を接続しようとした - スパークカサンドラコネクタに1.5.0 背景を使用してカサンドラ3.0を接続することができません。提供スパークカサンドラコネクタ1.5.0を使用したが、私はエラーの下に取得していますによって0 - DataStaxスパークカサンドラコネクタdocumentを1として、それはスパ

6熱

1答えて

Spark UIから出力サイズやレコードなどのメトリックを取得する方法は？

タスクまたはジョブの実行直後に、これらのメトリックをコンソール（SparkシェルまたはSparkサブミットジョブ）で収集する方法を教えてください。私たちはMysqlからCassandraにデータをロードするためにSparkを使用していますが、これは非常に巨大です（例：〜200 GBおよび600M行）。タスクが完了したら、正確に処理を開始した行の数を確認したいのですか？ Spark UIから数値を

0熱

1答えて

sparkクラスタでsession.execute（）がキャッサンドラに反映されない

キャッサンドラテーブルからデータが読み込まれるスパークジョブを実行しています。そのデータから、私はいくつかの挿入文と削除文を作成します。を実行してください。 boolean deleteStatus= connector.openSession().execute(delete).wasApplied(); boolean insertStatus = connector.openSessio

0熱

2答えて

spark-cassandraクラスタthriftserverへのsqlクエリは返されません

spark-cassandraクラスタが設定されています。 cqlshはうまく動作します。私はthriftserverを起動し、それに接続するためのコマンドラインを使用しました。私は use schemaname show schemas show tables を行うことができますが、簡単な select * from tablename がはまり込みます。 jdbc：hive2イン

1熱

1答えて

スパークカサンドラコネクタ - 句

私はDatasax Cassandra Connectorを使用してselect whereをやろうとしているが、私は次のエラーを取得しています： java.io.IOException: Exception during preparation of SELECT "path" FROM "tracking"."user_page_action" WHERE token("user_id") >

2熱

1答えて

spark cassandraコネクタはどのシステムテーブルを使用しますか？

スーパーユーザーではなく、cassandraに接続するためにユーザー名とパスワードを使用しています。スパーク付与の例外を使用して同じユーザーを使用しています。スパークがsystem.size_estimatesに接続しようとしています。他のシステムテーブルは、cassandraコネクタの使用を促します。 DBAからのアクセス権を取得するには、情報が必要です。また、READ権限が十分か、WR