【发布时间】:2015-02-27 10:18:04
【问题描述】:
我正在使用来自 Cloudera 的 TwitterSource for Flume。我想按国家/地区获取带有某些关键字的推文。当我想从荷兰获得推文时,我不确定要与什么比较。我有以下导致没有被处理:
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 的原因是因为我想将其用于关键字。如果我把它结合起来,那将是逻辑 OR 而不是 AND。
FilterQuery query = new FilterQuery().track(keywords);
【问题讨论】:
标签: java twitter4j cloudera flume