2017-03-23 14 views
-2

Scala + SparkエコシステムでIDごとにつぶやきを取得するにはどうすればよいですか? IDのリストがあれば、実際のつぶやきを含むRDDを簡単に作成したいと思います。idによって個々のつぶやきを取り込む方法は?

スパークとTwitterストリーミングAPIに関するオンラインリソースはたくさんありますが、特定のつぶやきを取得するための類似のものは見つかりませんでした。

+0

を呼び出し、あなたはストリーミングAPI自体から特定のつぶやきを取得したいと思いますか、あなたはすでにストリーミングツイートのリストから特定のツイートを選択するようにしたいですか? –

+1

あなたはurサンプルデータと期待される出力形式を共有できますか? – BDR

答えて

1

これはあなたが望むように見えます。 idパラメータに渡されたカンマ区切り値によって指定されるよう

GETステータス/ルックアップは
戻り、要求当たり最大100件の ツイートためさえずるオブジェクトを完全に水和。 idパラメータに渡されたカンマ区切り値によって指定されるよう

要求、 当たり最大100件のツイートためTwitter4J here

に包まhere

戻り値完全水和つぶやきオブジェクトを参照してください。 このメソッドは、 のツイートIDのコレクションの詳細(水和)を取得するのに特に便利です。この方法は、 https://api.twitter.com/1.1/statuses/lookup.json

関連する問題