2017-04-27 11 views
0

私はBig Data環境には新規ですので、よく分かりませんが、調査してpomファイルに依存関係を追加しましたが、spark StreamingContextを作成できません。私は任意のヘルプは大きな助けになるだろう依存性やは、scalaを通じてspark2.1.0のStreamingContextをインポートできません

以下の誤差の画像を添付しています。 私はあなたの輸入に関する詳細注意してくださいsparkバージョン2.1.0とscalaバージョン2.11.8

+0

プログラムにstreaming.StreamingContextそれを参照してください。 –

答えて

0

を使用しています。

Spark APIから、我々はそれを見ることができます:

StreamingContextオブジェクトの絶対パッケージパスは

org.apache.spark.streaming.StreamingContext 

あるしかし、あなたのイメージは、あなたがこのインポートパターンを持っていることを示しています。

import org.apache.spark._ 

これはあなたのIDEがStreamingContextの参照を見つけることができない理由のポイントです。

溶液は透明で、二つの選択肢です:

  1. import org.apache.spark.streaming._
  2. import org.apache.spark._とあなたがStreamingContextをインポートしていない
関連する問題