ExtractHashTagBolt.java

public void execute(Tuple input) {
    Object obj = input.getValueByField("tweet");
    if (obj instanceof Status) {
        try {
            final Status status = (Status) obj;
            LOGGER.debug("input tweet : {}", status);
            final HashtagEntity[] hashtags = status.getHashtagEntities();
            
            if (hashtags != null) {
                for(HashtagEntity hashtag : hashtags) {
                    if (hashtag != null) {
                        final String strHashtag = hashtag.getText();
                        collector.emit(new Values(strHashtag));
                        LOGGER.debug("emit hashtag text : {}", strHashtag);
                    }
                }
            }
        } catch (Exception e) {
            LOGGER.error("Exception occurred. {}", e);
        }
    }
    collector.ack(input);
}