apache-spark - Java でスパーク ストリーミングを介して Twitter ストリームに地理位置情報フィルターを追加します。

Question

特定の地理的位置のみに関連するツイートが必要です。グーグルで調べたところ、TwitterUtils および TwitterInputDStream クラスに追加のメソッド/機能を追加することでこれを実現できることがわかりました。しかし、これらは最終クラスであるため、そうすることができません。

どうすればこれを達成できますか?

前もって感謝します。

Answer 1

これは、ストリームを作成するときにこれを行うために見つけた最良の答えです。ただし、このフィルターでは、ツイートを受信した後にフィルター処理しています。フィルターをtwitter apiに提供することで、それらを受信する前にフィルタリングする方法があると思います。このコードは動作することが確認されており、http: //www.michael-goettsche.de/?p= 19#return-note-19-4 から取得されています。

    JavaDStream<Status> tweetsWithLocation = twitterStream.filter(
            new Function<Status, Boolean>() {
                public Boolean call(Status status){
                    if (status.getGeoLocation() != null) {
                        return true;
                    } else {
                        return false;
                    }
                }
            }
    );

    JavaDStream<String> statuses = tweetsWithLocation.map(
            new Function<Status, String>() {
                public String call(Status status) {
                    return status.getGeoLocation().toString() + ": " + status.getText();
                }
            }
    );