Spark Streaming アプリケーションの DStreams に含まれるデータに対して Shark クエリを実行することは可能ですか? (たとえば foreachRDD 呼び出し内)
それを行うための特定の API はありますか?
ありがとう。
Spark Streaming アプリケーションの DStreams に含まれるデータに対して Shark クエリを実行することは可能ですか? (たとえば foreachRDD 呼び出し内)
それを行うための特定の API はありますか?
ありがとう。
誰かが同じ問題について心配している場合、私の質問に答えるには: 私の質問に対する直接の答えは NO です。Spark ストリーミング データに対して直接 Shark を実行することはできません。
Spark SQL は現在有効な代替手段ですが、少なくとも私のニーズには合っていました。これは Spark に含まれており、追加の構成は必要ありません。ここで確認できます: http://spark.apache.org/docs/latest/sql-programming-guide.html