// Path: src/main/java/tutorial/storm/trident/testutil/Content.java
// public class Content {
//     private static final Logger log = LoggerFactory.getLogger(Content.class);
// 
//     private long tweetId;
//     private long userId;
//     private long createdAtMs;
// 
//     private String contentName;
//     private String contentType;
// 
//     public Content(long tweetId, long userId, long createdAtMs) {
//         this.tweetId = tweetId;
//         this.userId = userId;
//         this.createdAtMs = createdAtMs;
//     }
// 
//     public String getContentId(){
//         HashFunction md5 = Hashing.md5();
//         return md5.hashString(contentType + contentName).toString();
//     }
// 
//     public String getContentName() {
//         return contentName;
//     }
// 
//     public void setContentName(String contentName) {
//         this.contentName = contentName;
//     }
// 
//     public void setContentType(String contentType) {
//         this.contentType = contentType;
//     }
// 
//     public long getTweetId() {
//         return tweetId;
//     }
// 
//     public void setTweetId(long tweetId) {
//         this.tweetId = tweetId;
//     }
// 
//     public long getUserId() {
//         return userId;
//     }
// 
//     public void setUserId(long userId) {
//         this.userId = userId;
//     }
// 
//     public long getCreatedAtMs() {
//         return createdAtMs;
//     }
// 
//     public void setCreatedAtMs(long createdAtMs) {
//         this.createdAtMs = createdAtMs;
//     }
// 
//     @Override
//     public String toString() {
//         return "Content{" +
//                 "contentType='" + contentType + '\'' +
//                 ", contentName='" + contentName + '\'' +
//                 '}';
//     }
// 
//     public String getContentType() {
//         return contentType;
//     }
// }


import storm.trident.operation.BaseFilter;
import storm.trident.tuple.TridentTuple;
import tutorial.storm.trident.testutil.Content;
package tutorial.storm.trident.operations;



/**
 * @author Enno Shioji (enno.shioji@peerindex.com)
 */
public class OnlyHashtags extends BaseFilter {
    @Override
    public boolean isKeep(TridentTuple tuple) {
// Path: src/main/java/tutorial/storm/trident/testutil/Content.java
// public class Content {
//     private static final Logger log = LoggerFactory.getLogger(Content.class);
// 
//     private long tweetId;
//     private long userId;
//     private long createdAtMs;
// 
//     private String contentName;
//     private String contentType;
// 
//     public Content(long tweetId, long userId, long createdAtMs) {
//         this.tweetId = tweetId;
//         this.userId = userId;
//         this.createdAtMs = createdAtMs;
//     }
// 
//     public String getContentId(){
//         HashFunction md5 = Hashing.md5();
//         return md5.hashString(contentType + contentName).toString();
//     }
// 
//     public String getContentName() {
//         return contentName;
//     }
// 
//     public void setContentName(String contentName) {
//         this.contentName = contentName;
//     }
// 
//     public void setContentType(String contentType) {
//         this.contentType = contentType;
//     }
// 
//     public long getTweetId() {
//         return tweetId;
//     }
// 
//     public void setTweetId(long tweetId) {
//         this.tweetId = tweetId;
//     }
// 
//     public long getUserId() {
//         return userId;
//     }
// 
//     public void setUserId(long userId) {
//         this.userId = userId;
//     }
// 
//     public long getCreatedAtMs() {
//         return createdAtMs;
//     }
// 
//     public void setCreatedAtMs(long createdAtMs) {
//         this.createdAtMs = createdAtMs;
//     }
// 
//     @Override
//     public String toString() {
//         return "Content{" +
//                 "contentType='" + contentType + '\'' +
//                 ", contentName='" + contentName + '\'' +
//                 '}';
//     }
// 
//     public String getContentType() {
//         return contentType;
//     }
// }


// Path: src/main/java/tutorial/storm/trident/operations/OnlyHashtags.java
import storm.trident.operation.BaseFilter;
import storm.trident.tuple.TridentTuple;
import tutorial.storm.trident.testutil.Content;

package tutorial.storm.trident.operations;



/**
 * @author Enno Shioji (enno.shioji@peerindex.com)
 */
public class OnlyHashtags extends BaseFilter {
    @Override
    public boolean isKeep(TridentTuple tuple) {
        Content content = (Content)tuple.get(0);