package com.trident.fork.joins.test;

/**
 * @author dkirankumar
 */
import storm.trident.operation.BaseFunction;
import storm.trident.operation.TridentCollector;
import storm.trident.tuple.TridentTuple;
import backtype.storm.tuple.Values;

class ThirdFunction extends BaseFunction {

	@Override
	public void execute(TridentTuple tuple, TridentCollector collector) {
		String requestId = tuple.getStringByField("RequestId");
		collector.emit(new Values("ColumnMapId_1", "Value3"));
		collector.emit(new Values("ColumnMapId_3", "Value3"));
	}
}