Я использую TwitterSource для Flume из Cloudera. Я хочу получать твиты по странам с определенными ключевыми словами. Я не уверен, что сравнивать с тем, когда я хочу получить твиты из Нидерландов. У меня есть следующие, что приводит к ничего обрабатываемый:Получить страну из твита с определенными ключевыми словами
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);