-2
Scala + SparkエコシステムでIDごとにつぶやきを取得するにはどうすればよいですか? IDのリストがあれば、実際のつぶやきを含むRDDを簡単に作成したいと思います。idによって個々のつぶやきを取り込む方法は?
スパークとTwitterストリーミングAPIに関するオンラインリソースはたくさんありますが、特定のつぶやきを取得するための類似のものは見つかりませんでした。
Scala + SparkエコシステムでIDごとにつぶやきを取得するにはどうすればよいですか? IDのリストがあれば、実際のつぶやきを含むRDDを簡単に作成したいと思います。idによって個々のつぶやきを取り込む方法は?
スパークとTwitterストリーミングAPIに関するオンラインリソースはたくさんありますが、特定のつぶやきを取得するための類似のものは見つかりませんでした。
これはあなたが望むように見えます。 idパラメータに渡されたカンマ区切り値によって指定されるよう
GETステータス/ルックアップは
戻り、要求当たり最大100件の ツイートためさえずるオブジェクトを完全に水和。 idパラメータに渡されたカンマ区切り値によって指定されるよう
要求、 当たり最大100件のツイートためTwitter4J here
に包まhere
戻り値完全水和つぶやきオブジェクトを参照してください。 このメソッドは、 のツイートIDのコレクションの詳細(水和)を取得するのに特に便利です。この方法は、 https://api.twitter.com/1.1/statuses/lookup.json
を呼び出し、あなたはストリーミングAPI自体から特定のつぶやきを取得したいと思いますか、あなたはすでにストリーミングツイートのリストから特定のツイートを選択するようにしたいですか? –
あなたはurサンプルデータと期待される出力形式を共有できますか? – BDR