我使用twittersource作为cloudera的flume。我想获得特定关键字的国家推特。当我想从荷兰得到tweet时，我不知道该拿什么来比较。我有以下结果，导致没有任何处理：

public void onStatus(Status status) {
    if(status.getPlace().getCountry().equalsIgnoreCase("netherlands")) {
        headers.put("timestamp", String.valueOf(status.getCreatedAt().getTime()));
        Event event = EventBuilder.withBody(DataObjectFactory.getRawJSON(status).getBytes(), headers);
        channel.processEvent(event);
    }
}

我之所以不使用filterquery是因为我想用它作为关键字。如果我把这两者结合起来，就会是逻辑上的“与”与“非”与“与”。

FilterQuery query = new FilterQuery().track(keywords);