package com.trident.fork.joins.test;
/**
 * @author dkirankumar
 */
import storm.trident.operation.BaseFilter;
import storm.trident.tuple.TridentTuple;

class PrintFilter extends BaseFilter {

		private String name;

		public PrintFilter(String name) {
			super();
			this.name = name;
		}

		@Override
		public boolean isKeep(TridentTuple tuple) {
			System.out.println("## PrintFilter [" + name + "]: " + tuple.getValues());
			return true;
		}

	}